快捷導(dǎo)航

如何利用Redis作為Mybatis的二級(jí)緩存

更新時(shí)間：2022年08月11日 09:39:30 作者：一條coding

這篇文章主要介紹了如何利用Redis作為Mybatis的二級(jí)緩存，文章圍繞主題展開(kāi)詳細(xì)的內(nèi)容介紹，具有一定的參考價(jià)值，需要的朋友可以參考一下

前言

今天在開(kāi)發(fā)時(shí)發(fā)現(xiàn)一個(gè)奇怪的問(wèn)題，我手動(dòng)改完數(shù)據(jù)庫(kù)竟然不生效，反復(fù)確認(rèn)環(huán)境無(wú)誤后猜測(cè)是緩存的問(wèn)題，因?yàn)槭切陆邮值捻?xiàng)目，代碼還不熟悉，仔細(xì)一看，是開(kāi)啟了二級(jí)緩存，并且存入Redis。

那今天就聊聊怎么優(yōu)雅的用Redis作為Mybatis的二級(jí)緩存。

要優(yōu)雅就選擇Mybatis-Plus

關(guān)于Mybatis-Plus的基礎(chǔ)設(shè)置就不多做介紹了，只說(shuō)和二級(jí)緩存有關(guān)的。

首先在配置文件開(kāi)啟二級(jí)緩存。

mybatis-plus:
  configuration:
 ?  log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
 ?  cache-enabled: true ? # 開(kāi)啟二級(jí)緩存
  mapper-locations: classpath:*/mapper/*.xml

Redis配置

這部分就是Redis的基本用法：

  redis:
 ?  host: 101.411.160.111
 ?  database: 0
 ?  port: 6311
 ?  password: 1111111

配置RedisTemplate

@Configuration
public class RedisConfig {
 ? ?/**
 ? ? * 設(shè)置系列化方式、事務(wù)等配置
 ? ? */
 ? ?@Bean
 ? ?public RedisTemplate<String, Serializable> redisTemplate(LettuceConnectionFactory lettuceConnectionFactory)
 ?  {
 ? ? ? ?RedisTemplate<String,Serializable> redisTemplate = new RedisTemplate<>();
?
 ? ? ? ?redisTemplate.setConnectionFactory(lettuceConnectionFactory);
 ? ? ? ?//設(shè)置key序列化方式string
 ? ? ? ?redisTemplate.setKeySerializer(new StringRedisSerializer());
 ? ? ? ?//設(shè)置value的序列化方式j(luò)son
 ? ? ? ?redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
?
 ? ? ? ?redisTemplate.setHashKeySerializer(new StringRedisSerializer());
 ? ? ? ?redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
?
 ? ? ? ?redisTemplate.afterPropertiesSet();
?
 ? ? ? ?return redisTemplate;
 ?  }
}

自定義Mybatis緩存

我們只需要實(shí)現(xiàn)Cache這個(gè)接口。

@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("緩存出錯(cuò) ");
 ? ? ?  }
 ? ? ? ?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;
 ?  }
}

測(cè)試

1.第一次查詢，走數(shù)據(jù)庫(kù)，并寫入緩存。

看看Redis的記錄：

2.第二次查詢，直接走緩存

3.重啟項(xiàng)目，依然可以直接查緩存

緩存命中率（Cache Hit Ratio）

不知道有沒(méi)有細(xì)心的同學(xué)注意到這樣一行日志：

Cache Hit Ratio [com.yitiao.mapper.ArticleMapper]: 0.5

最后這個(gè)0.5就是緩存命中率，代表一共查詢兩次，命中一次緩存一次。

一級(jí)緩存和二級(jí)緩存

一級(jí)緩存

一級(jí)緩存 Mybatis 的一級(jí)緩存是指 SQLSession，一級(jí)緩存的作用域是 SQlSession , Mabits 默認(rèn)開(kāi)啟一級(jí)緩存。在同一個(gè)SqlSession中，執(zhí)行相同的SQL查詢時(shí)；第一次會(huì)去查詢數(shù)據(jù)庫(kù)，并寫在緩存中，第二次會(huì)直接從緩存中取。當(dāng)執(zhí)行SQL時(shí)候兩次查詢中間發(fā)生了增刪改的操作，則SQLSession的緩存會(huì)被清空。

每次查詢會(huì)先去緩存中找，如果找不到，再去數(shù)據(jù)庫(kù)查詢，然后把結(jié)果寫到緩存中。 Mybatis的內(nèi)部緩存使用一個(gè)HashMap，key為hashcode+statementId+sql語(yǔ)句。Value為查詢出來(lái)的結(jié)果集映射成的java對(duì)象。 SqlSession執(zhí)行insert、update、delete等操作commit后會(huì)清空該SQLSession緩存。

二級(jí)緩存

二級(jí)緩存二級(jí)緩存是 mapper 級(jí)別的，Mybatis默認(rèn)是沒(méi)有開(kāi)啟二級(jí)緩存的。第一次調(diào)用mapper下的SQL去查詢用戶的信息，查詢到的信息會(huì)存放到該 mapper 對(duì)應(yīng)的二級(jí)緩存區(qū)域。第二次調(diào)用 namespace 下的 mapper 映射文件中，相同的sql去查詢用戶信息，會(huì)去對(duì)應(yīng)的二級(jí)緩存內(nèi)取結(jié)果。