feat(kv): hot-key-calculator support set different config for read/wr…

…ite command (#332)
netease-im · Oct 12, 2024 · c1ee941 · c1ee941
1 parent 9e90951
commit c1ee941
Show file tree

Hide file tree

Showing 38 changed files with 67 additions and 47 deletions.
diff --git a/...re/src/main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/cache/HashLRUCache.java b/...re/src/main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/cache/HashLRUCache.java
@@ -3,6 +3,7 @@
 import com.netease.nim.camellia.redis.proxy.cluster.ClusterModeStatus;
 import com.netease.nim.camellia.redis.proxy.cluster.ProxyClusterSlotMapUtils;
 import com.netease.nim.camellia.redis.proxy.conf.ProxyDynamicConf;
+import com.netease.nim.camellia.redis.proxy.enums.RedisCommand;
 import com.netease.nim.camellia.redis.proxy.upstream.kv.conf.RedisKvConf;
 import com.netease.nim.camellia.redis.proxy.upstream.kv.meta.KeyType;
 import com.netease.nim.camellia.tools.utils.BytesKey;
@@ -62,8 +63,8 @@ private void rebuild() {
         this.capacity = capacity;
     }
 
-    public boolean isHotKey(byte[] key) {
-        return hotKeyCalculator.isHotKey(key);
+    public boolean isHotKey(byte[] key, RedisCommand redisCommand) {
+        return hotKeyCalculator.isHotKey(key, redisCommand);
     }
 
     public void putAllForRead(int slot, byte[] cacheKey, RedisHash hash) {

diff --git a/...rc/main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/cache/HotKeyCalculator.java b/...rc/main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/cache/HotKeyCalculator.java
@@ -2,6 +2,7 @@
 
 import com.googlecode.concurrentlinkedhashmap.ConcurrentLinkedHashMap;
 import com.netease.nim.camellia.redis.proxy.conf.ProxyDynamicConf;
+import com.netease.nim.camellia.redis.proxy.enums.RedisCommand;
 import com.netease.nim.camellia.redis.proxy.upstream.kv.conf.RedisKvConf;
 import com.netease.nim.camellia.redis.proxy.upstream.kv.meta.KeyType;
 import com.netease.nim.camellia.redis.proxy.util.TimeCache;
@@ -24,6 +25,8 @@ public class HotKeyCalculator {
     private final KeyType keyType;
     private ConcurrentLinkedHashMap<BytesKey, Node> cache;
     private int threshold;
+    private int readThreshold;
+    private int writeThreshold;
     private int capacity;
     private long window;
 
@@ -50,25 +53,39 @@ private void rebuild() {
         }
 
         int defaultThreshold = RedisKvConf.getInt(namespace, "kv.hot.key.threshold", 2);
+        int defaultReadThreshold = RedisKvConf.getInt(namespace, "kv.hot.key.read.threshold", -1);
+        int defaultWriteThreshold = RedisKvConf.getInt(namespace, "kv.hot.key.write.threshold", -1);
         int defaultWindow = RedisKvConf.getInt(namespace, "kv.hot.key.time.window", 5000);
 
         int threshold = RedisKvConf.getInt(namespace, keyType + ".kv.hot.key.threshold", defaultThreshold);
+        int readThreshold = RedisKvConf.getInt(namespace, keyType + ".kv.hot.key.read.threshold", defaultReadThreshold);
+        int writeThreshold = RedisKvConf.getInt(namespace, keyType + ".kv.hot.key.write.threshold", defaultWriteThreshold);
         int window = RedisKvConf.getInt(namespace, keyType + ".kv.hot.key.time.window", defaultWindow);
-        if (this.threshold != threshold) {
-            logger.info("kv hot key calculator cache build, namespace = {}, keyType = {}, threshold = {}", namespace, keyType, threshold);
+
+        if (this.threshold != threshold || this.readThreshold != readThreshold || this.writeThreshold != writeThreshold) {
+            logger.info("kv hot key calculator cache config update, namespace = {}, keyType = {}, threshold = {}, read.threshold = {}, write.threshold = {}",
+                    namespace, keyType, threshold, readThreshold, writeThreshold);
             this.threshold = threshold;
-            if (this.threshold < 0) {
+            this.readThreshold = readThreshold;
+            this.writeThreshold = writeThreshold;
+            if (this.threshold < 0 && this.writeThreshold < 0 && this.readThreshold < 0) {
                 cache.clear();
             }
         }
         if (this.window != window) {
-            logger.info("kv hot key calculator cache build, namespace = {}, keyType = {}, window = {}", namespace, keyType, window);
+            logger.info("kv hot key calculator cache config update, namespace = {}, keyType = {}, window = {}", namespace, keyType, window);
             this.window = window;
         }
     }
 
-    public boolean isHotKey(byte[] key) {
-        if (threshold < 0) {
+    public boolean isHotKey(byte[] key, RedisCommand redisCommand) {
+        int targetThreshold;
+        if (redisCommand.getType() == RedisCommand.Type.READ) {
+            targetThreshold = readThreshold < 0 ? threshold : readThreshold;
+        } else {
+            targetThreshold = writeThreshold < 0 ? threshold : writeThreshold;
+        }
+        if (targetThreshold < 0) {
             return false;
         }
         BytesKey bytesKey = new BytesKey(key);
@@ -78,7 +95,7 @@ public boolean isHotKey(byte[] key) {
             node.count.set(last / 2);
             node.time = TimeCache.currentMillis;
         }
-        return node.count.incrementAndGet() > threshold;
+        return node.count.incrementAndGet() > targetThreshold;
     }
 
     public long estimateSize() {

diff --git a/...ore/src/main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/cache/SetLRUCache.java b/...ore/src/main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/cache/SetLRUCache.java
@@ -3,6 +3,7 @@
 import com.netease.nim.camellia.redis.proxy.cluster.ClusterModeStatus;
 import com.netease.nim.camellia.redis.proxy.cluster.ProxyClusterSlotMapUtils;
 import com.netease.nim.camellia.redis.proxy.conf.ProxyDynamicConf;
+import com.netease.nim.camellia.redis.proxy.enums.RedisCommand;
 import com.netease.nim.camellia.redis.proxy.upstream.kv.conf.RedisKvConf;
 import com.netease.nim.camellia.redis.proxy.upstream.kv.meta.KeyType;
 import com.netease.nim.camellia.tools.utils.BytesKey;
@@ -62,8 +63,8 @@ private void rebuild() {
         this.capacity = capacity;
     }
 
-    public boolean isHotKey(byte[] key) {
-        return hotKeyCalculator.isHotKey(key);
+    public boolean isHotKey(byte[] key, RedisCommand redisCommand) {
+        return hotKeyCalculator.isHotKey(key, redisCommand);
     }
 
     public void putAllForRead(int slot, byte[] cacheKey, RedisSet set) {

diff --git a/...re/src/main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/cache/ZSetLRUCache.java b/...re/src/main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/cache/ZSetLRUCache.java
@@ -3,6 +3,7 @@
 import com.netease.nim.camellia.redis.proxy.cluster.ClusterModeStatus;
 import com.netease.nim.camellia.redis.proxy.cluster.ProxyClusterSlotMapUtils;
 import com.netease.nim.camellia.redis.proxy.conf.ProxyDynamicConf;
+import com.netease.nim.camellia.redis.proxy.enums.RedisCommand;
 import com.netease.nim.camellia.redis.proxy.upstream.kv.command.zset.utils.ZSetLex;
 import com.netease.nim.camellia.redis.proxy.upstream.kv.command.zset.utils.ZSetScore;
 import com.netease.nim.camellia.redis.proxy.upstream.kv.conf.RedisKvConf;
@@ -63,8 +64,8 @@ private void rebuild() {
         this.capacity = capacity;
     }
 
-    public boolean isHotKey(byte[] key) {
-        return hotKeyCalculator.isHotKey(key);
+    public boolean isHotKey(byte[] key, RedisCommand redisCommand) {
+        return hotKeyCalculator.isHotKey(key, redisCommand);
     }
 
     public void putZSetForWrite(int slot, byte[] cacheKey, RedisZSet zSet) {

diff --git a/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HDelCommander.java b/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HDelCommander.java
@@ -111,7 +111,7 @@ protected Reply execute(int slot, Command command) {
                 return IntegerReply.REPLY_0;
             }
             if (deleteMaps == null) {
-                boolean hotKey = hashLRUCache.isHotKey(key);
+                boolean hotKey = hashLRUCache.isHotKey(key, redisCommand());
                 if (hotKey) {
                     //
                     type = KvCacheMonitor.Type.kv_store;

diff --git a/.../java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HExistsCommander.java b/.../java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HExistsCommander.java
@@ -110,7 +110,7 @@ protected Reply execute(int slot, Command command) {
                 return IntegerReply.parse(hash.hexists(new BytesKey(field)));
             }
 
-            boolean hotKey = hashLRUCache.isHotKey(key);
+            boolean hotKey = hashLRUCache.isHotKey(key, redisCommand());
 
             if (hotKey) {
                 hash = loadLRUCache(slot, keyMeta, key);

diff --git a/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HGetCommander.java b/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HGetCommander.java
@@ -112,7 +112,7 @@ protected Reply execute(int slot, Command command) {
                 return new BulkReply(hash.hget(new BytesKey(field)));
             }
 
-            boolean hotKey = hashLRUCache.isHotKey(key);
+            boolean hotKey = hashLRUCache.isHotKey(key, redisCommand());
             if (hotKey) {
                 hash = loadLRUCache(slot, keyMeta, key);
                 hashLRUCache.putAllForRead(slot, cacheKey, hash);

diff --git a/...in/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HKeysCommander.java b/...in/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HKeysCommander.java
@@ -104,7 +104,7 @@ protected Reply execute(int slot, Command command) {
                 KvCacheMonitor.localCache(cacheConfig.getNamespace(), redisCommand().strRaw());
                 return toReply(hash.hgetAll());
             }
-            boolean hotKey = hashLRUCache.isHotKey(key);
+            boolean hotKey = hashLRUCache.isHotKey(key, redisCommand());
             if (hotKey) {
                 hash = loadLRUCache(slot, keyMeta, key);
                 hashLRUCache.putAllForRead(slot, cacheKey, hash);

diff --git a/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HLenCommander.java b/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HLenCommander.java
@@ -116,7 +116,7 @@ private Reply getSizeFromCache(int slot, KeyMeta keyMeta, byte[] key, byte[] cac
             if (checkHotKey) {
                 EncodeVersion encodeVersion = keyMeta.getEncodeVersion();
                 if (encodeVersion == EncodeVersion.version_1) {
-                    boolean hotKey = hashLRUCache.isHotKey(key);
+                    boolean hotKey = hashLRUCache.isHotKey(key, redisCommand());
                     if (hotKey) {
                         hash = loadLRUCache(slot, keyMeta, key);
                         hashLRUCache.putAllForRead(slot, cacheKey, hash);

diff --git a/...in/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HMGetCommander.java b/...in/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HMGetCommander.java
@@ -125,7 +125,7 @@ protected Reply execute(int slot, Command command) {
                 return toReply2(fields, hash.hgetAll());
             }
 
-            boolean hotKey = hashLRUCache.isHotKey(key);
+            boolean hotKey = hashLRUCache.isHotKey(key, redisCommand());
             if (hotKey) {
                 hash = loadLRUCache(slot, keyMeta, key);
                 hashLRUCache.putAllForRead(slot, cacheKey, hash);

diff --git a/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HSetCommander.java b/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HSetCommander.java
@@ -120,7 +120,7 @@ protected Reply execute(int slot, Command command) {
             } else {
                 existMapByCache = hashLRUCache.hset(slot, cacheKey, fieldMap);
                 if (existMapByCache == null) {
-                    boolean hotKey = hashLRUCache.isHotKey(key);
+                    boolean hotKey = hashLRUCache.isHotKey(key, redisCommand());
                     if (hotKey) {
                         //
                         type = KvCacheMonitor.Type.kv_store;

diff --git a/...n/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HSetNxCommander.java b/...n/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HSetNxCommander.java
@@ -133,7 +133,7 @@ protected Reply execute(int slot, Command command) {
 
             RedisHash hash = hashLRUCache.getForWrite(slot, cacheKey);
             if (hash == null) {
-                boolean hotKey = hashLRUCache.isHotKey(key);
+                boolean hotKey = hashLRUCache.isHotKey(key, redisCommand());
                 if (hotKey) {
                     //
                     type = KvCacheMonitor.Type.kv_store;

diff --git a/.../java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HStrLenCommander.java b/.../java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HStrLenCommander.java
@@ -108,7 +108,7 @@ protected Reply execute(int slot, Command command) {
                 KvCacheMonitor.localCache(cacheConfig.getNamespace(), redisCommand().strRaw());
                 return IntegerReply.parse(hash.hstrlen(new BytesKey(field)));
             }
-            boolean hotKey = hashLRUCache.isHotKey(key);
+            boolean hotKey = hashLRUCache.isHotKey(key, redisCommand());
             if (hotKey) {
                 hash = loadLRUCache(slot, keyMeta, key);
                 hashLRUCache.putAllForRead(slot, cacheKey, hash);

diff --git a/...in/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HValsCommander.java b/...in/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/hash/HValsCommander.java
@@ -105,7 +105,7 @@ protected Reply execute(int slot, Command command) {
                 KvCacheMonitor.localCache(cacheConfig.getNamespace(), redisCommand().strRaw());
                 return toReply(hash.hgetAll());
             }
-            boolean hotKey = hashLRUCache.isHotKey(key);
+            boolean hotKey = hashLRUCache.isHotKey(key, redisCommand());
             if (hotKey) {
                 hash = loadLRUCache(slot, keyMeta, key);
                 hashLRUCache.putAllForRead(slot, cacheKey, hash);

diff --git a/...main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SAddCommander.java b/...main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SAddCommander.java
@@ -114,7 +114,7 @@ protected Reply execute(int slot, Command command) {
             } else {
                 Set<BytesKey> existsSet = setLRUCache.sadd(slot, cacheKey, memberSet);
                 if (existsSet == null) {
-                    boolean hotKey = setLRUCache.isHotKey(key);
+                    boolean hotKey = setLRUCache.isHotKey(key, redisCommand());
                     if (hotKey) {
                         //
                         type = KvCacheMonitor.Type.kv_store;

diff --git a/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SCardCommander.java b/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SCardCommander.java
@@ -114,7 +114,7 @@ protected Reply execute(int slot, Command command) {
             }
 
             if (encodeVersion == EncodeVersion.version_1) {
-                boolean hotKey = setLRUCache.isHotKey(key);
+                boolean hotKey = setLRUCache.isHotKey(key, redisCommand());
                 if (hotKey) {
                     set = loadLRUCache(slot, keyMeta, key);
                     setLRUCache.putAllForRead(slot, cacheKey, set);

diff --git a/...java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SIsMemberCommander.java b/...java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SIsMemberCommander.java
@@ -108,7 +108,7 @@ protected Reply execute(int slot, Command command) {
                 return IntegerReply.parse(sismeber ? 1 : 0);
             }
 
-            boolean hotKey = setLRUCache.isHotKey(key);
+            boolean hotKey = setLRUCache.isHotKey(key, redisCommand());
 
             if (hotKey) {
                 set = loadLRUCache(slot, keyMeta, key);

diff --git a/...ava/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SMIsMemberCommander.java b/...ava/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SMIsMemberCommander.java
@@ -120,7 +120,7 @@ protected Reply execute(int slot, Command command) {
                 return toReply(smismember, members);
             }
 
-            boolean hotKey = setLRUCache.isHotKey(key);
+            boolean hotKey = setLRUCache.isHotKey(key, redisCommand());
 
             if (hotKey) {
                 set = loadLRUCache(slot, keyMeta, key);

diff --git a/...main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SPopCommander.java b/...main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SPopCommander.java
@@ -99,7 +99,7 @@ protected Reply execute(int slot, Command command) {
             }
 
             if (spop == null) {
-                boolean hotKey = setLRUCache.isHotKey(key);
+                boolean hotKey = setLRUCache.isHotKey(key, redisCommand());
                 if (hotKey) {
                     //
                     type = KvCacheMonitor.Type.kv_store;

diff --git a/...va/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SRandMemberCommander.java b/...va/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SRandMemberCommander.java
@@ -129,7 +129,7 @@ protected Reply execute(int slot, Command command) {
                 return toReply(srandmember, batch);
             }
 
-            boolean hotKey = setLRUCache.isHotKey(key);
+            boolean hotKey = setLRUCache.isHotKey(key, redisCommand());
 
             if (hotKey) {
                 set = loadLRUCache(slot, keyMeta, key);

diff --git a/...main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SRemCommander.java b/...main/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/set/SRemCommander.java
@@ -93,7 +93,7 @@ protected Reply execute(int slot, Command command) {
             }
 
             if (removedMembers == null) {
-                boolean hotKey = setLRUCache.isHotKey(key);
+                boolean hotKey = setLRUCache.isHotKey(key, redisCommand());
                 if (hotKey) {
                     //
                     type = KvCacheMonitor.Type.kv_store;

diff --git a/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZAddCommander.java b/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZAddCommander.java
@@ -119,7 +119,7 @@ protected Reply execute(int slot, Command command) {
             } else {
                 Map<BytesKey, Double> map = zSetLRUCache.zadd(slot, cacheKey, memberMap);
                 if (map == null) {
-                    boolean hotKey = zSetLRUCache.isHotKey(key);
+                    boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
                     if (hotKey) {
                         zSet = loadLRUCache(slot, keyMeta, key);
                         if (zSet != null) {

diff --git a/...n/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZCountCommander.java b/...n/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZCountCommander.java
@@ -144,7 +144,7 @@ protected Reply execute(int slot, Command command) {
                 return IntegerReply.parse(zcount);
             }
 
-            boolean hotKey = zSetLRUCache.isHotKey(key);
+            boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
 
             if (hotKey) {
                 zSet = loadLRUCache(slot, keyMeta, key);

diff --git a/...ava/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZLexCountCommander.java b/...ava/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZLexCountCommander.java
@@ -155,7 +155,7 @@ protected Reply execute(int slot, Command command) {
                 return IntegerReply.parse(zcount);
             }
 
-            boolean hotKey = zSetLRUCache.isHotKey(key);
+            boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
 
             if (hotKey) {
                 zSet = loadLRUCache(slot, keyMeta, key);

diff --git a/.../java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZMScoreCommander.java b/.../java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZMScoreCommander.java
@@ -126,7 +126,7 @@ protected Reply execute(int slot, Command command) {
                 return toReply(zSet.zmscore(members));
             }
 
-            boolean hotKey = zSetLRUCache.isHotKey(key);
+            boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
 
             if (hotKey) {
                 zSet = loadLRUCache(slot, keyMeta, key);

diff --git a/...a/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRangeByLexCommander.java b/...a/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRangeByLexCommander.java
@@ -151,7 +151,7 @@ protected Reply execute(int slot, Command command) {
                 return ZSetTupleUtils.toReply(list, false);
             }
 
-            boolean hotKey = zSetLRUCache.isHotKey(key);
+            boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
 
             if (hotKey) {
                 zSet = loadLRUCache(slot, keyMeta, key);

diff --git a/...com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRangeByScoreCommander.java b/...com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRangeByScoreCommander.java
@@ -147,7 +147,7 @@ protected Reply execute(int slot, Command command) {
                 return ZSetTupleUtils.toReply(list, withScores);
             }
 
-            boolean hotKey = zSetLRUCache.isHotKey(key);
+            boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
 
             if (hotKey) {
                 zSet = loadLRUCache(slot, keyMeta, key);

diff --git a/...n/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRangeCommander.java b/...n/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRangeCommander.java
@@ -133,7 +133,7 @@ protected Reply execute(int slot, Command command) {
                 return ZSetTupleUtils.toReply(list, withScores);
             }
 
-            boolean hotKey = zSetLRUCache.isHotKey(key);
+            boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
 
             if (hotKey) {
                 zSet = loadLRUCache(slot, keyMeta, key);

diff --git a/...in/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRankCommander.java b/...in/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRankCommander.java
@@ -127,7 +127,7 @@ protected Reply execute(int slot, Command command) {
                 return toReply(zrank, withScores);
             }
 
-            boolean hotKey = zSetLRUCache.isHotKey(key);
+            boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
 
             if (hotKey) {
                 zSet = loadLRUCache(slot, keyMeta, key);

diff --git a/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRemCommander.java b/...ain/java/com/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRemCommander.java
@@ -91,7 +91,7 @@ protected Reply execute(int slot, Command command) {
             }
 
             if (removedMembers == null) {
-                boolean hotKey = zSetLRUCache.isHotKey(key);
+                boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
                 if (hotKey) {
                     RedisZSet zSet = loadLRUCache(slot, keyMeta, key);
                     if (zSet != null) {

diff --git a/...om/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRemRangeByLexCommander.java b/...om/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRemRangeByLexCommander.java
@@ -114,7 +114,7 @@ protected Reply execute(int slot, Command command) {
             }
 
             if (removedMembers == null) {
-                boolean hotKey = zSetLRUCache.isHotKey(key);
+                boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
                 if (hotKey) {
                     RedisZSet zSet = loadLRUCache(slot, keyMeta, key);
                     if (zSet != null) {

diff --git a/...m/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRemRangeByRankCommander.java b/...m/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRemRangeByRankCommander.java
@@ -96,7 +96,7 @@ protected Reply execute(int slot, Command command) {
             }
 
             if (removedMap == null) {
-                boolean hotKey = zSetLRUCache.isHotKey(key);
+                boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
                 if (hotKey) {
                     RedisZSet zSet = loadLRUCache(slot, keyMeta, key);
                     if (zSet != null) {

diff --git a/.../netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRemRangeByScoreCommander.java b/.../netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRemRangeByScoreCommander.java
@@ -106,7 +106,7 @@ protected Reply execute(int slot, Command command) {
             }
 
             if (removedMap == null) {
-                boolean hotKey = zSetLRUCache.isHotKey(key);
+                boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
                 if (hotKey) {
                     RedisZSet zSet = loadLRUCache(slot, keyMeta, key);
                     if (zSet != null) {

diff --git a/...om/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRevRangeByLexCommander.java b/...om/netease/nim/camellia/redis/proxy/upstream/kv/command/zset/ZRevRangeByLexCommander.java
@@ -158,7 +158,7 @@ protected Reply execute(int slot, Command command) {
                 return ZSetTupleUtils.toReply(list, false);
             }
 
-            boolean hotKey = zSetLRUCache.isHotKey(key);
+            boolean hotKey = zSetLRUCache.isHotKey(key, redisCommand());
 
             if (hotKey) {
                 zSet = loadLRUCache(slot, keyMeta, key);