普通模式

我们先来看下普通模式下，一条 Redis 命令的简要执行过程：

客户端发送一条命令给 redis-server，阻塞等待 redis-server 应答
redis-server 接收到命令，执行命令
redis-server 将结果返回给客户端

下面我们来简要了解下一个完整请求的交互过程。

客户端调用 write() 将消息写入操作系统为 socket 分配的 send buffer 中
操作系统将 send buffer 中的内容发送到网卡，网卡通过网关路由把内容发送到服务器网卡
服务器网卡将接受到的消息写入操作系统为 socket 分配的 recv buffer
服务器进程调用 read() 从 recv buffer 中读取消息进行处理
处理完成之后，服务器调用 write() 将响应内容发送的 send buffer 中
服务器将 send buffer 中的内容通过网卡，发送到客户端
客户端操作系统将网卡中的内容放入 recv buffer 中
客户端进程调用 read() 从 recv buffer 中读取消息

普通模式的问题

我们来想一下，这种情况下可能导致什么问题。
如果同时执行大量的命令，那对于每一个命令，都要按上面的流程走一次，当前的命令需要等待上一条命令执行应答完毕之后，才会执行。这个过程中会有多次的 RTT ，也还会伴随着很多的 IO 开销，发送网络请求等。每条命令的发送和接收的过程都会占用两边的网络传输。
简单的来说，每个命令的执行时间 = 客户端发送耗时 + 服务器处理耗时 + 服务器返回耗时 + 一个网络来回耗时。
在这里，一个网络来回耗时（RTT）是不好控制的，也是不稳定的。它的影响因素很多，比如客户端到服务器的网络线路是否拥堵，经过了多少跳。还有就是 IO 系统调用也是耗时的，一个 read 系统调用，需要从用户态，切换到内核态。上文我们讲述一个命令的请求过程时多次降到 read 和 write 系统调用。
可以说一个命令的执行时间，很大程度上受到它们的限制。

pipeline 模式

有没有什么方法来解决这种问题呢。
第一种方法，就是利用多线程机制，并行执行命令。
第二种方法，调用批量命令，例如 mget等，一次操作多个键。
很多时候我们要执行的命令并不是一样的命令，而是一组命令，这个时候就无法使用类似 mget这样的批量命令了。那还有其他的方法吗？
回想一下，我们初学编程的时候，老手都会告诉我们，不要在循环里面做查询。我有一个 books 列表数据，要根据 book_id 查询它们的 price，如果我们循环 books 列表，在每次循环里面取查询单个 book_id 的 price，那性能肯定是不理想的。一般我们的优化方式是将多个 book_id 取出来，一次性去查多个 book_id 的 price，这样性能就有明显的提示。即将多次小命令中的耗时操作合并到一次，从而减少总的执行时间。
类似的，Redis pipeline 出现了，一般称之为管道。它允许客户端一次可以发送多条命令，而不用像普通模式那样每次执行一个小命令都要等待前一个小命令执行完，服务器在接收到一堆命令后，会依次执行，然后把结果打包，再一次性返回给客户端。
这样可以避免频繁的命令发送，减少 RTT，减少 IO 调用次数。前面已经介绍了，IO 调用会涉及到用户态和内核态之间的切换，在高性能的一些系统中，我们都是尽可能的减少 IO 调用。
简要流程如下图：

pipeline 的优点
- 减少 RTT
- 减少 IO 调用次数
基本使用

Pipeline pipeline =jedis.pipelined();

for(int i = 0; i < 100; i++){
pipeline.rpush("rediskey", i + "");
}

pipeline.sync()

总结一下 pipeline 的核心，就是客户端将一组 Redis 命令进行组装，通过一次 RTT 发送给服务器，同时服务器再将这组命令的执行结果按照顺序一次返回给客户端。

pipeline 注意问题

虽然 pipeline 在某些情况下会带来不小的性能提升，但是，我们在使用的时候也需要注意。

pipeline 中的命令数量不宜过多。

客户端会先将多个命令写入内存 buffer 中（打包），命令过多，如果是超过了客户端设置的 buffer 上限，被客户端的处理策略处理了（不同的客户端实现可能会有差异，比如 jedis pipeline ，限制每次最大的发送字节数为 8192，缓冲区满了就发送，然后再写缓冲，最后才处理 Redis 服务器的应答）。如果客户端没有设置 buffer 上限或不支持上限设置，则会占用更多的客户端机器内存，造成客户端瘫痪。官方推荐是每次 10k 个命令。
建议做好规范，遇到一次包含大量命令的 pipeline，可以拆分成多个稍小的 pipeline 来完成。