博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Redis管道(pipeline)
阅读量:7099 次
发布时间:2019-06-28

本文共 1872 字,大约阅读时间需要 6 分钟。

hot3.png

redis是一个cs模式的tcp server,使用和http类似的请求响应协议。一个client可以通过一个socket连接发起多个请求命令。每个请求命令发出后client通常会阻塞并等待redis服务处理,redis处理完后请求命令后会将结果通过响应报文返回给client。基本的通信过程如下:

Client: INCR XServer: 1Client: INCR XServer: 2Client: INCR XServer: 3Client: INCR XServer: 4

基本上四个命令需要8tcp报文才能完成。由于通信会有网络延迟,假如从clientserver之间的包传输时间需要0.125秒。那么上面的四个命令8个报文至少会需要1秒才能完成。这样即使redis每秒能处理100个命令,而我们的client也只能一秒钟发出四个命令。这显示没有充分利用 redis的处理能力。除了可以利用mget,mset 之类的单条命令处理多个key的命令外我们还可以利用pipeline的方式从client打包多条命令一起发出,不需要等待单条命令的响应返回,而redis服务端会处理完多条命令后会将多条命令的处理结果打包到一起返回给客户端。通信过程如下:

Client: INCR XClient: INCR XClient: INCR XClient: INCR XServer: 1Server: 2Server: 3Server: 4

假设不会因为tcp报文过长而被拆分。可能两个tcp报文就能完成四条命令,client可以将四个incr命令放到一个tcp报文一起发送,server则可以将四条命令的处理结果放到一个tcp报文返回。通过pipeline方式当有大批量的操作时候。我们可以节省很多原来浪费在网络延迟的时间。需要注意到是用 pipeline方式打包命令发送,redis必须在处理完所有命令前先缓存起所有命令的处理结果。打包的命令越多,缓存消耗内存也越多。所以并是不是打包的命令越多越好。具体多少合适需要根据具体情况测试。下面是个jedis客户端使用pipeline的测试:

package com.jd.redis.client; import redis.clients.jedis.Jedis;import redis.clients.jedis.Pipeline; publicclass PipelineTest {     /**     * @param args     */    publicstaticvoid main(String[] args) {               int count = 1000;               long start = System.currentTimeMillis();        withoutPipeline(count);        long end = System.currentTimeMillis();        System.out.println("withoutPipeline: " + (end-start));               start = System.currentTimeMillis();        usePipeline(count);        end = System.currentTimeMillis();        System.out.println("usePipeline: " + (end-start));           }     privatestaticvoid withoutPipeline(int count){        Jedis jr = null;        try {            jr = new Jedis("10.10.224.44", 6379);            for(int i =0; i

输出:

withoutPipeline: 11341usePipeline: 344

测试结果还是很明显有较大的差距,所以多次操作用pipeline还是有明显的优势。我用的是Win7中的Jedis Java客户端程序连接局域网的Linux虚拟机上的Redis Server

转载于:https://my.oschina.net/ydsakyclguozi/blog/464883

你可能感兴趣的文章
快速排序算法真的正确吗?-试试120,100,105,103,118 从大到小排列
查看>>
Linux基础操作
查看>>
使用标准输入框 --- Qt
查看>>
PDF怎么翻译
查看>>
怎样加密数据以及怎样恢复加密数据
查看>>
fdisk和 parted 磁盘分区 以及 vimrc
查看>>
Collection
查看>>
抖音云控专业营销实战引流,一键暴涨百万精准粉原理!
查看>>
golang学习的点点滴滴:channel缓冲区
查看>>
springboot 之缓存注解
查看>>
apt-get install 的用法
查看>>
如何写高效率的SQL
查看>>
利用灰名单阻止垃圾邮件
查看>>
Cisco 路由器加电/启动顺序
查看>>
HTTP X-Forwarded-For 头部字段的应用
查看>>
【翻译】安卓 opengl ES教程之六——纹理
查看>>
我的友情链接
查看>>
ncat使用总结
查看>>
expect 批量修改密码(无密码ssh登入就不要用这个了)
查看>>
hadoop 添加删除datanode及tasktracker
查看>>