# 缓存
MyBatis
内置了一个强大的事务性查询缓存机制,它可以非常方便地配置和定制。
默认情况下,只启用了本地的会话缓存(一级缓存),它仅仅对一个会话(SqlSession
)中的数据进行缓存。 要启用全局的二级缓存,只需要在你的 SQL 映射文件中添加一行:
<cache/>
基本上就是这样。这个简单语句的效果如下:
- 映射语句文件中的所有 select 语句的结果将会被缓存。
- 映射语句文件中的所有 insert、update 和 delete 语句会刷新缓存。
- 缓存会使用最近最少使用算法(LRU, Least Recently Used)算法来清除不需要的缓存。
- 缓存不会定时进行刷新(也就是说,没有刷新间隔)。
- 缓存会保存列表或对象(无论查询方法返回哪种)的 1024 个引用。
- 缓存会被视为读/写缓存,这意味着获取到的对象并不是共享的,可以安全地被调用者修改,而不干扰其他调用者或线程所做的潜在修改。
# 一级缓存
一级缓存Local Cache
的查询和写入是在Executor
内部完成的。在org.apache.ibatis.executor.BaseExecutor
源码中,Local Cache
就是它内部的一个成员变量。
BaseExecutor
相关构造函数如下:
protected BaseExecutor(Configuration configuration, Transaction transaction) {
this.transaction = transaction;
this.deferredLoads = new ConcurrentLinkedQueue<>();
this.localCache = new PerpetualCache("LocalCache");
this.localOutputParameterCache = new PerpetualCache("LocalOutputParameterCache");
this.closed = false;
this.configuration = configuration;
this.wrapper = this;
}
2
3
4
5
6
7
8
9
BaseExecutor
成员变量之一的PerpetualCache
,就是对Cache
接口最基本的实现,其实现非常的简内部持有了HashMap
,对一级缓存的操作其实就是对这个HashMap
的操作。PerpetualCache
代码如下:
/**
* @author Clinton Begin
*/
public class PerpetualCache implements Cache {
private final String id;
private final Map<Object, Object> cache = new HashMap<>();
// ...
}
2
3
4
5
6
7
8
9
10
11
12
BaseExecutor
的query
核心方法源码如下:
@SuppressWarnings("unchecked")
@Override
public <E> List<E> query(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {
ErrorContext.instance().resource(ms.getResource()).activity("executing a query").object(ms.getId());
if (closed) {
throw new ExecutorException("Executor was closed.");
}
if (queryStack == 0 && ms.isFlushCacheRequired()) {
clearLocalCache();
}
List<E> list;
try {
queryStack++;
// 从缓存中获取
list = resultHandler == null ? (List<E>) localCache.getObject(key) : null;
if (list != null) {
handleLocallyCachedOutputParameters(ms, key, parameter, boundSql);
} else {
// 缓存中不存在,则从数据库查询,并且对查询的结果缓存到本地缓存
list = queryFromDatabase(ms, parameter, rowBounds, resultHandler, key, boundSql);
}
} finally {
queryStack--;
}
if (queryStack == 0) {
for (DeferredLoad deferredLoad : deferredLoads) {
deferredLoad.load();
}
// issue #601
deferredLoads.clear();
// 判断本地缓存的级别(作用域)是否是 STATEMENT 级别,如果是,则清空缓存。这也就是 STATEMENT 级别的一级缓存失效的原因。
if (configuration.getLocalCacheScope() == LocalCacheScope.STATEMENT) {
// issue #482
clearLocalCache();
}
}
return list;
}
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
queryFromDatabase
方法源码如下:
private <E> List<E> queryFromDatabase(MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException {
List<E> list;
localCache.putObject(key, EXECUTION_PLACEHOLDER);
try {
list = doQuery(ms, parameter, rowBounds, resultHandler, boundSql);
} finally {
localCache.removeObject(key);
}
// 添加本地缓存
localCache.putObject(key, list);
if (ms.getStatementType() == StatementType.CALLABLE) {
localOutputParameterCache.putObject(key, parameter);
}
return list;
}
2
3
4
5
6
7
8
9
10
11
12
13
14
15
insert
/delete
/update
方法,缓存就会刷新的原因,源码如下:
@Override
public int update(MappedStatement ms, Object parameter) throws SQLException {
ErrorContext.instance().resource(ms.getResource()).activity("executing an update").object(ms.getId());
if (closed) {
throw new ExecutorException("Executor was closed.");
}
// 清空本地缓存
clearLocalCache();
return doUpdate(ms, parameter);
}
2
3
4
5
6
7
8
9
10
# 二级缓存
二级缓存只作用于cache
标签所在的映射文件中的语句(作用域namespace
)。如果你混合使用 Java API
和XML
映射文件,在共用接口中的语句将不会被默认缓存。你需要使用@CacheNamespaceRef
注解指定缓存作用域。
这些属性可以通过 cache
元素的属性来修改。比如:
<cache
eviction="FIFO"
flushInterval="60000"
size="512"
readOnly="true"/>
2
3
4
5
这个更高级的配置创建了一个FIFO
缓存,每隔60
秒刷新,最多可以存储结果对象或列表的512
个引用,而且返回的对象被认为是只读的,因此对它们进行修改可能会在不同线程中的调用者产生冲突。
可用的清除策略有:
- LRU – 最近最少使用:移除最长时间不被使用的对象。
- FIFO – 先进先出:按对象进入缓存的顺序来移除它们。
- SOFT – 软引用:基于垃圾回收器状态和软引用规则移除对象。
- WEAK – 弱引用:更积极地基于垃圾收集器状态和弱引用规则移除对象。
默认的清除策略是LRU
。
flushInterval
(刷新间隔)属性可以被设置为任意的正整数,设置的值应该是一个以毫秒为单位的合理时间量。 默认情况是不设置,也就是没有刷新间隔,缓存仅仅会在调用语句时刷新。
size
(引用数目)属性可以被设置为任意正整数,要注意欲缓存对象的大小和运行环境中可用的内存资源。默认值是1024
。
readOnly
(只读)属性可以被设置为true
或false
。只读的缓存会给所有调用者返回缓存对象的相同实例。 因此这些对象不能被修改。这就提供了可观的性能提升。而可读写的缓存会(通过序列化)返回缓存对象的拷贝。 速度上会慢一些,但是更安全,因此默认值是 false。
提示
二级缓存是事务性的。这意味着,当SqlSession
完成并提交时,或是完成并回滚,但没有执行flushCache=true
的insert/delete/update
语句时,缓存会获得更新。
最后特别注意的是,强烈推荐放弃使用二级缓存,在业务层使用可控制的缓存代替更好!
# mybatis-spring 一级缓存
Using an SqlSession (opens new window)
Spring
只有在开启了事务之后,在同一个事务里的SqlSession
会被缓存起来,同一个事务中,多次查询是可以命中缓存的!所以,在不使用事务的情况下,一级缓存是失效的,因为不是一个SqlSession
。
没有事务注解代码如下:
// @Transactional
@Override
public CourseCsware findById(Integer id) {
courseCswareMapper.selectById(id);
return courseCswareMapper.selectById(id);
}
2
3
4
5
6
7
打印的SQL
如下:
-- 42 2021-02-25 13:46:01.417|zmbiz-brain-record-b@12482-ac196e25-448397-3055|zmbiz-brain-record-b@12482-ac196e25-448397-3055|zmbiz-brain-record-b@12482-ac196e25-448397-3055||zmbiz-brain-record-b|[http-nio-8080-exec-2]|DEBUG|c.z.c.domain.mapper.CourseCswareMapper.selectById - ==>
SELECT id,type,name,version_num,subject_code,subject,grade_code,grade,edition_id,course_system_first_id,course_system_second_id,course_system_third_id,course_system_fourth_id,link_id,biz_state,updated_user_name,resource_local_url,created_user,created_time,updated_user,updated_time,deleted
FROM zm_xtc_course_csware
WHERE id=2488 AND deleted=0;
-- ---------------------------------------------------------------------------------------------------------------------
-- 43 2021-02-25 13:46:01.431|zmbiz-brain-record-b@12482-ac196e25-448397-3055|zmbiz-brain-record-b@12482-ac196e25-448397-3055|zmbiz-brain-record-b@12482-ac196e25-448397-3055||zmbiz-brain-record-b|[http-nio-8080-exec-2]|DEBUG|c.z.c.domain.mapper.CourseCswareMapper.selectById - ==>
SELECT id,type,name,version_num,subject_code,subject,grade_code,grade,edition_id,course_system_first_id,course_system_second_id,course_system_third_id,course_system_fourth_id,link_id,biz_state,updated_user_name,resource_local_url,created_user,created_time,updated_user,updated_time,deleted
FROM zm_xtc_course_csware
WHERE id=2488 AND deleted=0;
2
3
4
5
6
7
8
9
有事务注解代码如下:
@Transactional
@Override
public CourseCsware findById(Integer id) {
courseCswareMapper.selectById(id);
return courseCswareMapper.selectById(id);
}
2
3
4
5
6
7
-- 42 2021-02-25 13:46:01.417|zmbiz-brain-record-b@12482-ac196e25-448397-3055|zmbiz-brain-record-b@12482-ac196e25-448397-3055|zmbiz-brain-record-b@12482-ac196e25-448397-3055||zmbiz-brain-record-b|[http-nio-8080-exec-2]|DEBUG|c.z.c.domain.mapper.CourseCswareMapper.selectById - ==>
SELECT id,type,name,version_num,subject_code,subject,grade_code,grade,edition_id,course_system_first_id,course_system_second_id,course_system_third_id,course_system_fourth_id,link_id,biz_state,updated_user_name,resource_local_url,created_user,created_time,updated_user,updated_time,deleted
FROM zm_xtc_course_csware
WHERE id=2488 AND deleted=0;
2
3
4