Redis KEYS查询大批量数据替代方案

/**
 * scan命令测试
 * @author senfel
 * @date 2024/12/26 11:34
 * @return void
 */
@Test
public void scan() {
    try (Jedis jedis = new Jedis("localhost", 6379)) {
        String cursor = "0";
        ScanParams scanParams = new ScanParams().match("sys_dict:*").count(100);
        do {
            ScanResult<String> scanResult = jedis.scan(cursor, scanParams);
            for (String key : scanResult.getResult()) {
                System.out.println("Found key: " + key);
            }
            cursor = scanResult.getCursor();
        } while (!cursor.equals("0"));
    }
}

/**
 * sortSet
 * @author senfel
 * @date 2024/12/26 11:51
 * @return void
 */
@Test
public void sortSet() {
    try (Jedis jedis = new Jedis("localhost", 6379)) {
        // 添加键到有序集合
        for (int i = 0; i < 100; i++) {
            jedis.zadd("sorted_keys", System.currentTimeMillis(), "senfel"+i);
        }
        // 获取前 10 个键
        Set<String> keys = jedis.zrange("sorted_keys", 0, 9);
        for (String key : keys) {
            System.out.println("Key from sorted set: " + key);
        }
    }
}

/**
 * useHash
 * @author senfel
 * @date 2024/12/26 11:55
 * @return void
 */
@Test
public void useHash() {
    try (Jedis jedis = new Jedis("localhost", 6379)) {
        for (int i = 0; i < 100; i++) {
            // 添加键到哈希表
            jedis.hset("user_data", "name"+i, "senfel"+i);
        }
        // 获取所有键值对
        Map<String, String> userData = jedis.hgetAll("user_data");
        for (Map.Entry<String, String> entry : userData.entrySet()) {
            System.out.println("User data: " + entry.getKey() + " -> " + entry.getValue());
        }
    }
}

<dependency>
    <groupId>com.redislabs</groupId>
    <artifactId>jredisearch</artifactId>
    <version>2.0.0</version>
</dependency>

/**
 * useRediSearch 未安装RediSearch未测试
 * @author senfel
 * @date 2024/12/26 12:26 
 * @return void
 */
@Test
public void useRediSearch() {
    Client client = Client.create("localhost", 6379).connect();
    // 创建索引并添加文档
    client.ftCreate("idx", Schema.newBuilder()
            .addField(new TextField("title"))
            .addField(new TextField("content"))
            .build());
    client.ftAdd("idx", "doc1", 1.0, Document.newDocument()
            .addField("title", "Redis Search")
            .addField("content", "Learn how to use Redis Search"));
    // 查询文档
    SearchResult result = client.ftSearch("idx", new Query("Redis"));
    for (Document doc : result.documents()) {
        System.out.println("Found document: " + doc.getId());
    }
    client.close();
}