redis批量查询key问题处理

back_recharge
duhui 2021-03-08 15:29:40 +08:00
parent 50ce973616
commit 3a3b2725e3
3 changed files with 5 additions and 16 deletions

View File

@ -653,11 +653,8 @@ public class DeathPathLogic {
// redisUtil.del(RedisKey.getKey(personRank.getRedisKey(),"",false)); // redisUtil.del(RedisKey.getKey(personRank.getRedisKey(),"",false));
} }
Set<String> keys = RedisUtil.getInstence().getDimKey(serverId + ":DEATH_PATH*", -1); Set<String> keys = RedisUtil.getInstence().getDimKey(serverId + ":DEATH_PATH*", -1);
keys.forEach(key->{ keys.forEach(key-> RedisUtil.getInstence().del(key));
RedisUtil.getInstence().del(key);
});
} }
public static int nextDiscrete(double[] probs) { public static int nextDiscrete(double[] probs) {

View File

@ -308,9 +308,7 @@ public class HelpHeroLogic {
String key = serverId +":" + RedisKey.HELP_FIGHT + "*"; String key = serverId +":" + RedisKey.HELP_FIGHT + "*";
// 模糊批量删除key // 模糊批量删除key
Set<String> keys = RedisUtil.getInstence().getDimKey(key, -1); Set<String> keys = RedisUtil.getInstence().getDimKey(key, -1);
keys.forEach(k->{ keys.forEach(k->RedisUtil.getInstence().del(k));
RedisUtil.getInstence().del(k);
});
} }
/** /**

View File

@ -222,15 +222,9 @@ public abstract class AbstractRank implements IRank {
} }
public void removeAllRank(String rkey){ public void removeAllRank(String rkey){
try { try {
Set<String> dimKey = RedisUtil.getInstence().getDimKey(RedisKey.getKey(redisKey, rkey, false) + "*", 200);
Cursor<String> cursor2 =RedisUtil.getInstence().scan( RedisKey.getKey(redisKey,rkey,false)+"*", 200); dimKey.forEach(item->RedisUtil.getInstence().del(item));
while (cursor2.hasNext()){ } catch (Exception e) {
String next = cursor2.next();
LOGGER.info("删除排行{}",next);
RedisUtil.getInstence().del(next);
}
cursor2.close();
} catch (IOException e) {
e.printStackTrace(); e.printStackTrace();
} }
} }