设为首页 收藏本站

运维网

查看: 195|回复: 0

[经验分享] 五 redis学习笔记之pipeline

[复制链接]

尚未签到

发表于 6 天前 | 显示全部楼层 |阅读模式
  redis是一个cs模式的tcp   server,使用和http类似的请求响应协议。一个client可以通过一个socket连接发起多个请求命令。每个请求命令发出后client通常  会阻塞并等待redis服务处理,redis处理完后请求命令后会将结果通过响应报文返回给client。基本的通信过程如下
  Client: INCR X
  Server: 1
  Client: INCR X
  Server: 2
  Client: INCR X
  Server: 3
  Client: INCR X
  Server: 4
  基   本上四个命令需要8个tcp报文才能完成。由于通信会有网络延迟,假如从client和server之间的包传输时间需要0.125秒。那么上面的四个命  令8个报文至少会需要1秒才能完成。这样即使redis每秒能处理100个命令,而我们的client也只能一秒钟发出四个命令。这显示没有充分利用  redis的处理能力。除了可以利用mget,mset 之类的单条命令处理多个key的命令外
  我们还可以利用pipeline的方式从client打包多条命令一起发出,不需要等待单条命令的响应返回,而redis服务端会处理完多条命令后会将多条命令的处理结果打包到一起返回给客户端。通信过程如下
  Client: INCR X
  Client: INCR X
  Client: INCR X
  Client: INCR X
  Server: 1
  Server: 2
  Server: 3
  Server: 4
  假  设不会因为tcp   报文过长而被拆分。可能两个tcp报文就能完成四条命令,client可以将四个incr命令放到一个tcp报文一起发送,server则可以将四条命令  的处理结果放到一个tcp报文返回。通过pipeline方式当有大批量的操作时候。我们可以节省很多原来浪费在网络延迟的时间。需要注意到是用  pipeline方式打包命令发送,redis必须在处理完所有命令前先缓存起所有命令的处理结果。打包的命令越多,缓存消耗内存也越多。所以并是不是打  包的命令越多越好。具体多少合适需要根据具体情况测试。下面是个jredis客户端使用pipeline的测试
  package jredisStudy;
  import org.jredis.JRedis;
  import org.jredis.connector.ConnectionSpec;
  import org.jredis.ri.alphazero.JRedisClient;
  import org.jredis.ri.alphazero.JRedisPipelineService;
  import org.jredis.ri.alphazero.connection.DefaultConnectionSpec;

  public>  public static void main(String[] args) {
  long start = System.currentTimeMillis();
  usePipeline();
  long end = System.currentTimeMillis();
  System.out.println(end-start);
  start =  System.currentTimeMillis();
  withoutPipeline();
  end  = System.currentTimeMillis();
  System.out.println(end-start);
  }
  private static void withoutPipeline()
  {
  try {
  JRedis  jredis = new JRedisClient("192.168.56.55",6379);
  for(int i =0 ; i < 100000 ; i++)
  {
  jredis.incr(&quot;test2&quot;);
  }
  jredis.quit();
  } catch (Exception e) {
  }
  }
  private static void usePipeline() {
  try {
  ConnectionSpec spec = DefaultConnectionSpec.newSpec(&quot;192.168.56.55&quot;, 6379, 0, null);
  JRedis jredis = new JRedisPipelineService(spec);
  for(int i =0 ; i < 100000 ; i++)
  {
  jredis.incr(&quot;test2&quot;);
  }
  jredis.quit();
  } catch (Exception e) {
  }
  }
  }
  输出
  103408 //使用了pipeline
  104598 //没有使用
  测试结果不是很明显,这应该是跟我的测试环境有关。我是在自己win连接虚拟机的linux。网络延迟比较小。所以pipeline
  优势不明显。如果网络延迟小的话,最好还是不用pipeline。除了增加复杂外,带来的性能提升不明显。


运维网声明 1、欢迎大家加入本站运维交流群:群①:263444886群②:197202523群③:485755530群④:201730672群⑤:202807635运维网交流群⑥:281548029
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、其他单位或个人使用、转载或引用本文时必须注明原文的出处
4、如本帖侵犯到任何版权问题,请立即告知本站,本站将及时予与删除并致以最深的歉意
5、运维网 - 服务您的运维操作管理专家!
6、联系人Email:admin@yunvn.com 网址:www.iyunv.com

点击关注更多内容
您需要登录后才可以回帖 登录 | 立即注册  

本版积分规则  允许回帖邮件提醒楼主

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服 E-mail:kefu@yunvn.com

本站由青云提供云计算服务

运维网--中国最专业的运维工程师交流社区

京ICP备14039699号-1 Copyright © 2012-2018

使用手机软件扫描微信二维码

关注我们可获取更多热点资讯

Good good study day day up !


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


独家合作伙伴: 青云cloud

快速回复 返回顶部 返回列表