怎么利用Redis作为Mybatis的二级缓存
这篇文章主要介绍“怎么利用Redis作为Mybatis的二级缓存”,在日常操作中,相信很多人在怎么利用Redis作为Mybatis的二级缓存问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”怎么利用Redis作为Mybatis的二级缓存”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
要优雅就选择Mybatis-Plus
关于Mybatis-Plus的基础设置就不多做介绍了,只说和二级缓存有关的。
首先在配置文件开启二级缓存。
mybatis-plus: configuration: log-impl: org.apache.ibatis.logging.stdout.StdOutImpl cache-enabled: true # 开启二级缓存 mapper-locations: classpath:*/mapper/*.xml
Redis配置
这部分就是Redis的基本用法:
redis: host: 101.411.160.111 database: 0 port: 6311 password: 1111111
配置RedisTemplate
@Configuration public class RedisConfig { /** * 设置系列化方式、事务等配置 */ @Bean public RedisTemplate<String, Serializable> redisTemplate(LettuceConnectionFactory lettuceConnectionFactory) { RedisTemplate<String,Serializable> redisTemplate = new RedisTemplate<>(); redisTemplate.setConnectionFactory(lettuceConnectionFactory); //设置key序列化方式string redisTemplate.setKeySerializer(new StringRedisSerializer()); //设置value的序列化方式json redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer()); redisTemplate.setHashKeySerializer(new StringRedisSerializer()); redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer()); redisTemplate.afterPropertiesSet(); return redisTemplate; } }
自定义Mybatis缓存
我们只需要实现Cache
这个接口。
@Slf4j public class MybatisRedisCache implements Cache { private static final String COMMON_CACHE_KEY = "mybatis"; // 读写锁 private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock(true) private final RedisTemplate<String, Object> redisTemplate; private final String nameSpace; public MybatisRedisCache(String nameSpace) { if (nameSpace == null) { throw new IllegalArgumentException("Cache instances require an ID"); } redisTemplate = SpringUtil.getBean("redisTemplate"); this.nameSpace = nameSpace; } @Override public String getId() { return this.nameSpace; } private String getKeys() { return COMMON_CACHE_KEY + "::" + nameSpace + "::*"; } private String getKey(Object key) { return COMMON_CACHE_KEY + "::" + nameSpace + "::" + DigestUtils.md5Hex(String.valueOf(key)); } @Override public void putObject(Object key, Object value) { redisTemplate.opsForValue().set(getKey(key), value, 10, TimeUnit.MINUTES); } @Override public Object getObject(Object key) { try { return redisTemplate.opsForValue().get(getKey(key)); } catch (Exception e) { e.printStackTrace(); log.error("缓存出错 "); } return null; } @Override public Object removeObject(Object o) { Object n = redisTemplate.opsForValue().get(getKey(o)); redisTemplate.delete(getKey(o)); return n; } @Override public void clear() { Set<String> keys = redisTemplate.keys(getKeys()); if (CollectionUtil.isNotEmpty(keys)) { assert keys != null; redisTemplate.delete(keys); } } @Override public int getSize() { Set<String> keys = redisTemplate.keys(getKeys()); if (CollectionUtil.isNotEmpty(keys)) { assert keys != null; return keys.size(); } return 0; } @Override public ReadWriteLock getReadWriteLock() { return this.readWriteLock; } }
测试
1.第一次查询,走数据库,并写入缓存。
看看Redis的记录:
2.第二次查询,直接走缓存
3.重启项目,依然可以直接查缓存
缓存命中率(Cache Hit Ratio)
不知道有没有细心的同学注意到这样一行日志:
Cache Hit Ratio [com.yitiao.mapper.ArticleMapper]: 0.5
最后这个0.5就是缓存命中率,代表一共查询两次,命中一次缓存一次。
一级缓存和二级缓存
一级缓存
一级缓存 Mybatis 的一级缓存是指 SQLSession,一级缓存的作用域是 SQlSession , Mabits 默认开启一级缓存。 在同一个SqlSession中,执行相同的SQL查询时;第一次会去查询数据库,并写在缓存中,第二次会直接从缓存中取。 当执行SQL时候两次查询中间发生了增删改的操作,则SQLSession的缓存会被清空。
每次查询会先去缓存中找,如果找不到,再去数据库查询,然后把结果写到缓存中。 Mybatis的内部缓存使用一个HashMap,key为hashcode+statementId+sql语句。Value为查询出来的结果集映射成的java对象。 SqlSession执行insert、update、delete等操作commit后会清空该SQLSession缓存。
二级缓存
二级缓存 二级缓存是 mapper 级别的,Mybatis默认是没有开启二级缓存的。 第一次调用mapper下的SQL去查询用户的信息,查询到的信息会存放到该 mapper 对应的二级缓存区域。 第二次调用 namespace 下的 mapper 映射文件中,相同的sql去查询用户信息,会去对应的二级缓存内取结果。
到此,关于“怎么利用Redis作为Mybatis的二级缓存”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注蜗牛博客网站,小编会继续努力为大家带来更多实用的文章!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:niceseo99@gmail.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
评论