@CacheEvict + redis實(shí)現(xiàn)批量刪除緩存
更新時(shí)間：2021年10月12日 14:57:19 作者：llllllllll4er5ty
這篇文章主要介紹了@CacheEvict + redis實(shí)現(xiàn)批量刪除緩存方式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
@CacheEvict + redis批量刪除緩存
一、@Cacheable注解
添加緩存。
/**
* @Cacheable
* 將方法的運(yùn)行結(jié)果進(jìn)行緩存；以后再要相同的數(shù)據(jù)，直接從緩存中獲取，不用調(diào)用方法；
* CacheManager管理多個(gè)Cache組件，對(duì)緩存的真正CRUD操作在Cache組件中，每一個(gè)緩存組件有自己唯一一個(gè)名字；
*
*
* 原理：
* 1、自動(dòng)配置類(lèi)；CacheAutoConfiguration
* 2、緩存的配置類(lèi)
* org.springframework.boot.autoconfigure.cache.GenericCacheConfiguration
* org.springframework.boot.autoconfigure.cache.JCacheCacheConfiguration
* org.springframework.boot.autoconfigure.cache.EhCacheCacheConfiguration
* org.springframework.boot.autoconfigure.cache.HazelcastCacheConfiguration
* org.springframework.boot.autoconfigure.cache.InfinispanCacheConfiguration
* org.springframework.boot.autoconfigure.cache.CouchbaseCacheConfiguration
* org.springframework.boot.autoconfigure.cache.RedisCacheConfiguration
* org.springframework.boot.autoconfigure.cache.CaffeineCacheConfiguration
* org.springframework.boot.autoconfigure.cache.GuavaCacheConfiguration
* org.springframework.boot.autoconfigure.cache.SimpleCacheConfiguration【默認(rèn)】
* org.springframework.boot.autoconfigure.cache.NoOpCacheConfiguration
* 3、哪個(gè)配置類(lèi)默認(rèn)生效：SimpleCacheConfiguration；
*
* 4、給容器中注冊(cè)了一個(gè)CacheManager：ConcurrentMapCacheManager
* 5、可以獲取和創(chuàng)建ConcurrentMapCache類(lèi)型的緩存組件；他的作用將數(shù)據(jù)保存在ConcurrentMap中；
*
* 運(yùn)行流程：
* @Cacheable：
* 1、方法運(yùn)行之前，先去查詢(xún)Cache（緩存組件），按照cacheNames指定的名字獲??；
* （CacheManager先獲取相應(yīng)的緩存），第一次獲取緩存如果沒(méi)有Cache組件會(huì)自動(dòng)創(chuàng)建。
* 2、去Cache中查找緩存的內(nèi)容，使用一個(gè)key，默認(rèn)就是方法的參數(shù)；
* key是按照某種策略生成的；默認(rèn)是使用keyGenerator生成的，默認(rèn)使用SimpleKeyGenerator生成key；
* SimpleKeyGenerator生成key的默認(rèn)策略；
* 如果沒(méi)有參數(shù)；key=new SimpleKey()；
* 如果有一個(gè)參數(shù)：key=參數(shù)的值
* 如果有多個(gè)參數(shù)：key=new SimpleKey(params)；
* 3、沒(méi)有查到緩存就調(diào)用目標(biāo)方法；
* 4、將目標(biāo)方法返回的結(jié)果，放進(jìn)緩存中
*
* @Cacheable標(biāo)注的方法執(zhí)行之前先來(lái)檢查緩存中有沒(méi)有這個(gè)數(shù)據(jù)，默認(rèn)按照參數(shù)的值作為key去查詢(xún)緩存，
* 如果沒(méi)有就運(yùn)行方法并將結(jié)果放入緩存；以后再來(lái)調(diào)用就可以直接使用緩存中的數(shù)據(jù)；
*
* 核心：
* 1）、使用CacheManager【ConcurrentMapCacheManager】按照名字得到Cache【ConcurrentMapCache】組件
* 2）、key使用keyGenerator生成的，默認(rèn)是SimpleKeyGenerator
*
*
* 幾個(gè)屬性：
* cacheNames/value：指定緩存組件的名字;將方法的返回結(jié)果放在哪個(gè)緩存中，是數(shù)組的方式，可以指定多個(gè)緩存；
*
* key：緩存數(shù)據(jù)使用的key；可以用它來(lái)指定。默認(rèn)是使用方法參數(shù)的值 1-方法的返回值
* 編寫(xiě)SpEL； #i d;參數(shù)id的值 #a0 #p0 #root.args[0]
* getEmp[2]
*
* keyGenerator：key的生成器；可以自己指定key的生成器的組件id
* key/keyGenerator：二選一使用;
*
*
* cacheManager：指定緩存管理器；或者cacheResolver指定獲取解析器
*
* condition：指定符合條件的情況下才緩存；
* ,condition = "#id>0"
* condition = "#a0>1"：第一個(gè)參數(shù)的值》1的時(shí)候才進(jìn)行緩存
*
* unless:否定緩存；當(dāng)unless指定的條件為true，方法的返回值就不會(huì)被緩存；可以獲取到結(jié)果進(jìn)行判斷
* unless = "#result == null"
* unless = "#a0==2":如果第一個(gè)參數(shù)的值是2，結(jié)果不緩存；
* sync：是否使用異步模式
*
*/
二、@CacheEvict注解
清除緩存。
| cacheNames/value： | 指定緩存組件的名字;將方法的返回結(jié)果放在哪個(gè)緩存中，是數(shù)組的方式，可以指定多個(gè)緩存； |
| key | 緩存數(shù)據(jù)使用的key |
| allEntries | 是否清除這個(gè)緩存中所有的數(shù)據(jù)。true：是；false：不是 |
| beforeInvocation | 緩存的清除是否在方法之前執(zhí)行，默認(rèn)代表緩存清除操作是在方法執(zhí)行之后執(zhí)行;如果出現(xiàn)異常緩存就不會(huì)清除。true：是；false：不是 |
三、批量刪除緩存
現(xiàn)實(shí)應(yīng)用中，某些緩存都有相同的前綴或者后綴，數(shù)據(jù)庫(kù)更新時(shí)，需要?jiǎng)h除某一類(lèi)型（也就是相同前綴）的緩存。
而@CacheEvict只能單個(gè)刪除key，不支持模糊匹配刪除。
解決辦法：使用redis + @CacheEvict解決。
@CacheEvict實(shí)際上是調(diào)用RedisCache的evict方法刪除緩存的。下面為RedisCache的部分代碼，可以看到，evict方法是不支持模糊匹配的，而clear方法是支持模糊匹配的。
/*
* (non-Javadoc)
* @see org.springframework.cache.Cache#evict(java.lang.Object)
*/
@Override
public void evict(Object key) {
cacheWriter.remove(name, createAndConvertCacheKey(key));
}
/*
* (non-Javadoc)
* @see org.springframework.cache.Cache#clear()
*/
@Override
public void clear() {
byte[] pattern = conversionService.convert(createCacheKey("*"), byte[].class);
cacheWriter.clean(name, pattern);
}
所以，只需重寫(xiě)RedisCache的evict方法就可以解決模糊匹配刪除的問(wèn)題。
四、代碼
4.1 自定義RedisCache：
public class CustomizedRedisCache extends RedisCache {
private static final String WILD_CARD = "*";
private final String name;
private final RedisCacheWriter cacheWriter;
private final ConversionService conversionService;
protected CustomizedRedisCache(String name, RedisCacheWriter cacheWriter, RedisCacheConfiguration cacheConfig) {
super(name, cacheWriter, cacheConfig);
this.name = name;
this.cacheWriter = cacheWriter;
this.conversionService = cacheConfig.getConversionService();
}
@Override
public void evict(Object key) {
if (key instanceof String) {
String keyString = key.toString();
if (keyString.endsWith(WILD_CARD)) {
evictLikeSuffix(keyString);
return;
}
if (keyString.startsWith(WILD_CARD)) {
evictLikePrefix(keyString);
return;
}
}
super.evict(key);
}
/**
* 前綴匹配
*
* @param key
*/
public void evictLikePrefix(String key) {
byte[] pattern = this.conversionService.convert(this.createCacheKey(key), byte[].class);
this.cacheWriter.clean(this.name, pattern);
}
/**
* 后綴匹配
*
* @param key
*/
public void evictLikeSuffix(String key) {
byte[] pattern = this.conversionService.convert(this.createCacheKey(key), byte[].class);
this.cacheWriter.clean(this.name, pattern);
}
}
4.2 重寫(xiě)RedisCacheManager，使用自定義的RedisCache：
public class CustomizedRedisCacheManager extends RedisCacheManager {
private final RedisCacheWriter cacheWriter;
private final RedisCacheConfiguration defaultCacheConfig;
private final Map<String, RedisCacheConfiguration> initialCaches = new LinkedHashMap<>();
private boolean enableTransactions;
public CustomizedRedisCacheManager(RedisCacheWriter cacheWriter, RedisCacheConfiguration defaultCacheConfiguration) {
super(cacheWriter, defaultCacheConfiguration);
this.cacheWriter = cacheWriter;
this.defaultCacheConfig = defaultCacheConfiguration;
}
public CustomizedRedisCacheManager(RedisCacheWriter cacheWriter, RedisCacheConfiguration defaultCacheConfiguration, String... initialCacheNames) {
super(cacheWriter, defaultCacheConfiguration, initialCacheNames);
this.cacheWriter = cacheWriter;
this.defaultCacheConfig = defaultCacheConfiguration;
}
public CustomizedRedisCacheManager(RedisCacheWriter cacheWriter, RedisCacheConfiguration defaultCacheConfiguration, boolean allowInFlightCacheCreation, String... initialCacheNames) {
super(cacheWriter, defaultCacheConfiguration, allowInFlightCacheCreation, initialCacheNames);
this.cacheWriter = cacheWriter;
this.defaultCacheConfig = defaultCacheConfiguration;
}
public CustomizedRedisCacheManager(RedisCacheWriter cacheWriter, RedisCacheConfiguration defaultCacheConfiguration, Map<String, RedisCacheConfiguration> initialCacheConfigurations) {
super(cacheWriter, defaultCacheConfiguration, initialCacheConfigurations);
this.cacheWriter = cacheWriter;
this.defaultCacheConfig = defaultCacheConfiguration;
}
public CustomizedRedisCacheManager(RedisCacheWriter cacheWriter, RedisCacheConfiguration defaultCacheConfiguration, Map<String, RedisCacheConfiguration> initialCacheConfigurations, boolean allowInFlightCacheCreation) {
super(cacheWriter, defaultCacheConfiguration, initialCacheConfigurations, allowInFlightCacheCreation);
this.cacheWriter = cacheWriter;
this.defaultCacheConfig = defaultCacheConfiguration;
}
/**
* 這個(gè)構(gòu)造方法最重要
**/
public CustomizedRedisCacheManager(RedisConnectionFactory redisConnectionFactory, RedisCacheConfiguration cacheConfiguration) {
this(RedisCacheWriter.nonLockingRedisCacheWriter(redisConnectionFactory),cacheConfiguration);
}
/**
* 覆蓋父類(lèi)創(chuàng)建RedisCache
*/
@Override
protected RedisCache createRedisCache(String name, @Nullable RedisCacheConfiguration cacheConfig) {
return new CustomizedRedisCache(name, cacheWriter, cacheConfig != null ? cacheConfig : defaultCacheConfig);
}
@Override
public Map<String, RedisCacheConfiguration> getCacheConfigurations() {
Map<String, RedisCacheConfiguration> configurationMap = new HashMap<>(getCacheNames().size());
getCacheNames().forEach(it -> {
RedisCache cache = CustomizedRedisCache.class.cast(lookupCache(it));
configurationMap.put(it, cache != null ? cache.getCacheConfiguration() : null);
});
return Collections.unmodifiableMap(configurationMap);
}
}
4.3 在RedisTemplateConfig中使用自定義的CacheManager
@Bean
public CacheManager oneDayCacheManager(RedisConnectionFactory factory) {
RedisSerializer<String> redisSerializer = new StringRedisSerializer();
Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
//解決查詢(xún)緩存轉(zhuǎn)換異常的問(wèn)題
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
// 配置序列化（解決亂碼的問(wèn)題）
RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
// 1天緩存過(guò)期
.entryTtl(Duration.ofDays(1))
.serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))
.computePrefixWith(name -> name + ":")
.disableCachingNullValues();
return new CustomizedRedisCacheManager(factory, config);
}
4.4 在代碼方法上使用@CacheEvict模糊匹配刪除
@Cacheable(value = "current_group", cacheManager = "oneDayCacheManager",
key = "#currentAttendanceGroup.getId() + ':' + args[1]", unless = "#result eq null")
public String getCacheAttendanceId(CurrentAttendanceGroupDO currentAttendanceGroup, String dateStr) {
// 方法體
}
@CacheEvict(value = "current_group", key = "#currentAttendanceGroup.getId() + ':' + '*'", beforeInvocation = true)
public void deleteCacheAttendanceId(CurrentAttendanceGroupDO currentAttendanceGroup) {
}
注意：如果RedisTemplateConfig中有多個(gè)CacheManager，可以使用@Primary注解標(biāo)注默認(rèn)生效的CacheManager
@CacheEvict清除指定下所有緩存
@CacheEvict(cacheNames = "parts:grid",allEntries = true)
此注解會(huì)清除part:grid下所有緩存
@CacheEvict要求指定一個(gè)或多個(gè)緩存，使之都受影響。
此外，還提供了一個(gè)額外的參數(shù)allEntries 。表示是否需要清除緩存中的所有元素。
默認(rèn)為false，表示不需要。當(dāng)指定了allEntries為true時(shí)，Spring Cache將忽略指定的key。
有的時(shí)候我們需要Cache一下清除所有的元素。
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
Java easyui樹(shù)形表格TreeGrid的實(shí)現(xiàn)代碼
這篇文章主要為大家詳細(xì)介紹了Java easyui樹(shù)形表格TreeGrid的實(shí)現(xiàn)代碼，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-03-03
Java運(yùn)行時(shí)環(huán)境之ClassLoader類(lèi)加載機(jī)制詳解
這篇文章主要給大家介紹了關(guān)于Java運(yùn)行時(shí)環(huán)境之ClassLoader類(lèi)加載機(jī)制的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-01-01
Java?Ribbon與openfeign區(qū)別和用法講解
Ribbon是基于Netflix?Ribbon實(shí)現(xiàn)的一套客戶(hù)端負(fù)載均衡的工具，主要功能是提供客戶(hù)端的軟件負(fù)載均衡算法和服務(wù)調(diào)用。openfeign對(duì)Feign進(jìn)行了增強(qiáng)，使其支持Spring MVC注解，另外還整合了Ribbon和Nacos，從而使得Feign的使用更加方便2022-08-08
Java基礎(chǔ)之SpringBoot整合knife4j
Swagger現(xiàn)在已經(jīng)成了最流行的接口文檔生成與管理工具,但是你是否在用的時(shí)候也在吐槽,它是真的不好看,接口測(cè)試的json數(shù)據(jù)沒(méi)法格式化,測(cè)試地址如果更改了還要去改配置,接口測(cè)試時(shí)增加token驗(yàn)證是真的麻煩…針對(duì)Swagger的種種缺點(diǎn),Knife4j就呼之欲出了.需要的朋友可以參考下2021-05-05
大家好，本篇文章主要講的是Java中接口的多態(tài)詳解，感興趣的同學(xué)趕快來(lái)看一看吧，對(duì)你有幫助的話(huà)記得收藏一下2022-02-02
SpringBoot限制接口訪(fǎng)問(wèn)頻率避坑
這篇文章主要為大家介紹了SpringBoot限制接口訪(fǎng)問(wèn)頻率避坑，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-05-05
這篇文章主要介紹了springboot如何使用sm2加密傳輸問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-04-04
關(guān)于Java?中?Future?的?get?方法超時(shí)問(wèn)題
這篇文章主要介紹了Java?中?Future?的?get?方法超時(shí),最常見(jiàn)的理解就是，“超時(shí)以后，當(dāng)前線(xiàn)程繼續(xù)執(zhí)行，線(xiàn)程池里的對(duì)應(yīng)線(xiàn)程中斷”，真的是這樣嗎？本文給大家詳細(xì)介紹，需要的朋友參考下吧2022-06-06
這篇文章主要介紹了Java for循環(huán)方法，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2019-03-03
如何解決java.util.concurrent.CancellationException問(wèn)題
這篇文章主要介紹了如何解決java.util.concurrent.CancellationException問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-05-05