mybatis 使用redis实现二级缓存（spring boot)
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了mybatis 使用redis实现二级缓存（spring boot)，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含8395字，纯文字阅读大概需要12分钟。
内容图文
mybatis 自定义redis做二级缓存
前言
如果关注功能实现，可以直接看功能实现部分
何时使用二级缓存
一个宗旨---不常变的稳定而常用的
- 一级是默认开启的sqlsession级别的。
- 只在单表中使用，且所有的操作都是一个namespace下
- 查询多 增删改少的情况下
缓存并不全是优点，缺点很明显，缓存有时不是最新的数据。
二级缓存参数说明
这是一个跨Sqlsession级虽的缓存，是mapper级别的，也就是可以多个sqlsession访问同一个mapper时生效
| 关键字 | 解读 |
|---|---|
| eviction | 缓存回收策略 |
| flushInterval | 刷新时间间隔，单位毫秒 |
| size | 引用数目，代表缓存最多可以存多少对象 |
| readOnly | 是否只读默认false 如果True所有的sql返回的是一个对象，性能高并发安全性底，如果false返回的是序列化后的副本，安全高效率底 |
常用的回收策略（与操作系统内存回收策略差不多）
- LRU 默认，最近最少使用
- FIFO 先进先出
- SOFT 软引用 移除基于垃圾回收器状态和软引用规则的对象
WEAK 弱引用 更积极的移除移除基于垃圾回收器状态和弱引用规则的对象
sql中控制是否使用缓存及刷新缓存
<!-- 开启二级缓存 -->
<setting name="cacheEnabled" value="true"/>
<select id="" resultMap="" useCache="false">
<update id="" parameterType="" flushCache="false" />缓存何时会失效(意思就是构成key的因素一样，但是没有命中value)
一级失效
- 不在同一个Sqlsession中，例如未开启事务，mybatis每次查询都会关闭旧的创建新的。
- 增删改操作程序会clear缓存
手动执行sqlsession.clearCache()
二级失效
- insert ,update,delete语句的执行
- 超时
- 被回收策略回收
功能实现
添加依赖
<!-- 集成了lettuce的连接方式也可以用jedis方式看自己建议用集成的说明稳定些 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- 序列化 -->
<dependency>
<groupId>de.javakaffee</groupId>
<artifactId>kryo-serializers</artifactId>
</dependency>
<!-- 连接池 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-pool2</artifactId>
</dependency>
<!-- 自定义获取Bean -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
</dependency>
<!-- 断言判断，正式环境中可以使用 -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>启动二级缓存
- 可以配置在调用mapper的项目中，方便以后维护
spring:
redis:
lettuce:
pool:
max-active: 8
max-wait: -1ms
max-idle: 8
min-idle: 0
#集群的方式
# sentinel:
# master: mymaster
# nodes: 192.168.15.154:6379
database: 0
host: 192.168.15.154
port: 6379
# MyBatis Config properties
mybatis:
type-aliases-package:
mapper-locations: classpath:mapper/*.xml
configuration:
log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
cache-enabled: true自定义相关代码
- 确保所有POJO都实现了序列化并声明了序列号
private static final long serialVersionUID =-1L;- 自定义实现缓存接口
/**
* @author lyy
* @description
* @date 2019/9/2
*/
public class RedisCache implements Cache {
private static final Logger logger = LoggerFactory.getLogger(RedisCache.class);
private final ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
// cache instance id
private final String id;
private RedisTemplate redisTemplate;
// redis过期时间
private static final long EXPIRE_TIME_IN_MINUTES = 30;
public RedisCache(String id) {
if (id == null) {
throw new IllegalArgumentException("Cache instances require an ID");
}
this.id = id;
}
@Override
public String getId() {
return id;
}
/**
* Put query result to redis
*
* @param key
* @param value
*/
@Override
public void putObject(Object key, Object value) {
try {
RedisTemplate redisTemplate = getRedisTemplate();
ValueOperations opsForValue = redisTemplate.opsForValue();
opsForValue.set(key, value, EXPIRE_TIME_IN_MINUTES, TimeUnit.MINUTES);
logger.debug("Put query result to redis");
} catch (Throwable t) {
logger.error("Redis put failed", t);
}
}
/**
* Get cached query result from redis
*
* @param key
* @return
*/
@Override
public Object getObject(Object key) {
try {
RedisTemplate redisTemplate = getRedisTemplate();
ValueOperations opsForValue = redisTemplate.opsForValue();
logger.debug("Get cached query result from redis");
return opsForValue.get(key);
} catch (Throwable t) {
logger.error("Redis get failed, fail over to db", t);
return null;
}
}
/**
* Remove cached query result from redis
*
* @param key
* @return
*/
@Override
@SuppressWarnings("unchecked")
public Object removeObject(Object key) {
try {
RedisTemplate redisTemplate = getRedisTemplate();
redisTemplate.delete(key);
logger.debug("Remove cached query result from redis");
} catch (Throwable t) {
logger.error("Redis remove failed", t);
}
return null;
}
/**
* Clears this cache instance
*/
@Override
public void clear() {
RedisTemplate redisTemplate = getRedisTemplate();
redisTemplate.execute((RedisCallback) connection -> {
connection.flushDb();
return null;
});
logger.debug("Clear all the cached query result from redis");
}
/**
* This method is not used
*
* @return
*/
@Override
public int getSize() {
return 0;
}
@Override
public ReadWriteLock getReadWriteLock() {
return readWriteLock;
}
private RedisTemplate getRedisTemplate() {
if (redisTemplate == null) {
redisTemplate = ApplicationContextHolder.getBean("redisTemplate");
}
return redisTemplate;
}
}- 定义ApplicationContextHolder来实现Bean的注入和获取
/**
* @author lyy
* @description
* @date 2019/9/2
*/
@Component
public class ApplicationContextHolder implements ApplicationContextAware, DisposableBean {
private static final Logger logger = LoggerFactory.getLogger(ApplicationContextHolder.class);
private static ApplicationContext applicationContext;
public static ApplicationContext getApplicationContext() {
if (applicationContext == null) {
throw new IllegalStateException(
"'applicationContext' property is null,ApplicationContextHolder not yet init.");
}
return applicationContext;
}
/**
* ? ? ?* 根据bean的id来查找对象
* ? ? ?* @param id
* ? ? ?* @return
* ? ? ?
*/
public static Object getBeanById(String id) {
checkApplicationContext();
return applicationContext.getBean(id);
}
/**
* ? ? ?* 通过名称获取bean
* ? ? ?* @param name
* ? ? ?* @return
* ? ? ?
*/
@SuppressWarnings("unchecked")
public static <T> T getBean(String name) {
checkApplicationContext();
Object object = applicationContext.getBean(name);
return (T) object;
}
/**
* ? ? ?* 根据bean的class来查找对象
* ? ? ?* @param c
* ? ? ?* @return
* ? ? ?
*/
@SuppressWarnings("all")
public static <T> T getBeanByClass(Class<T> c) {
checkApplicationContext();
return (T) applicationContext.getBean(c);
}
/**
* ? ? ?* 从静态变量ApplicationContext中取得Bean, 自动转型为所赋值对象的类型.
* 如果有多个Bean符合Class, 取出第一个.
* ? ? ?* @param cluss
* ? ? ?* @return
* ? ? ?
*/
public static <T> T getBean(Class<T> cluss) {
checkApplicationContext();
return (T) applicationContext.getBean(cluss);
}
/**
* ? ? ?* 名称和所需的类型获取bean
* ? ? ?* @param name
* ? ? ?* @param cluss
* ? ? ?* @return
* ? ? ?
*/
public static <T> T getBean(String name, Class<T> cluss) {
checkApplicationContext();
return (T) applicationContext.getBean(name, cluss);
}
public static <T> Map<String, T> getBeansOfType(Class<T> type) throws BeansException {
checkApplicationContext();
return applicationContext.getBeansOfType(type);
}
/**
* 检查ApplicationContext不为空.
*/
private static void checkApplicationContext() {
if (applicationContext == null) {
throw new IllegalStateException("applicaitonContext未注入,请在applicationContext.xml中定义ApplicationContextHolderGm");
}
}
@Override
public void destroy() throws Exception {
checkApplicationContext();
}
/**
* 清除applicationContext静态变量
*/
public static void cleanApplicationContext() {
applicationContext = null;
}
@Override
public void setApplicationContext(ApplicationContext context) throws BeansException {
//checkApplicationContext();
applicationContext = context;
logger.info("holded applicationContext,显示名称:" + applicationContext.getDisplayName());
}
}启用缓存
- 注解的方式,注解在mapper接口上
@CacheNamespace(implementation = RedisCache.class)- xml的方式
<cache type="***.RedisCache">
<property name="eviction" value="LRU"/>
<property name="flushInterval" value="60000000"/>
<property name="size" value="2048"/>
<property name="readOnly" value="false"/>
</cache>为什么使用redis?除了redis还有其它什么？
- redis是一个高性能nosql库，配上集群稳定高效，因为默认的二级缓存是在内存中的。这样可以把缓存独立出来，也是所有第三方map结构做二级缓存的优点
- 可以更好的适应分布式
- 还有ehcache,还有理论上的所有nosql库应该都可以
注意事项
缓存不生效（或者叫缓存穿透）
- 注解的sql使用注解开启，xml配置的sql要在xml中开启，混用不生效
- windows版的redis要配置一下允许外网连接，即使把redis.windows.conf中的bind 127.0.0.1注释掉了也不行
# Examples:
#
# bind 192.168.1.100 10.0.0.1
bind 0.0.0.0- intellij idea 生成序列号,下面选中后放光标放在类是，不是接口上按alt+enter
File -> Settings -> Inspections -> Serialization issues -> Serialization class without ‘serialVersionUID’内容总结
以上是互联网集市为您收集整理的mybatis 使用redis实现二级缓存（spring boot)全部内容，希望文章能够帮你解决mybatis 使用redis实现二级缓存（spring boot)所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】