日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后，達者為師

網站首頁 編程語言 正文

如何利用Redis作為Mybatis的二級緩存_Redis

作者：一條coding ? 更新時間： 2022-10-06 編程語言

前言

今天在開發時發現一個奇怪的問題，我手動改完數據庫竟然不生效，反復確認環境無誤后猜測是緩存的問題，因為是新接手的項目，代碼還不熟悉，仔細一看，是開啟了二級緩存，并且存入Redis。

那今天就聊聊怎么優雅的用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去查詢用戶信息，會去對應的二級緩存內取結果。

什么時候該開啟二級緩存

說實話，我遇到開啟二級緩存的時候并不多，因為緩存有利也有弊。

我的建議是如果發現接口耗時嚴重，可以在線上開啟二級緩存，開發環境關掉，為什么呢？

就拿今天我遇到的事來說，開發直接改庫不能立即生效，就很煩。

原文鏈接：https://juejin.cn/post/7130142146610331661

欄目分類
最近更新