//XMLmapperBuilder
private void configurationElement(XNode context) {
  try {
    // 獲取<mapper>標(biāo)簽的namespace值，也就是命名空間
    String namespace = context.getStringAttribute("namespace");
    // 命名空間不能為空
    if (namespace == null || namespace.isEmpty()) {
      throw new BuilderException("Mapper's namespace cannot be empty");
    }
    // MapperBuilderAssistant:構(gòu)建MappedStatement對(duì)象的構(gòu)建助手，設(shè)置當(dāng)前的命名空間為namespace的值
    builderAssistant.setCurrentNamespace(namespace);
    ......
        
    // 解析<cache>子標(biāo)簽,這里生成二級(jí)緩存
    cacheElement(context.evalNode("cache"));

    ......
  } catch (Exception e) {
    throw new BuilderException("Error parsing Mapper XML. The XML location is '" + resource + "'. Cause: " + e, e);
  }
}

//XMLmapperBuilder
private void cacheElement(XNode context) {
  if (context != null) {
    // 解析<cache>標(biāo)簽type屬性的值，在這可以自定義type的值，比如redisCache,如果沒有指定默認(rèn)就是PERPETUAL
    String type = context.getStringAttribute("type", "PERPETUAL");
    Class<? extends Cache> typeClass = typeAliasRegistry.resolveAlias(type);
    // 獲取負(fù)責(zé)過期的eviction對(duì)象，默認(rèn)策略為L(zhǎng)RU
    String eviction = context.getStringAttribute("eviction", "LRU");
    Class<? extends Cache> evictionClass = typeAliasRegistry.resolveAlias(eviction);
    // 清空緩存的頻率 0代表不清空
    Long flushInterval = context.getLongAttribute("flushInterval");
    // 緩存容器的大小
    Integer size = context.getIntAttribute("size");
    // 是否只讀
    boolean readWrite = !context.getBooleanAttribute("readOnly", false);
    // 是否阻塞
    boolean blocking = context.getBooleanAttribute("blocking", false);
    // 獲得Properties屬性
    Properties props = context.getChildrenAsProperties();
    //builderAssistant是MapperBuilderAssistant，作用就是解耦建立MapperStatement，因?yàn)?
    //MapperStatement對(duì)象創(chuàng)建復(fù)雜，所以用這個(gè)類來解耦創(chuàng)建
    builderAssistant.useNewCache(typeClass, evictionClass, flushInterval, size, readWrite, blocking, props);
  }
}

public class PerpetualCache implements Cache {

  private final String id;

  private final Map<Object, Object> cache = new HashMap<>();

//CachingExecutor
@Override
public <E> List<E> query(MappedStatement ms, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql)
    throws SQLException {
  // 獲取二級(jí)緩存，是從MapperStatement里面獲取的
  Cache cache = ms.getCache();
  if (cache != null) {
    // 刷新tcm的緩存 （存在緩存且flushCache為true時(shí)）
    flushCacheIfRequired(ms);
    if (ms.isUseCache() && resultHandler == null) {
      ensureNoOutParams(ms, boundSql);
      @SuppressWarnings("unchecked")
      // 從二級(jí)緩存中查詢數(shù)據(jù)
      List<E> list = (List<E>) tcm.getObject(cache, key);
      // 如果二級(jí)緩存中沒有查詢到數(shù)據(jù)，則查詢一級(jí)緩存及數(shù)據(jù)庫
      if (list == null) {
        // 委托給BaseExecutor執(zhí)行
        list = delegate.query(ms, parameterObject, rowBounds, resultHandler, key, boundSql);
        // 將查詢結(jié)果 要存到二級(jí)緩存中（注意：此處只是存到map集合中，沒有真正存到二級(jí)緩存中）
        tcm.putObject(cache, key, list); // issue #578 and #116
      }
      return list;
    }
  }
  // 如果沒有開啟二級(jí)緩存或開啟了沒查到二級(jí)緩存則委托給BaseExecutor執(zhí)行下一步查詢
  return delegate.query(ms, parameterObject, rowBounds, resultHandler, key, boundSql);
}

public class TransactionalCacheManager {

