本文介紹spring中自定義緩存resolver，通過(guò)自定義resolver，可以在spring的cache注解中增加附加處理。

一、概述

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

使用流程如下圖：

當(dāng)更新數(shù)據(jù)庫(kù)中的數(shù)據(jù)后，對(duì)緩存做失效處理，后續(xù)就能讀取到數(shù)據(jù)庫(kù)中最新的數(shù)據(jù)，使得緩存數(shù)據(jù)與數(shù)據(jù)庫(kù)數(shù)據(jù)保持一致。

在spring中通過(guò)cache注解進(jìn)行緩存的處理，一般會(huì)把緩存處理封裝到dao層，這樣業(yè)務(wù)層就不需要感知緩存操作的細(xì)節(jié)，可以專(zhuān)注于業(yè)務(wù)邏輯的處理。

二、緩存的讀取和失效

dao層的操作通常使用springdatajpa，數(shù)據(jù)庫(kù)方法都是一個(gè)interface，通過(guò)在interface上增加對(duì)應(yīng)的cache注解實(shí)現(xiàn)緩存處理。

讀取數(shù)據(jù)：

@Cacheable(value = "testCache", key = "#p0", unless = "#result == null")
Optional<DemoEntity> findById(Long id);

通過(guò)Cacheable注解，從數(shù)據(jù)庫(kù)中讀取到數(shù)據(jù)后，會(huì)同步寫(xiě)到緩存中。

保存數(shù)據(jù)：

@CacheEvict(value = "testCache", key = "#p0.id")
DemoEntity save(DemoEntity entity);

通過(guò)CacheEvict注解，在將數(shù)據(jù)寫(xiě)入到數(shù)據(jù)庫(kù)后，對(duì)緩存進(jìn)行失效。

如果我們想在緩存失效后，進(jìn)行其它的操作，例如將失效緩存的key寫(xiě)入kafka，用于其它系統(tǒng)同步刪除緩存，這時(shí)該怎樣處理？

三、自定義緩存resolver

spring提供了自定義緩存resolver的方式，通過(guò)自定義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部分是常規(guī)的cacheManager的配置， 而 customCacheResolver部分是自定義resolver的配置，通過(guò)定義customCacheResolver這個(gè)bean，可以在cache注解中引用到這個(gè)自定義的resolver。

定義好customCacheResolver的bean后，我們就可以在cache注解中引用，上面提到的數(shù)據(jù)保存方法改造后的代碼：

@CacheEvict(value = "testCache", cacheResolver = "customCacheResolver", key = "#p0.id")
DemoEntity save(DemoEntity entity);

相比于之前的實(shí)現(xiàn)，對(duì)CacheEvict增加指定cacheResolver。

四、自定義resolver的實(shí)現(xiàn)

上面我們介紹了如果配置和引用cacheResolver，下面介紹自定義cacheResolver的實(shí)現(xiàn)。

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這個(gè)自定義resolver類(lèi)，繼承SimpleCacheResolver。SimpleCacheResolver類(lèi)是spring在cache注解中默認(rèn)使用的resolver。

我們通過(guò)擴(kuò)展SimpleCacheResolver這個(gè)類(lèi)，來(lái)增加附加操作。其中resolveCaches就是解析緩存操作的部分。

在這部分代碼中，我們需要的是獲取到 @CacheEvict(value = "testCache", cacheResolver = "customCacheResolver", key = "#p0.id")注解中失效的緩存的key的值。

通過(guò) context.getOperation()).getKey()從參數(shù)context中可以讀取到key的定義，即 #p0.id，這個(gè)定義是一個(gè)spel表達(dá)式，與普通的spel表達(dá)式不同， p0這個(gè)變量是jpa方法中的一個(gè)特有變量，表示方法中的第一個(gè)參數(shù)，同樣p1表示方法中的第二個(gè)參數(shù)。通過(guò)普通的spel處理無(wú)法解析這個(gè)spel表達(dá)式。
spring提供了 MethodBasedEvaluationContext類(lèi)用于解析這種特殊的spel表達(dá)式。

通過(guò)一下四行代碼，我們就能夠獲取到具體的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的值，我們就可以對(duì)這個(gè)key做很多操作，可以把這個(gè)key寫(xiě)入kafka，通知其它系統(tǒng)同步清理key。

五、總結(jié)

我們通常把緩存操作封裝到dao層以簡(jiǎn)化程序的整體邏輯，當(dāng)使用springdatajpa作為dao層的實(shí)現(xiàn)時(shí)，具體的dao方法都是interface，對(duì)于在interface上添加的cache注解，沒(méi)有辦法增加額外的其它操作。

當(dāng)需要對(duì)緩存操作做額外處理時(shí)，可以通過(guò)自定義resolver的方式實(shí)現(xiàn)，在cache注解中使用我們自定義的resolver。

這樣既沒(méi)有破環(huán)程序的整理邏輯，又?jǐn)U展了對(duì)緩存的操作，是一種比較好的實(shí)現(xiàn)方式。

本篇文章就到這里了，希望能夠給你帶來(lái)幫助，也希望您能夠多多關(guān)注腳本之家的更多內(nèi)容!  

最新評(píng)論