概述
设计如下： 在接口层传入缓存key的前缀，通过匹配的方式将能匹配到该前缀的所有key均删除。
举个例子
如上3个key,当我们传入shopcategory这个前缀时，会将如上3个前缀全部清除掉。
接口层改造
为了方便使用前缀，我们在将之前定义在方法体中的前缀抽取到接口层，如下所示
public interface AreaService { // redis key的前缀，抽取到接口层，方便使用 public static final String AREALISTKEY = "arealist"; ..... ..... }
public interface HeadLineService { // redis key的前缀，抽取到接口层，方便使用 public static final String HEADLINEKEY = "headline"; ..... ..... }
public interface ShopCategoryService { // redis key的前缀，抽取到接口层，方便使用 public static final String SCLISTKEY = "shopcategory"; ..... ..... }
CacheService接口
package com.artisan.o2o.service; public interface CacheService { /** * * * @Title: removeFromCache * * @Description: 根据缓存的前缀清理匹配的全部缓存 * * @param keyPrefix * * @return: void */ void removeFromCache(String keyPrefix); }
CacheService接口实现类
package com.artisan.o2o.service.impl; import java.util.Set; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.artisan.o2o.cache.JedisUtil; import com.artisan.o2o.service.CacheService; @Service public class CacheServiceImpl implements CacheService { @Autowired JedisUtil.Keys jedisKeys; @Override public void removeFromCache(String keyPrefix) { Set<String> keySet = jedisKeys.keys(keyPrefix + "*"); for (String key : keySet) { jedisKeys.del(key); } } }
工具类中的方法
/** * 查找所有匹配给定的模式的键 * * @param String * key的表达式,*表示多个，？表示一个 * */ public Set<String> keys(String pattern) { Jedis jedis = getJedis(); Set<String> set = jedis.keys(pattern); jedis.close(); return set; } /** * 删除keys对应的记录,可以是多个key * * @param String * ... keys * @return 删除的记录数 * */ public long del(String... keys) { Jedis jedis = getJedis(); long count = jedis.del(keys); jedis.close(); return count; }
单元测试
package com.artisan.o2o.service; import java.io.IOException; import java.util.List; import org.junit.Test; import org.springframework.beans.factory.annotation.Autowired; import com.artisan.o2o.BaseTest; import com.artisan.o2o.entity.Area; import com.fasterxml.jackson.core.JsonParseException; import com.fasterxml.jackson.databind.JsonMappingException; public class AreaServiceTest extends BaseTest { @Autowired AreaService areaService; @Autowired CacheService cacheService; @Test public void testGetAreaList() throws JsonParseException, JsonMappingException, IOException { // 首次从db中加载 List<Area> areaList = areaService.getAreaList(); for (Area area : areaList) { System.out.println("||---->" + area.toString()); } // 再次查询从redis中获取 areaList = areaService.getAreaList(); for (Area area : areaList) { System.out.println("**---->" + area.toString()); } // 清除缓存 cacheService.removeFromCache(AreaService.AREALISTKEY); // 再次查询 从db中获取 areaList = areaService.getAreaList(); for (Area area : areaList) { System.out.println("**---->" + area.toString()); } // 再次查询从redis中获取 areaList = areaService.getAreaList(); for (Area area : areaList) { System.out.println("**---->" + area.toString()); } } }
观察数据，确保测试结果符合预期。 比较简单就不贴数据了。
Github地址
代码地址： https://github.com/yangshangwei/o2o
