From 3a3b2725e3a5334ee4b7df55b8e5054eec0d1d15 Mon Sep 17 00:00:00 2001 From: duhui Date: Mon, 8 Mar 2021 15:29:40 +0800 Subject: [PATCH] =?UTF-8?q?redis=E6=89=B9=E9=87=8F=E6=9F=A5=E8=AF=A2key?= =?UTF-8?q?=E9=97=AE=E9=A2=98=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ljsd/jieling/logic/family/DeathPathLogic.java | 5 +---- .../com/ljsd/jieling/logic/help/HelpHeroLogic.java | 4 +--- .../jieling/logic/rank/rankImpl/AbstractRank.java | 12 +++--------- 3 files changed, 5 insertions(+), 16 deletions(-) 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(); } }