概述
设计如下：在通达信接口dll函数破解,接口层传入缓存key的前缀，通过匹配的方式将能匹配到该前缀的所有key均删除。
举个例子
如上3个key,当我们传入shopcategory这个前缀时，会将如上3个前缀全部清除掉。
通达信接口dll函数破解,接口层改造
为了方便使用前缀，我们在将之前定义在方法体中的前缀抽取到通达信接口dll函数破解,接口层，如下所示
public interface AreaService {
// redis key的前缀，抽取到通达信接口dll函数破解,接口层，方便使用
public static final String AREALISTKEY = 'arealist';
.....
.....
}
public interface HeadLineService {
// redis key的前缀，抽取到通达信接口dll函数破解,接口层，方便使用
public static final String HEADLINEKEY = 'headline';
.....
.....
}
public interface ShopCategoryService {
// redis key的前缀，抽取到通达信接口dll函数破解,接口层，方便使用
public static final String SCLISTKEY = 'shopcategory';
.....
.....
}
package com.artisan.o2o.service;
public interface CacheService {
/**
*
*
* @Title: removeFromCache
*
* @Description: 根据缓存的前缀清理匹配的全部缓存
*
* @param keyPrefix
*
* @return: void
*/
void removeFromCache(String keyPrefix);
}
CacheService通达信接口dll函数破解,接口实现类
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 keySet = jedisKeys.keys(keyPrefix + '*');
for (String key : keySet) {
jedisKeys.del(key);
}
}
}
工具类中的方法
/**
* 查找所有匹配给定的模式的键
*
* @param String
* key的表达式,*表示多个，？表示一个
* */
public Set keys(String pattern) {
Jedis jedis = getJedis();
Set 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 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地址
文章为作者独立观点，不代表股票交易接口观点
股民评论