redis-cli -h <host> -p <port> --bigkeys -i 0.01

rdb --command bigkeys /path/to/dump.rdb
# 或者生成 JSON 格式報(bào)告進(jìn)行更詳細(xì)分析
rdb -c json /path/to/dump.rdb > dump.json

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>5.1.0</version> 
</dependency>

import redis.clients.jedis.Jedis;
import redis.clients.jedis.params.ScanParams;
import redis.clients.jedis.resps.ScanResult;
import java.util.Set;
public class RedisBigKeyScanner {
    private static final String REDIS_HOST = "localhost";
    private static final int REDIS_PORT = 6379;
    private static final String REDIS_PASSWORD = null; // 如果有密碼則填寫
    // 定義 BigKey 的閾值
    // 字符串 10MB
    private static final long BIG_STRING_THRESHOLD_BYTES = 10 * 1024 * 1024; 
    // 集合類型 10萬元素
    private static final long BIG_COLLECTION_THRESHOLD_ELEMENTS = 100000;  
    public static void main(String[] args) {
        // 使用 try-with-resources 確保 Jedis 連接被正確關(guān)閉
        try (Jedis jedis = new Jedis(REDIS_HOST, REDIS_PORT)) {
            // 如果 Redis 服務(wù)器有密碼，進(jìn)行認(rèn)證
            if (REDIS_PASSWORD != null && !REDIS_PASSWORD.isEmpty()) {
                jedis.auth(REDIS_PASSWORD);
            }
            System.out.println("Scanning for BigKeys...");
            // 初始化 SCAN 命令的游標(biāo)，從頭開始掃描
            String cursor = ScanParams.SCAN_POINTER_START;
            // 設(shè)置每次 SCAN 命令返回的 Key 數(shù)量
            ScanParams scanParams = new ScanParams().count(1000);
            // 循環(huán)執(zhí)行 SCAN 命令，直到游標(biāo)回到起點(diǎn)（表示所有 Key 都已遍歷）
            do {
                ScanResult<String> scanResult = jedis.scan(cursor, scanParams);
                // 更新游標(biāo)
                cursor = scanResult.getCursor();
                // 獲取當(dāng)前批次掃描到的 Key 集合
                Set<String> keys = scanResult.getResult();
                // 遍歷當(dāng)前批次獲取到的所有 Key
                for (String key : keys) {
                    String keyType = jedis.type(key);
                    // 根據(jù) Key 類型，使用不同的命令來判斷是否是 BigKey
                    switch (keyType) {
                        case "string":
                            // 獲取字符串的長度（字節(jié)數(shù)）
                            long stringSize = jedis.strlen(key);
                            if (stringSize > BIG_STRING_THRESHOLD_BYTES) {
                                System.out.printf("  [BIG KEY] String: %s (Size: %.2f MB)%n", key, (double) stringSize / (1024 * 1024));
                            }
                            break;
                        case "list":
                            // 獲取列表的元素?cái)?shù)量
                            long listLength = jedis.llen(key);
                            if (listLength > BIG_COLLECTION_THRESHOLD_ELEMENTS) {
                                System.out.printf("  [BIG KEY] List: %s (Elements: %d)%n", key, listLength);
                            }
                            break;
                        case "hash":
                            // 獲取哈希表的字段數(shù)量
                            long hashFields = jedis.hlen(key);
                            if (hashFields > BIG_COLLECTION_THRESHOLD_ELEMENTS) {
                                System.out.printf("  [BIG KEY] Hash: %s (Fields: %d)%n", key, hashFields);
                            }
                            break;
                        case "set":
                            // 獲取集合的成員數(shù)量
                            long setMembers = jedis.scard(key);
                            if (setMembers > BIG_COLLECTION_THRESHOLD_ELEMENTS) {
                                System.out.printf("  [BIG KEY] Set: %s (Members: %d)%n", key, setMembers);
                            }
                            break;
                        case "zset":
                            // 獲取有序集合的成員數(shù)量
                            long zsetMembers = jedis.zcard(key);
                            if (zsetMembers > BIG_COLLECTION_THRESHOLD_ELEMENTS) {
                                System.out.printf("  [BIG KEY] ZSet: %s (Members: %d)%n", key, zsetMembers);
                            }
                            break;
                        // 可以根據(jù)需要添加其他 Redis 數(shù)據(jù)類型的判斷或跳過
                        default:
                            break;
                    }
                }
            // 當(dāng)游標(biāo)回到起始點(diǎn) "0" 時(shí)，表示遍歷完成
            } while (!cursor.equals(ScanParams.SCAN_POINTER_START));
            System.out.println("BigKey scan complete.");
        } catch (Exception e) {
            System.err.println("Error connecting to Redis or during scan: " + e.getMessage());
            e.printStackTrace();
        }
    }
}