<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>4.2.3</version> <!-- 請根據(jù)需要選擇合適的版本 -->
</dependency>

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.Pipeline;

import java.util.List;

public class TestRedisPipeline {
    // Redis服務(wù)器信息
    private static final String REDIS_HOST = "192.168.200.141";
    private static final int REDIS_PORT = 6379;
    private static final String REDIS_PASSWORD = "sl183691";

    public static void main(String[] args) {
        // 配置連接池
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        poolConfig.setMaxTotal(128); // 設(shè)置連接池最大連接數(shù)
        poolConfig.setMaxIdle(16);   // 設(shè)置連接池中的最大空閑連接
        poolConfig.setMinIdle(4);    // 設(shè)置連接池中的最小空閑連接
        poolConfig.setTestOnBorrow(true); // 從池中取出連接時(shí)，是否進(jìn)行有效性檢查
        poolConfig.setTestOnReturn(true); // 在歸還連接時(shí)檢查有效性

        JedisPool jedisPool = new JedisPool(poolConfig, REDIS_HOST, REDIS_PORT, 10000, REDIS_PASSWORD);

        try (Jedis jedis = jedisPool.getResource()) {
            // 創(chuàng)建管道
            Pipeline pipeline = jedis.pipelined();

            // 批量設(shè)置鍵值對
            for (int i = 0; i < 1000; i++) {
                pipeline.set("key" + i, "value" + i);
            }

            // 批量獲取鍵值對
            for (int i = 0; i < 1000; i++) {
                pipeline.get("key" + i);
            }

            // 執(zhí)行管道操作并獲取結(jié)果
            List<Object> results = pipeline.syncAndReturnAll();

            // 處理結(jié)果
            for (Object result : results) {
                System.out.println(result);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 關(guān)閉連接池
            jedisPool.close();
        }
    }
}

// 分批處理1000個(gè)命令
int batchSize = 100;
for (int batch = 0; batch < 10; batch++) {
    Pipeline pipeline = jedis.pipelined();
    for (int i = 0; i < batchSize; i++) {
        int index = batch * batchSize + i;
        pipeline.set("key" + index, "value" + index);
    }
    pipeline.syncAndReturnAll();
}

CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
    Pipeline pipeline = jedis.pipelined();
    for (int i = 0; i < 1000; i++) {
        pipeline.set("key" + i, "value" + i);
    }
    pipeline.syncAndReturnAll();
});

// 繼續(xù)執(zhí)行其他操作
future.join(); // 等待異步操作完成

long startTime = System.currentTimeMillis();
Pipeline pipeline = jedis.pipelined();
for (int i = 0; i < 1000; i++) {
    pipeline.set("key" + i, "value" + i);
}
pipeline.syncAndReturnAll();
long endTime = System.currentTimeMillis();
System.out.println("Pipeline execution time: " + (endTime - startTime) + " ms");