为什么需要 pipeline ?

Redis 的工作过程是基于 请求/响应 模式的。正常情况下，客户端发送一个命令，等待 Redis 应答；Redis 接收到命令，处理后应答。请求发出到响应的时间叫做往返时间，即 RTT（Round Time Trip）。在这种情况下，如果需要执行大量的命令，就需要等待上一条命令应答后再执行。这中间不仅仅多了许多次 RTT，而且还频繁的调用系统 IO，发送网络请求。为了提升效率，pipeline 出现了，它允许客户端可以一次发送多条命令，而不等待上一条命令执行的结果。

实现思路

客户端首先将执行的命令写入到缓冲区中，最后再一次性发送 Redis。但是有一种情况就是，缓冲区的大小是有限制的：如果命令数据太大，可能会有多次发送的过程，但是仍不会处理 Redis 的应答。

实现原理

要支持 pipeline，既要服务端的支持，也要客户端支持。对于服务端来说，所需要的是能够处理一个客户端通过同一个 TCP 连接发来的多个命令。可以理解为，这里将多个命令切分，和处理单个命令一样。对于客户端，则是要将多个命令缓存起来，缓冲区满了就发送，然后再写缓冲，最后才处理 Redis 的应答。

参考资料

https://redis.io/topics/pipelining

在php中使用Redis pipeline

<?php
 //实例化redis
$redis = new Redis();
//连接
$redis->connect('127.0.0.1', 6379);
$redis->pipeline();//开启管道
if(!$redis){
    throw new Exception('redis连接失败！',1);
}
$key = "pipeline_test";
$len = 200000;
$succ = 0;
for($i=0;$i<$len;$i++){
    $res = $redis->hset($key,"test_".$i,1);
    if($res){
        $succ ++;
    }
}
$redis->exec();

总结

Redis pipeline 的特性以及使用时需要注意的地方
pipeline 减少了 RTT，也减少了IO调用次数（IO 调用涉及到用户态到内核态之间的切换）
如果某一次需要执行大量的命令，不能放到一个 pipeline 中执行。数据量过多，网络传输延迟会增加，且会消耗 Redis 大量的内存。应该将大量的命令切分为多个 pipeline 分别执行。