Redis批量執行(如list批量添加)命令工具 —— pipeline管道應用

前言

1. Redis使用的是客戶端-服務器（CS）模型和請求/響應協議的TCP服務器。這意味着一般狀況下一個請求會遵循如下步驟：

   （1）客戶端向服務端發送一個查詢請求，並監聽Socket返回，一般是以阻塞模式，等待服務端響應。
   （2）服務端處理命令，並將結果返回給客戶端。

2. 客戶端和服務端經過網絡進行鏈接。這樣的鏈接可能很是快（在一個迴路網絡中），也可能很是慢（在廣域網上通過多個結點才能互通的兩個主機）。
3. 可是不管是否存在網絡延遲，數據包從客戶端傳輸到服務端，以及客戶端從服務端得到響應都須要花費一些時間。這段時間就稱爲往返時延(Round Trip Time)。
4. 所以當客戶端須要執行一串請求的時候，很容易看出它對性能的影響（例如往同一個隊列中加入大量元素，或者往數據庫中插入大量的鍵）。若是RTT時長爲250毫秒（在基於廣域網的低速鏈接環境下），即便服務器每秒能夠處理10萬個請求，可是實際上咱們依然只能每秒處理最多4個請求。
5. 若是處於一個迴路網絡中，RTT時長則至關短（個人主機ping 127.0.0.1時只須要0.063ms），可是若是你執行一大串寫入請求的時候，仍是會有點長。
6. 若是須要一次執行多個redis命令，以往的方式須要發送屢次命令請求，由redis服務器依次執行，並返回結果。
7. 爲了解決此類問題，設計者設計出了redis管道命令：客戶端能夠向服務器發送多個請求，而沒必要等待回覆，並最終在一個步驟中讀取回復返回給客戶端，從而大大增長了協議性能。

pipeline在php中的應用

1. 管道的開啓方式最主要是一條命令：$redis->pipeline()

2. 批量給一個list類型的key添加10w條數據，實例以下：

   <?php
      $redis = new Redis();
      $redis->connect('127.0.0.1', 6379);
      $redis->auth('******');
      $redis->select(0);
      $redis->pipeline();//開啓管道
      
      //假設變量$data數組有10w條數據，批量添加到list類型中
      $data = array(1,2,3,...,100000);
      $key = 'list1';
      foreach($data as $value){
          $redis->rpush($key,$value);
      }