深入了解MyBatis二级缓存

2023-09-02 12:02:04 304

一、创建Cache的完整过程

我们从SqlSessionFactoryBuilder解析mybatis-config.xml配置文件开始：

Readerreader=Resources.getResourceAsReader("mybatis-config.xml");
SqlSessionFactorysqlSessionFactory=newSqlSessionFactoryBuilder().build(reader);

然后是：

XMLConfigBuilderparser=newXMLConfigBuilder(inputStream,environment,properties);
returnbuild(parser.parse());

看parser.parse()方法：

parseConfiguration(parser.evalNode("/configuration"));

看处理Mapper.xml文件的位置：

mapperElement(root.evalNode("mappers"));

看处理Mapper.xml的XMLMapperBuilder：

XMLMapperBuildermapperParser=newXMLMapperBuilder(inputStream,configuration,
resource,configuration.getSqlFragments());
mapperParser.parse();

继续看parse方法：

configurationElement(parser.evalNode("/mapper"));

到这里：

Stringnamespace=context.getStringAttribute("namespace");
if(namespace.equals("")){
thrownewBuilderException("Mapper'snamespacecannotbeempty");
}
builderAssistant.setCurrentNamespace(namespace);
cacheRefElement(context.evalNode("cache-ref"));
cacheElement(context.evalNode("cache"));

从这里看到namespace就是xml中元素的属性。然后下面是先后处理的cache-ref和cache，后面的cache会覆盖前面的cache-ref，但是如果一开始cache-ref没有找到引用的cache，他就不会被覆盖，会一直到最后处理完成为止，最后如果存在cache，反而会被cache-ref覆盖。这里是不是看着有点晕、有点乱？所以千万别同时配置这两个，实际上也很少有人会这么做。

看看MyBatis如何处理：

privatevoidcacheElement(XNodecontext)throwsException{
if(context!=null){
Stringtype=context.getStringAttribute("type","PERPETUAL");
ClasstypeClass=typeAliasRegistry.resolveAlias(type);
Stringeviction=context.getStringAttribute("eviction","LRU");
ClassevictionClass=typeAliasRegistry.resolveAlias(eviction);
LongflushInterval=context.getLongAttribute("flushInterval");
Integersize=context.getIntAttribute("size");
booleanreadWrite=!context.getBooleanAttribute("readOnly",false);
booleanblocking=context.getBooleanAttribute("blocking",false);
Propertiesprops=context.getChildrenAsProperties();
builderAssistant.useNewCache(typeClass,evictionClass,
flushInterval,size,readWrite,blocking,props);
}
}

从源码可以看到MyBatis读取了那些属性，而且很容易可以到这些属性的默认值。

创建Java的cache对象方法为builderAssistant.useNewCache，我们看看这段代码：

publicCacheuseNewCache(ClasstypeClass,
ClassevictionClass,
LongflushInterval,
Integersize,
booleanreadWrite,
booleanblocking,
Propertiesprops){
typeClass=valueOrDefault(typeClass,PerpetualCache.class);
evictionClass=valueOrDefault(evictionClass,LruCache.class);
Cachecache=newCacheBuilder(currentNamespace)
.implementation(typeClass)
.addDecorator(evictionClass)
.clearInterval(flushInterval)
.size(size)
.readWrite(readWrite)
.blocking(blocking)
.properties(props)
.build();
configuration.addCache(cache);
currentCache=cache;
returncache;
}

从调用该方法的地方，我们可以看到并没有使用返回值cache，在后面的过程中创建MappedStatement的时候使用了currentCache。

二、使用Cache过程

在系统中，使用Cache的地方在CachingExecutor中：

@Override
publicListquery(
MappedStatementms,ObjectparameterObject,
RowBoundsrowBounds,ResultHandlerresultHandler,
CacheKeykey,BoundSqlboundSql)throwsSQLException{
Cachecache=ms.getCache();

获取cache后，先判断是否有二级缓存。

只有通过,或@CacheNamespace,@CacheNamespaceRef标记使用缓存的Mapper.xml或Mapper接口（同一个namespace，不能同时使用）才会有二级缓存。

if(cache!=null){

如果cache存在，那么会根据sql配置(,

像上面这个查询，你会写到那个xml中呢？？

不管是写到RoleMapper.xml还是UserRoleMapper.xml，或者是一个独立的XxxMapper.xml中。如果使用了二级缓存，都会导致上面这个查询结果可能不正确。

如果你正好修改了这个用户的角色，上面这个查询使用缓存的时候结果就是错的。

这点应该很容易理解。

在我看来，就以MyBatis目前的缓存方式来看是无解的。多表操作根本不能缓存。

如果你让他们都使用同一个namespace（通过）来避免脏数据，那就失去了缓存的意义。

看到这里，实际上就是说，二级缓存不能用。整篇文章介绍这么多也没什么用了。

五、挽救二级缓存？

想更高效率的使用二级缓存是解决不了了。

但是解决多表操作避免脏数据还是有法解决的。解决思路就是通过拦截器判断执行的sql涉及到那些表（可以用jsqlparser解析），然后把相关表的缓存自动清空。但是这种方式对缓存的使用效率是很低的。

设计这样一个插件是相当复杂的，既然我没想着去实现，就不废话了。

最后还是建议，放弃二级缓存，在业务层使用可控制的缓存代替更好。

推荐：集成SpringRedis缓存
https://www.nhooo.com/article/153343.htm

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对毛票票的支持。如果你想了解更多相关内容请查看下面相关链接

深入了解MyBatis二级缓存

热门推荐

随机推荐