文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

spring缓存自定义resolver的方法怎么用

2023-06-29 11:57

关注

本篇内容介绍了“spring缓存自定义resolver的方法怎么用”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

一、概述

cache-aside模式是常用的缓存使用模式。

使用流程如下图:

spring缓存自定义resolver的方法怎么用

当更新数据库中的数据后,对缓存做失效处理,后续就能读取到数据库中最新的数据,使得缓存数据与数据库数据保持一致。

在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,可以在缓存处理中增加附加操作。

@Configurationpublic 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类,继承SimpleCacheResolverSimpleCacheResolver类是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。

“spring缓存自定义resolver的方法怎么用”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注编程网网站,小编将为大家输出更多高质量的实用文章!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     807人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     351人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     314人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     433人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     221人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