您好,登錄后才能下訂單哦!
本篇內(nèi)容介紹了“spring緩存自定義resolver的方法怎么用”的有關(guān)知識(shí),在實(shí)際案例的操作過(guò)程中,不少人都會(huì)遇到這樣的困境,接下來(lái)就讓小編帶領(lǐng)大家學(xué)習(xí)一下如何處理這些情況吧!希望大家仔細(xì)閱讀,能夠?qū)W有所成!
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é),可以專注于業(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í)該怎樣處理?
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。
上面我們介紹了如果配置和引用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類,繼承SimpleCacheResolver
。SimpleCacheResolver
類是spring在cache注解中默認(rèn)使用的resolver。
我們通過(guò)擴(kuò)展SimpleCacheResolver這個(gè)類,來(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
類用于解析這種特殊的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。
“spring緩存自定義resolver的方法怎么用”的內(nèi)容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業(yè)相關(guān)的知識(shí)可以關(guān)注億速云網(wǎng)站,小編將為大家輸出更多高質(zhì)量的實(shí)用文章!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。