spring缓存自定义resolver的方法
作者:QiHY 发布时间:2021-05-30 17:07:56
本文介绍spring中自定义缓存resolver,通过自定义resolver,可以在spring的cache注解中增加附加处理。
一、概述
cache-aside模式是常用的缓存使用模式。
使用流程如下图:
当更新数据库中的数据后,对缓存做失效处理,后续就能读取到数据库中最新的数据,使得缓存数据与数据库数据保持一致。
在spring中通过cache注解进行缓存的处理,一般会把缓存处理封装到dao层,这样业务层就不需要感知缓存操作的细节,可以专注于业务逻辑的处理。
二、缓存的读取和失效
dao层的操作通常使用springdatajpa,数据库方法都是一个interface,通过在interface上增加对应的cache注解实现缓存处理。
读取数据:
@Cacheable(value = "testCache", key = "#p0", unless = "#result == null")
Optional<DemoEntity> findById(Long id);
通过Cacheable注解,从数据库中读取到数据后,会同步写到缓存中。
保存数据:
@CacheEvict(value = "testCache", key = "#p0.id")
DemoEntity save(DemoEntity entity);
通过CacheEvict注解,在将数据写入到数据库后,对缓存进行失效。
如果我们想在缓存失效后,进行其它的操作,例如将失效缓存的key写入kafka,用于其它系统同步删除缓存,这时该怎样处理?
三、自定义缓存resolver
spring提供了自定义缓存resolver的方式,通过自定义resolver,可以在缓存处理中增加附加操作。
@Configuration
public class RedisCacheConfig extends CachingConfigurerSupport {
@Bean
public RedisCacheManager redisCacheManager(RedisConnectionFactory redisConnectionFactory) {
RedisCacheConfiguration cacheConfiguration = RedisCacheConfiguration.defaultCacheConfig()
.computePrefixWith(cacheName -> cacheName.concat(":"));
return RedisCacheManager.builder(redisConnectionFactory)
.cacheDefaults(cacheConfiguration)
.build();
}
@Bean
public CacheResolver customCacheResolver(RedisConnectionFactory redisConnectionFactory) {
return new CustomCacheResolver(redisCacheManager(redisConnectionFactory));
}
}
以上代码是redis缓存的配置,其中 RedisCacheManager
部分是常规的cacheManager的配置, 而 customCacheResolver
部分是自定义resolver的配置,通过定义customCacheResolver这个bean,可以在cache注解中引用到这个自定义的resolver。
定义好customCacheResolver的bean
后,我们就可以在cache注解中引用,上面提到的数据保存方法改造后的代码:
@CacheEvict(value = "testCache", cacheResolver = "customCacheResolver", key = "#p0.id")
DemoEntity save(DemoEntity entity);
相比于之前的实现,对CacheEvict增加指定cacheResolver。
四、自定义resolver的实现
上面我们介绍了如果配置和引用cacheResolver
,下面介绍自定义cacheResolver
的实现。
public class CustomCacheResolver extends SimpleCacheResolver {
public CustomCacheResolver(CacheManager cacheManager) {
super(cacheManager);
}
@Override
@NonNull
public Collection<? extends Cache> resolveCaches(CacheOperationInvocationContext<?> context) {
ParameterNameDiscoverer paramNameDiscoverer = new DefaultParameterNameDiscoverer();
EvaluationContext evaluationContext = new MethodBasedEvaluationContext(context.getOperation(), context.getMethod(), context.getArgs(), paramNameDiscoverer);
Expression exp = (new SpelExpressionParser()).parseExpression(((CacheEvictOperation) context.getOperation()).getKey());
Collection<? extends Cache> caches = super.resolveCaches(context);
context.getOperation().getCacheNames().forEach(cacheName -> {
String key = cacheName + ':' + exp.getValue(evaluationContext, String.class);
log.info("cache key={}", key);
});
return caches;
}
}
上面的代码定义了CustomCacheResolver
这个自定义resolver类,继承SimpleCacheResolver
。SimpleCacheResolver
类是spring在cache注解中默认使用的resolver。
我们通过扩展SimpleCacheResolver这个类,来增加附加操作。其中resolveCaches
就是解析缓存操作的部分。
在这部分代码中,我们需要的是获取到 @CacheEvict(value = "testCache", cacheResolver = "customCacheResolver", key = "#p0.id")
注解中失效的缓存的key的值。
通过 context.getOperation()).getKey()
从参数context中可以读取到key的定义,即 #p0.id
,这个定义是一个spel表达式,与普通的spel表达式不同, p0这个变量是jpa方法中的一个特有变量,表示方法中的第一个参数,同样p1表示方法中的第二个参数。通过普通的spel处理无法解析这个spel表达式。
spring提供了 MethodBasedEvaluationContext
类用于解析这种特殊的spel表达式。
通过一下四行代码,我们就能够获取到具体的key的值:
ParameterNameDiscoverer paramNameDiscoverer = new DefaultParameterNameDiscoverer();
EvaluationContext evaluationContext = new MethodBasedEvaluationContext(context.getOperation(), context.getMethod(), context.getArgs(), paramNameDiscoverer);
Expression exp = (new SpelExpressionParser()).parseExpression(((CacheEvictOperation) context.getOperation()).getKey());
String key = cacheName + ':' + exp.getValue(evaluationContext, String.class);
获取到了key的值,我们就可以对这个key做很多操作,可以把这个key写入kafka,通知其它系统同步清理key。
五、总结
我们通常把缓存操作封装到dao层以简化程序的整体逻辑,当使用springdatajpa作为dao层的实现时,具体的dao方法都是interface,对于在interface上添加的cache注解,没有办法增加额外的其它操作。
当需要对缓存操作做额外处理时,可以通过自定义resolver的方式实现,在cache注解中使用我们自定义的resolver。
这样既没有破环程序的整理逻辑,又扩展了对缓存的操作,是一种比较好的实现方式。
本篇文章就到这里了,希望能够给你带来帮助,也希望您能够多多关注脚本之家的更多内容!
来源:https://blog.csdn.net/haiyan_qi/article/details/123468492
猜你喜欢
- MyCat一个彻底开源的,面向企业应用开发的大数据库集群。基于阿里开源的Cobar产品而研发。能满足数据库数据大量存储;提高了查询性能。文章
- 1.概述当Java 8发布时,其中最令人兴奋的特性之一就是 Lambda 表达式。Lambda 表达式是一种轻量级、简洁和高效的函数式编程方
- 通过http://localhost:7002/card/services/HelloWorld?wsdl访问到xml如下,说明接口写对了。
- 本文实例为大家分享了struts2和hibernate实现登录和注册功能,供大家参考,具体内容如下1、该项目使用MySQL数据库,数据库名为
- 前言自从国产之光fastjson频频暴雷,jackson json的使用是越来越广泛了。尤其是spring家族把它搞成了默认的JSON处理包
- 本文实例为大家分享了Java实现简单酒店管理系统的具体代码,供大家参考,具体内容如下为某个酒店编写程序:酒店管理系统,模拟订房、退房和打印所
- //执行顺序:(优先级从高到低。)静态代码块>mian方法>构造代码块>构造方法。其中静态代码块只执行一次。构造代码块在每
- 我的安卓开发经历始于一个原生安卓项目开发。后来由于公司有个项目与几家医疗设备公司合作,需要我写安卓端的桥接代码给 react native
- ThreadLocal简介变量值的共享可以使用public static的形式,所有线程都使用同一个变量,如果想实现每一个线程都有自己的共享
- 年纪大了,以前做过的东西过阵子还是会忘,今天使用jenkins持续集成工具时用到了eclipse上传新maven工程至svn,上传完毕后改了
- 为什么使用logback记得前几年工作的时候,公司使用的日志框架还是log4j,大约从16年中到现在,不管是我参与的别人已经搭建好的项目还是
- 请求参数解析客户端请求在handlerMapping中找到对应handler后,将会继续执行DispatchServlet的doPatch(
- import java.io.File;import java.io.FileNotFoundException;import java.i
- 定义枚举类型时本质上就是在定义一个类,只不过很多细节由编译器帮您补齐了,所以某些程度上,enum关键字的 作用就像是class或interf
- 本文实例为大家分享了Unity UI实现拖拽旋转的具体代码,供大家参考,具体内容如下跟随鼠标旋转第一种效果是跟随鼠标旋转,原理是计算下鼠标位
- 一、实现了Aware的接口Spring中有很多继承于aware中的接口,这些接口到底是做什么用到的,下面我们就一起来看看吧。Aware 接口
- 在Android中因为不同像素手机的多样化,对于一张图片,放大不同的手机上因像素不同显示上也会有区别。现有如下需求:将一张图片宽度充满整个屏
- a)原理:每一趟从待排序的记录中选出最小的元素,顺序放在已排好序的序列最后,直到全部记录排序完毕。也就是:每一趟在n-i+1(i=1,2,…
- 一、首先编写一个工具类Hello:public class Hello { public static void say(Str
- 上传临时文件被删除引起报错的解决1.前言在项目中使用到了SpringBoot的上传实现了一个excel导入功能,上线后稳得一批,但突然有一天