这篇文章主要介绍“总结MyBatis缓存结构”,在日常操作中,相信很多人在总结MyBatis缓存结构问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”总结MyBatis缓存结构”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
“专业、务实、高效、创新、把客户的事当成自己的事”是我们每一个人一直以来坚持追求的企业文化。 创新互联是您可以信赖的网站建设服务商、专业的互联网服务提供商! 专注于网站建设、成都网站设计、软件开发、设计服务业务。我们始终坚持以客户需求为导向,结合用户体验与视觉传达,提供有针对性的项目解决方案,提供专业性的建议,创新互联建站将不断地超越自我,追逐市场,引领市场!
主要内容:
二级缓存构建在一级缓存之上,在收到查询请求时,MyBatis 首先会查询二级缓存。若二级缓存未命中,再去查询一级缓存。与一级缓存不同,二级缓存和具体的命名空间绑定,一级缓存则是和 SqlSession 绑定。
在按照 MyBatis 规范使用 SqlSession 的情况下,一级缓存不存在并发问题。二级缓存则不然,二级缓存可在多个命名空间间共享。这种情况下,会存在并发问题,因此需要针对性去处理。除了并发问题,二级缓存还存在事务问题。
配置项
cacheEnabled=true表示二级缓存可用,但是要开启话,需要在Mapper.xml内配置。
或者 简单方式
对配置项属性说明:
flushInterval="60000",间隔60秒清空缓存,这个间隔60秒,是被动触发的,而不是定时器轮询的。
size=512,表示队列最大512个长度,大于则移除队列最前面的元素,这里的长度指的是CacheKey的个数,默认为1024。
readOnly="true",表示任何获取对象的操作,都将返回同一实例对象。如果readOnly="false",则每次返回该对象的拷贝对象,简单说就是序列化复制一份返回。
eviction:缓存会使用默认的Least Recently Used(LRU,最近最少使用的)算法来收回。FIFO:First In First Out先进先出队列。
在Configuration类的newExecutor方法中是否开启二级缓存
public Executor newExecutor(Transaction transaction, ExecutorType executorType) { executorType = executorType == null ? defaultExecutorType : executorType; executorType = executorType == null ? ExecutorType.SIMPLE : executorType; Executor executor; if (ExecutorType.BATCH == executorType) { executor = new BatchExecutor(this, transaction); } else if (ExecutorType.REUSE == executorType) { executor = new ReuseExecutor(this, transaction); } else { executor = new SimpleExecutor(this, transaction); } //是否开启二级缓存 if (cacheEnabled) { executor = new CachingExecutor(executor); } executor = (Executor) interceptorChain.pluginAll(executor); return executor; }
二级缓存通过CachingExecutor来实现的,原理是缓存里存在,就返回,不存在就调用Executor ,如果一级缓存未关闭,则先查一级缓存,不存在,再到数据库中查询。
下面使用一张图来表示:
下面是源码:
@Override publicList query(MappedStatement ms, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler) throws SQLException { // 获得 BoundSql 对象 BoundSql boundSql = ms.getBoundSql(parameterObject); // 创建 CacheKey 对象 CacheKey key = createCacheKey(ms, parameterObject, rowBounds, boundSql); // 查询 return query(ms, parameterObject, rowBounds, resultHandler, key, boundSql); } @Override public List query(MappedStatement ms, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler, CacheKey key, BoundSql boundSql) throws SQLException { // 调用 MappedStatement#getCache() 方法,获得 Cache 对象, //即当前 MappedStatement 对象的二级缓存。 Cache cache = ms.getCache(); if (cache != null) { // <2> // 如果需要清空缓存,则进行清空 flushCacheIfRequired(ms); //当 MappedStatement#isUseCache() 方法,返回 true 时,才使用二级缓存。默认开启。 //可通过@Options(useCache = false) 或
也是使用的是BaseExecutor类中的createCacheKey方法生成的,所以二级缓存key和一级缓存生成规则是一样的。
二级缓存有一个非常重要的空间划分策略:
namespace="com.tian.mybatis.mappers.UserMapper" namespace="com.tian.mybatis.mappers.RoleMapper"
即,按照namespace划分,同一个namespace,同一个Cache空间,不同的namespace,不同的Cache空间。
比如:
在这个namespace下的二级缓存是同一个。
每当执行insert、update、delete,flushCache=true时,二级缓存都会被清空。
SqlSession sqlSession = sqlSessionFactory.openSession(); System.out.println("第一次查询"); User user = sqlSession.selectOne("com.tian.mybatis.mapper.UserMapper.selectById", 1); System.out.println(user); //sqlSession.commit(); SqlSession sqlSession1 = sqlSessionFactory.openSession(); System.out.println("第二次查询"); User user2 = sqlSession1.selectOne("com.tian.mybatis.mapper.UserMapper.selectById", 1); System.out.println(user2);
因为二级缓存使用的是TransactionalCaheManager(tcm)来管理的,最后又调用了TranscatinalCache的getObject()、putObject()、commit方法。
TransactionalCache里面又持有真正的Cache对象,比如:经过层层装饰的PrepetualCache。
在putObject的时候,只是添加到entriesToAddOnCommit里面。
//TransactionalCache类中 @Override public void putObject(Object key, Object object) { // 暂存 KV 到 entriesToAddOnCommit 中 entriesToAddOnCommit.put(key, object); }
只有conmit方法被调用的时候,才会调用flushPendingEntries方法,真正写入到缓存里。DefaultSqlSession调用commit方法的时候就会调到这个commit方法。
//TransactionalCache类中 public void commit() { //如果 clearOnCommit 为 true ,则清空 delegate 缓存 if (clearOnCommit) { delegate.clear(); } // 将 entriesToAddOnCommit、entriesMissedInCache 刷入 delegate 中 flushPendingEntries(); // 重置 reset(); } private void flushPendingEntries() { // 将 entriesToAddOnCommit 刷入 delegate 中 for (Map.Entry
因为在CachingExecutor的update方法中
@Override public int update(MappedStatement ms, Object parameterObject) throws SQLException { flushCacheIfRequired(ms); return delegate.update(ms, parameterObject); } private void flushCacheIfRequired(MappedStatement ms) { Cache cache = ms.getCache(); // 是否需要清空缓存 //通过 @Options(flushCache = Options.FlushCachePolicy.TRUE) 或
关于多个namespace的缓存共享的问题,可以使用来解决。
比如:
cache-ref代表引用别名的命名空间的Cache配置,两个命名空间的操作使用的是同一个Cache。在关联的表比较少或者按照业务可以对表进行分组的时候可以使用。
「注意」:在这种情况下,多个mapper的操作都会引起缓存刷新,所以这里的缓存的意义已经不是很大了。
如果将第三方缓存作为二级缓存?
Mybatis除了自带的二级换以外,我们还可以通过是想Cache接口来自定义二级缓存。
添加依赖
org.mybatis.caches mybatis-redis 1.0.0-beta2 redis基础配置项
host=127.0.0.1 port=6379 connectionTimeOut=5000 soTimeout=5000 datebase=0在我们的UserMapper.xml中添加
RedisCache类图,Cache就是Mybatis中缓存的顶层接口。
二级缓存应用场景
对于访问多的查询请求且用户对查询结果实时性要求不高,此时可采用mybatis二级缓存技术降低数据库访问量,提高访问速度,业务场景比如:耗时较高的统计分析sql、电话账单查询sql等。
缓存查询顺序
先查二级缓存,不存在则坚持一级缓存是否关闭,没关闭,则再查一级缓存,还不存在,最后查询数据库。
二级缓存总结
二级缓存开启方式有两步:
第一步:在全局配置中添加配置
第二步,在Mapper中添加配置
二级换是默认开启的,但是针对每一个Mapper的二级缓存是需要手动开启的。
二级缓存的key和一级缓存的key是一样的。
每当执行insert、update、delete,flushCache=true时,二级缓存都会被清空。
我们可以继承第三方缓存来作为Mybatis的二级缓存。
到此,关于“总结MyBatis缓存结构”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注创新互联网站,小编会继续努力为大家带来更多实用的文章!
网站名称:总结MyBatis缓存结构
文章网址:http://cdkjz.cn/article/gehhgs.html