diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/family/DeathPathLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/family/DeathPathLogic.java index 00bae6e0d..c1fe03cb0 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/family/DeathPathLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/family/DeathPathLogic.java @@ -653,11 +653,8 @@ public class DeathPathLogic { // redisUtil.del(RedisKey.getKey(personRank.getRedisKey(),"",false)); } - Set keys = RedisUtil.getInstence().getDimKey(serverId + ":DEATH_PATH*", -1); - keys.forEach(key->{ - RedisUtil.getInstence().del(key); - }); + keys.forEach(key-> RedisUtil.getInstence().del(key)); } public static int nextDiscrete(double[] probs) { diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/help/HelpHeroLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/help/HelpHeroLogic.java index 228d47b61..f2d7e0794 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/help/HelpHeroLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/help/HelpHeroLogic.java @@ -308,9 +308,7 @@ public class HelpHeroLogic { String key = serverId +":" + RedisKey.HELP_FIGHT + "*"; // 模糊批量删除key Set keys = RedisUtil.getInstence().getDimKey(key, -1); - keys.forEach(k->{ - RedisUtil.getInstence().del(k); - }); + keys.forEach(k->RedisUtil.getInstence().del(k)); } /** diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/AbstractRank.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/AbstractRank.java index 7d19bc86a..2597775a0 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/AbstractRank.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/rank/rankImpl/AbstractRank.java @@ -222,15 +222,9 @@ public abstract class AbstractRank implements IRank { } public void removeAllRank(String rkey){ try { - - Cursor cursor2 =RedisUtil.getInstence().scan( RedisKey.getKey(redisKey,rkey,false)+"*", 200); - while (cursor2.hasNext()){ - String next = cursor2.next(); - LOGGER.info("删除排行{}",next); - RedisUtil.getInstence().del(next); - } - cursor2.close(); - } catch (IOException e) { + Set dimKey = RedisUtil.getInstence().getDimKey(RedisKey.getKey(redisKey, rkey, false) + "*", 200); + dimKey.forEach(item->RedisUtil.getInstence().del(item)); + } catch (Exception e) { e.printStackTrace(); } }