javamap模糊匹配key_SpringCache扩展@CacheEvict的key模糊匹配清除

javamap模糊匹配key_SpringCache扩展@CacheEvict的key

模糊匹配清除

之前就⼀直集成SpringCache+redis缓存数据，这次项⽬中的缓存⼀直有缓存清除失效的问题，我就花时间好好梳理了⼀番，主要是针对@CacheEvict的key模糊匹配⽀持。熟悉redis命令的⼈都知道，查询和删除都可以做模糊匹配，所以我就想让SpringCache也⽀持模糊匹配清除。

起因是对外发布的API接⼝做了缓存，API需要⽀持分页，所以在@Cacheable的key中⽤current(当前页码)和classify(分类)做了匹配，在改动数据集的时候，如果每次都把所有分类的key全部清除掉有点不合理，如果只是针对改动数据集中某个分类做key的清理，这样最节省资源。

开始⾏动，查看SpringCache源码和原理，具体的可以⽹上查，我只想说重点。

到RedisCache中的evict，对应的就是@CacheEvict最终的执⾏⽅法，看到下⾯有个clear⽅法，使⽤的就是模糊匹配批量清除，⼀下觉得有戏。

/** (non-Javadoc)* @see org.springframework.cache.Cache#evict(java.lang.Object)*/@Overridepublic voidevict(Object key) {ve(name, createAndConvertCacheKey(key)); //remove只能针对单个key删除操作

}

/** (non-Javadoc)* @see org.springframework.cache.Cache#clear()*/@Overridepublic voidclear() {

byte[]pattern = vert(createCacheKey("*"), byte[].class);

cacheWriter.clean(name, pattern); //clean⽀持模糊匹配，这个是扩展的时候重点

}

1.先写个RedisCache⼦类，在实际中替代RedisCache

public classCustomizedRedisCache extendsRedisCache {

private finalString name;

private finalRedisCacheWriter cacheWriter;

private finalConversionService conversionService;

protectedCustomizedRedisCache(String name, RedisCacheWriter cacheWriter, RedisCacheConfiguration cacheConfig) {super(name, cacheWriter, cacheConfig);

this.name= name;

this.cacheWriter=cacheWriter;

}

@Overridepublic voidevict(Object key) {if(key instanceofString){String String();

dsWith(keyString,"*")){evictLikeSuffix(keyString);

return;

}if(StringUtils.startsWith(keyString,"*")){evictLikePrefix(keyString);

return;

}}super.evict(key);

}

*** 前缀匹配*@paramkey*/public voidevictLikePrefix(String key) {byte[]pattern =

this.cacheWriter.clean(this.name, pattern);

}

/*** 后缀匹配*@paramkey*/public voidevictLikeSuffix(String key) {byte[]pattern =

(byte[])ateCacheKey(key), byte[].class);

this.cacheWriter.clean(this.name, pattern);

}

//前后都匹配的就不需要了，直接allEntries=true

}

2.要想让⾃定义的CustomizedRedisCache替换RedisCache，还必须弄个RedisCacheManager的⼦类，RedisCache的创建过程是在manager中

public classCustomizedRedisCacheManager extendsRedisCacheManager {

private finalRedisCacheWriter cacheWriter;

private finalRedisCacheConfiguration defaultCacheConfig;

private finalMapinitialCaches= newLinkedHashMap<>();

private booleanenableTransactions;

cacheablepublicCustomizedRedisCacheManager(RedisCacheWriter cacheWriter, RedisCacheConfiguration defaultCacheConfiguration) {super(cacheWriter, defaultCacheConfiguration);

this.cacheWriter= cacheWriter;