運行結果1

在輸入了正確的 ApsaraDB for Redis 實例訪問地址和密碼之後，運行以上 Java 程序，輸出結果如下。從中可以看出使用 pipeline 的性能要快的多。

不用Pipeline > value為:5000 > 操作用時：5844ms
使用Pipeline > value為:5000 > 操作用時：78ms

代碼示例2

在 Jedis 中使用管道（pipeline）時，對於響應數據（response）的處理有兩種方式，請參考以下代碼示例。

package pipeline.kvstore.aliyun.com;
import java.util.List;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;
import redis.clients.jedis.Response;
    public class PipelineClientTest {
        static final String host = "xxxxxxxx.m.cnhza.kvstore.aliyuncs.com";
        static final int port = 6379;
        static final String password = "password";
        public static void main(String[] args) {
            Jedis jedis = new Jedis(host, port);
                // ApsaraDB for Redis的實例ID及密碼
                String authString = jedis.auth(password);// password
                if (!authString.equals("OK")) {
                    System.err.println("AUTH Failed: " + authString);
                    jedis.close();
                    return;
                }
                String key = "KVStore-Test1";
                jedis.del(key);//初始化
                // -------- 方法1
                Pipeline p1 = jedis.pipelined();
                System.out.println("-----方法1-----");
                for (int i = 0; i < 5; i++) {
                    p1.incr(key);
                    System.out.println("Pipeline發送請求");
                }
                // 發送請求完成，開始接收響應
                System.out.println("發送請求完成，開始接收響應");
                List<Object> responses = p1.syncAndReturnAll();
                if (responses == null || responses.isEmpty()) {
                    jedis.close();
                    throw new RuntimeException("Pipeline error: 沒有接收到響應");
                }
                for (Object resp : responses) {
                    System.out.println("Pipeline接收響應Response: " + resp.toString());
                }
                System.out.println();
                //-------- 方法2
                System.out.println("-----方法2-----");
                jedis.del(key);//初始化
                Pipeline p2 = jedis.pipelined();  
                //需要先聲明Response
                Response<Long> r1 = p2.incr(key); 
                System.out.println("Pipeline發送請求");
                Response<Long> r2 = p2.incr(key);
                System.out.println("Pipeline發送請求");
                Response<Long> r3 = p2.incr(key);
                System.out.println("Pipeline發送請求");
                Response<Long> r4 = p2.incr(key);  
                System.out.println("Pipeline發送請求");
                Response<Long> r5 = p2.incr(key);
                System.out.println("Pipeline發送請求");
                try{  
                    r1.get();  //此時還未開始接收響應，所以此操作會出錯
                }catch(Exception e){  
                    System.out.println(" <<< Pipeline error：還未開始接收響應  >>> ");  
                }  
             // 發送請求完成，開始接收響應
                System.out.println("發送請求完成，開始接收響應");
                p2.sync();  
                System.out.println("Pipeline接收響應Response: " + r1.get());  
                System.out.println("Pipeline接收響應Response: " + r2.get());  
                System.out.println("Pipeline接收響應Response: " + r3.get());
                System.out.println("Pipeline接收響應Response: " + r4.get());
                System.out.println("Pipeline接收響應Response: " + r5.get());
                jedis.close();
            }
    }

-----方法1-----
Pipeline發送請求
Pipeline發送請求
Pipeline發送請求
Pipeline發送請求
Pipeline發送請求
發送請求完成，開始接收響應
Pipeline接收響應Response: 1
Pipeline接收響應Response: 2
Pipeline接收響應Response: 3
Pipeline接收響應Response: 4
Pipeline接收響應Response: 5
-----方法2-----
Pipeline發送請求
Pipeline發送請求
Pipeline發送請求
Pipeline發送請求
Pipeline發送請求
 <<< Pipeline error：還未開始接收響應  >>> 
發送請求完成，開始接收響應
Pipeline接收響應Response: 1
Pipeline接收響應Response: 2
Pipeline接收響應Response: 3
Pipeline接收響應Response: 4
Pipeline接收響應Response: 5