package com.javaweb.redis.service;
|
|
|
import com.javaweb.common.core.domain.AjaxResult;
|
import com.javaweb.common.core.page.TableDataInfo;
|
import com.javaweb.common.utils.StringUtils;
|
import com.javaweb.redis.util.RedisUtil;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
|
import java.util.ArrayList;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Service
|
public class RedisCacheMonitorService {
|
protected Logger logger = LoggerFactory.getLogger(getClass());
|
|
public Object removeCacheByKey(String key){
|
if(RedisUtil.exists(key)){
|
RedisUtil.del(key);
|
return AjaxResult.success("清除缓存成功!");
|
}
|
return AjaxResult.error("不存在key为["+key+"]的缓存!");
|
}
|
public Map<String,Object> viewCacheInfoByKey(String key){
|
Map<String,Object> res=new HashMap();
|
if(RedisUtil.exists(key)){
|
res.put("key",key);
|
String value= RedisUtil.getStringValue(key);
|
res.put("value",value);
|
}
|
return res;
|
}
|
/**
|
* 获取缓存分页信息
|
* @param map
|
* @return
|
*/
|
public Object listPg(Map<String, Object> map) {
|
try {
|
String keyContent = String.valueOf(map.get("keyContent"));
|
|
String page_str = (String) map.get("pageNum");//当前页
|
String limit_str = (String) map.get("pageSize");//每页几条数据
|
page_str = StringUtils.assertNotNullOrEmpty(page_str, "1");
|
limit_str = StringUtils.assertNotNullOrEmpty(limit_str, "10");
|
int page = Integer.parseInt(page_str);
|
int limit = Integer.parseInt(limit_str);
|
int start = page - 1;
|
if (page == 1 || page == 0) {
|
start = 0;
|
}
|
if (StringUtils.isEmpty(keyContent)) {
|
keyContent = "*";
|
} else {
|
keyContent = "*" + keyContent + "*";
|
}
|
List<String> keysList = RedisUtil.keys(keyContent);
|
int keysCount = keysList.size();
|
List<Map<String, Object>> mapList = new ArrayList<Map<String, Object>>();
|
Map<String, Object> temp = null;
|
for (int i = start * limit; i < keysCount && i < (start + 1) * limit; i++) {
|
temp = new HashMap<>();
|
String key = keysList.get(i);
|
String type = RedisUtil.type(key);
|
long ttl = RedisUtil.ttl(key);
|
temp.put("key", key);
|
temp.put("type", type);
|
temp.put("ttl", ttl);
|
mapList.add(temp);
|
}
|
TableDataInfo tableDataInfo=new TableDataInfo();
|
tableDataInfo.setTotal(keysCount);
|
tableDataInfo.setRows(mapList);
|
tableDataInfo.setCode(0);
|
tableDataInfo.setMsg(0);
|
|
return tableDataInfo;
|
}catch (Exception ex){
|
ex.printStackTrace();
|
return AjaxResult.error("获取缓存分页信息失败!");
|
}
|
}
|
|
|
}
|
