掘金 后端 ( ) • 2024-06-28 11:34

MyBatis 提供了两级缓存机制:一级缓存(Session级别)和二级缓存(全局级别),以提高应用的性能通过减少数据库的查询次数。

一级缓存(Session级别)

一级缓存是基于 SQL 会话(SqlSession)的,它是默认开启的。一级缓存的生命周期与 SQL 会话一致,当会话结束时,缓存也随之消失。这意味着,在同一个 SQL 会话中,对于相同的查询请求,第一次会从数据库中获取数据,并缓存结果;之后相同的查询请求将直接从缓存中获取数据,不会再去访问数据库。

try (SqlSession session = sqlSessionFactory.openSession()) {
    BlogMapper mapper = session.getMapper(BlogMapper.class);
    
    // 第一次查询,数据来自数据库
    Blog blog1 = mapper.selectBlogById(1);
    // 第二次查询,相同的会话中,数据来自一级缓存
    Blog blog2 = mapper.selectBlogById(1);
}

一级缓存主要是利用了一个 Map 来存储缓存数据,关键代码在 DefaultSqlSession 类中的 selectList 方法里,它使用了 Executorquery 方法来实现。

public <E> List<E> selectList(String statement, Object parameter, RowBounds rowBounds) {
    try {
        MappedStatement ms = configuration.getMappedStatement(statement);
        return executor.query(ms, wrapCollection(parameter), rowBounds, Executor.NO_RESULT_HANDLER);
    } catch (Exception e) {
        throw ExceptionFactory.wrapException("Error querying database.  Cause: " + e, e);
    } finally {
        ErrorContext.instance().reset();
    }
}

CachingExecutor 类的 query 方法中实现了一级缓存的逻辑:

public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler) throws SQLException {
    BoundSql boundSql = ms.getBoundSql(parameter);
    CacheKey key = createCacheKey(ms, parameter, rowBounds, boundSql);
    return query(ms, parameter, rowBounds, resultHandler, key, boundSql);
}

二级缓存(全局级别)

二级缓存是跨 SQL 会话的,它基于 namespace 级别。开启二级缓存后,数据会存储在全局作用域内,这意味着,即使 SQL 会话关闭,缓存数据仍然可用,可以被其他 SQL 会话复用。

要启用二级缓存,需要在 MyBatis 配置文件中添加相应的配置,并在映射文件中明确指定哪些映射器使用二级缓存。

<!-- 在 mybatis-config.xml 中启用全局二级缓存 -->
<configuration>
    <settings>
        <setting name="cacheEnabled" value="true"/>
    </settings>
</configuration>

在映射文件中使用二级缓存:

<!-- 在 Mapper.xml 中开启二级缓存 -->
<cache eviction="FIFO" flushInterval="60000" size="512" readOnly="true"/>

二级缓存的关键实现在 CachingExecutor 类:

public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler,
                         CacheKey key, BoundSql boundSql) throws SQLException {
    Cache cache = ms.getCache();
    if (cache != null) {
        flushCacheIfRequired(ms);
        if (ms.isUseCache() && resultHandler == null) {
            ensureNoOutParams(ms, boundSql);
            @SuppressWarnings("unchecked")
            List<E> list = (List<E>) tcm.getObject(cache, key);
            if (list == null) {
                list = delegate.query(ms, parameter, rowBounds, resultHandler, key, boundSql);
                tcm.putObject(cache, key, list); // issue #578 and #116
            }
            return list;
        }
    }
    return delegate.query(ms, parameter, rowBounds, resultHandler, key, boundSql);
}

区别总结

  • 作用范围:一级缓存是基于 SqlSession 的,其生命周期也随之绑定;而二级缓存是基于 Mapper 的 namespace,对整个应用有效。
  • 生命周期:一级缓存随着 SQL 会话的结束而失效,二级缓存则可以跨会话使用。
  • 可自定义性:二级缓存提供了更多的自定义设置,例如失效策略、大小限制等,通过在 Mapper.xml 中配置 <cache> 标签来实现。
  • 数据安全:二级缓存由于是跨会话的,使用时需要更加注意数据的一致性问题。在使用二级缓