Redis--pipeline(流水线)

矫情吗；* 2023-06-25 06:02 11阅读 0赞

## 什么是流水线 ##

首先我们看一下Redis1次网络命令通讯模型  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bqc2RzZw_size_16_color_FFFFFF_t_70]

如果要执行多条命令，要执行多次操作，批量网络命令通讯模型如下  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bqc2RzZw_size_16_color_FFFFFF_t_70 1]  
我们知道Redis的命令执行时间是特别快的，但是网络相反会有很大的不同，可能是内网之间通讯，也有可能是外网之间通讯，也甚至可能是跨机房，跨地区访问都有可能。

**那么什么是流水线，流水线是将一批命令批量打包，然后在服务端进行批量计算，然后将批量结果返回给客户端，如下图所示，这样就会减少网络通讯时间**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bqc2RzZw_size_16_color_FFFFFF_t_70 2]  
**因此pipeline其实要解决的是减少n次操作的网络连接时间**

## 使用客户端实现流水线 ##

举一个没有使用pipeline时的批量应用场景

Jedis jedis = new Jedis("127.0.0.1", 6379);
    for (int i = 0; i < 10000; i++) {
    	jedis.hset("hashkey:" + i, "field" + i, "value" + i);
    }

使用pipeline,减少多次IO往返的时间缩减为一次

Jedis jedis = new Jedis("127.0.0.1", 6379);
    for (int i = 0; i < 100; i++) {
    	Pipeline pipeline = new Pipeline();
        for (int j = i * 100; j < (i + 1) * 100; j++) {
    		redisUtil.hset("hashkey:" + j, "field" + j, "value" + j);
    	}
    	pipeline.syncAndReturnAll();
    }

## 使用建议 ##

1.  注意每次pipeline携带数据量
2.  pipeline每次只能作用在一个Redis节点上

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bqc2RzZw_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191226122507847.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bqc2RzZw==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bqc2RzZw_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191226122611780.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bqc2RzZw==,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bqc2RzZw_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20191226133852567.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Bqc2RzZw==,size_16,color_FFFFFF,t_70