Redis pipeline(12)

Stella981
• 阅读 717

常规的连接客户端一般有3种请求方式:

  1. Client
  2. Pipeline
  3. 事务

三中模式的区别

Client模式:就是客户端发送一个命令,阻塞等待服务端执行,然后读取返回结果。

Pipeline模式:是一次性发送多个命令,最后一次取回所有的返回结果,这种模式通过减少网络的往返时间和io读写次数,大幅度提高通信性能。

事务模式:Transaction模式即开启Redis的事务管理,事务模式开启后,所有的命令(除了exec,discard,multi和watch)到达服务端以后不会立即执行,会进入一个等待队列。

什么时候Pipeline?

Redis客户端与Redis服务器之间使用TCP协议进行连接,一个客户端可以通过一个socket连接发起多个请求命令。每个请求命令发出后client通常会阻塞并等待redis服务器处理,redis处理完请求命令后会将结果通过响应报文返回给client,因此当执行多条命令的时候都需要等待上一条命令执行完毕才能执行。执行过程如图:

Redis pipeline(12)

由于通信会有网络延迟,假如client和server之间的包传输时间需要10毫秒,一次交互就是20毫秒(RTT:RoundTripTime)。这样的话,client1秒钟也只能也只能发送50个命令。这显然没有充分利用Redis的处理能力。另外一个,Redis服务端执行I/O的次数过多。

Pipeline管道

那我们能不能像数据库的batch操作一样,把一组命令组装在一起发送给Redis服务端执行,然后一次性获得返回结果呢?这个就是Pipeline的作用。Pipeline通过一个队列把所有的命令缓存起来,然后把多个命令在一次连接中发送给服务器。

Redis pipeline(12)

要实现Pipeline,既要服务端的支持,也要客户端的支持。对于服务端来说,需要能够处理客户端通过一个TCP连接发来的多个命令,并且逐个地执行命令一起返回。对于客户端来说,要把多个命令缓存起来,达到一定的条件就发送出去,最后才处理Redis的应答(这里也要注意对客户端内存的消耗)。

在Jedis客户端中jedis-pipeline的client-buffer限制:8192bytes,客户端堆积的命令超过8192bytes时,会发送给服务端。

源码:redis.clients.util.RedisOutputStream.java

public RedisOutputStream(final OutputStream out){
  this(out,8192);
}

pipeline对于命令条数没有限制,但是命令可能会受限于TCP包大小。

如果Jedis发送了一组命令,而发送请求还没有结束,Redis响应的结果会放在接收缓冲区。如果接收缓冲区满了,jedis会通知rediswin=0,此时redis不会再发送结果给jedis端,转而把响应结果保存在Redis服务端的输出缓冲区中。

输出缓冲区的配置:redis.conf

client-output-buffer-limit <class> <hardlimit> <softlimit> <softseconds>

client-output-buffer-limit normal 0 0 0
client-output-buffer-limit replica 256mb 64mb 60
client-output-buffer-limit pubsub 32mb 8mb 60

配置

作用

class

客户端类型,分为三种。a)normal:普通客户端;b)slave:slave客户端,用于复制;c)pubsub:发布订阅客户端

hardlimit

如果客户端使用的输出缓冲区大于,客户端会被立即关闭,0代表不限制

soft limit \ soft seconds

如果客户端使用的输出缓冲区超过了并且持续了秒,客户端会被立即关闭

每个客户端使用的输出缓冲区的大小可以用clientlist命令查看

Pipeline适用于什么场景呢?

如果某些操作需要马上得到Redis操作是否成功的结果,这种场景就不适合。

有些场景,例如批量写入数据,对于结果的实时性和成功性要求不高,就可以用Pipeline。

点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
待兔 待兔
5个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
Jacquelyn38 Jacquelyn38
3年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
Stella981 Stella981
3年前
KVM调整cpu和内存
一.修改kvm虚拟机的配置1、virsheditcentos7找到“memory”和“vcpu”标签,将<namecentos7</name<uuid2220a6d1a36a4fbb8523e078b3dfe795</uuid
Easter79 Easter79
3年前
Twitter的分布式自增ID算法snowflake (Java版)
概述分布式系统中,有一些需要使用全局唯一ID的场景,这种时候为了防止ID冲突可以使用36位的UUID,但是UUID有一些缺点,首先他相对比较长,另外UUID一般是无序的。有些时候我们希望能使用一种简单一些的ID,并且希望ID能够按照时间有序生成。而twitter的snowflake解决了这种需求,最初Twitter把存储系统从MySQL迁移
Wesley13 Wesley13
3年前
00:Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。
Wesley13 Wesley13
3年前
00_设计模式之语言选择
设计模式之语言选择设计模式简介背景设计模式是一套被反复使用的、多数人知晓的、经过分类编目的、代码设计经验的总结。设计模式(Designpattern)代表了最佳的实践,通常被有经验的面向对象的软件开发人员所采用。设计模式是软件开发人员在软件开发过程中面临的
Wesley13 Wesley13
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
Python进阶者 Python进阶者
11个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这