  // Cache 與 TransactionalCache 的映射關(guān)系表
  private final Map<Cache, TransactionalCache> transactionalCaches = new HashMap<>();
    
  public Object getObject(Cache cache, CacheKey key) {
    // 直接從TransactionalCache中獲取緩存
    return getTransactionalCache(cache).getObject(key);
  }

  public void putObject(Cache cache, CacheKey key, Object value) {
    // 直接存入TransactionalCache的緩存中
    getTransactionalCache(cache).putObject(key, value);
  }
    
  private TransactionalCache getTransactionalCache(Cache cache) {
    // 從映射表中獲取 TransactionalCache，下面代碼等同于
    // transactionalCaches.computeIfAbsent(cache, TransactionalCache::new);
    return MapUtil.computeIfAbsent(transactionalCaches, cache, TransactionalCache::new);
  }

public class TransactionalCache implements Cache {
   /* 二級(jí)緩存 Cache 對(duì)象。
   */
  private final Cache delegate;
  /**
   * 提交時(shí)，清空 {@link #delegate}
   *
   * 初始時(shí)，該值為 false
   * 清理后{@link #clear()} 時(shí)，該值為 true ，表示持續(xù)處于清空狀態(tài)
   */
  private boolean clearOnCommit;
  /**
   *  // 在事務(wù)被提交前，所有從數(shù)據(jù)庫中查詢的結(jié)果將緩存在此集合中
   */
  private final Map<Object, Object> entriesToAddOnCommit;
  /**
   *   在事務(wù)被提交前，當(dāng)緩存未命中時(shí)，CacheKey 將會(huì)被存儲(chǔ)在此集合中
   */
  private final Set<Object> entriesMissedInCache;
  
  public Object getObject(Object key) {
    // issue #116
    // 查詢的時(shí)候是直接從delegate（就是MapperSatement的二級(jí)緩存對(duì)象）中去查詢的
    Object object = delegate.getObject(key);
    // 如果不存在，則添加到 entriesMissedInCache 中
    if (object == null) {
      // 緩存未命中，則將 key 存入到 entriesMissedInCache 中
      entriesMissedInCache.add(key);
    }
    // issue #146
    // 如果 clearOnCommit 為 true ，表示處于持續(xù)清空狀態(tài)，則返回 null
    if (clearOnCommit) {
      return null;
    } else {
      // 返回 value
      return object;
    }
  }

//TransactionalCache
public void putObject(Object key, Object object) {
  // 將鍵值對(duì)存入到 entriesToAddOnCommit 這個(gè)Map中中，而非真實(shí)的緩存對(duì)象 delegate 中
  entriesToAddOnCommit.put(key, object);
}

public void commit() {
  // 如果 clearOnCommit 為 true ，則清空 delegate 緩存
  if (clearOnCommit) {
    delegate.clear();
  }
  // 將 entriesToAddOnCommit、entriesMissedInCache 刷入 delegate(cache) 中
  flushPendingEntries();
  // 重置
  reset();
}

private void flushPendingEntries() {
    // 將 entriesToAddOnCommit 中的內(nèi)容轉(zhuǎn)存到 delegate 中
    for (Map.Entry<Object, Object> entry : entriesToAddOnCommit.entrySet()) {
      // 在這里真正的將entriesToAddOnCommit的對(duì)象逐個(gè)添加到delegate中，只有這時(shí)，二級(jí)緩存才真正的生效
      delegate.putObject(entry.getKey(), entry.getValue());
    }
    // 將 entriesMissedInCache 刷入 delegate 中
    for (Object entry : entriesMissedInCache) {
      if (!entriesToAddOnCommit.containsKey(entry)) {
        delegate.putObject(entry, null);
      }
    }
  }