java scan获取redis所有key

在 Java 中通过 Redis SCAN 命令可以获取所有的 key，SCAN 命令可以配合游标（cursor）进行分批次获取，以避免一次性获取过多的 key 导致性能问题。以下是使用 Jedis 和 Lettuce 两个 Redis 客户端库中的方法实现的示例代码：

使用 Jedis 客户端库：

// 创建 Jedis 实例
Jedis jedis = new Jedis("localhost", 6379);

// 初始化游标
String cursor = ScanParams.SCAN_POINTER_START;

// 创建 ScanParams 实例
ScanParams params = new ScanParams().count(1000);

// 循环扫描所有 key
while (true) {
    // 执行 SCAN 命令
    ScanResult<String> result = jedis.scan(cursor, params);

    // 获取当前批次的游标和 key 列表
    cursor = result.getStringCursor();
    List<String> keys = result.getResult();

    // 对 key 列表进行处理
    for (String key : keys) {
        System.out.println(key);
    }

    // 如果游标为 0，则说明已经扫描完成
    if (cursor.equals(ScanParams.SCAN_POINTER_START)) {
        break;
    }
}

// 关闭 Jedis 连接
jedis.close();

使用 Lettuce 客户端库：

// 创建 RedisClient 实例
RedisClient client = RedisClient.create("redis://localhost");

// 创建 RedisConnection 实例
RedisConnection<String, String> connection = client.connect();

// 初始化游标
String cursor = ScanCursor.INITIAL.getValue();

// 创建 ScanArgs 实例
ScanArgs args = ScanArgs.Builder.limit(1000);

// 循环扫描所有 key
while (true) {
    // 执行 SCAN 命令
    RedisAdvancedClusterAsyncCommands<String, String> asyncCommands = connection.async();
    RedisFuture<ScanResult<String>> future = asyncCommands.scan(cursor, args);
    ScanResult<String> result = future.get();

    // 获取当前批次的游标和 key 列表
    cursor = result.getCursor();
    List<String> keys = result.getResult();

    // 对 key 列表进行处理
    for (String key : keys) {
        System.out.println(key);
    }

    // 如果游标为 0，则说明已经扫描完成
    if (cursor.equals(ScanCursor.INITIAL.getValue())) {
        break;
    }
}

// 关闭 RedisConnection 连接
connection.close();

// 关闭 RedisClient 连接
client.shutdown();

需要注意的是，SCAN 命令会消耗一定的性能，因此需要根据实际情况来调整游标的大小和扫描的频率。同时，SCAN 命令是一个近似算法，可能会漏扫或者重复扫描一些 key，因此在实际使用中需要进行进一步的判断和处理。