redis学习笔记之pipeline

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 class PipeLineTest {
    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("test2");
                }
               jredis.quit();
        } catch (Exception e) {
        }
    }

    private static void usePipeline() {
        try {
            ConnectionSpec spec =DefaultConnectionSpec.newSpec("192.168.56.55", 6379, 0, null);
            JRedis jredis = newJRedisPipelineService(spec);
            for(int i =0 ; i <100000 ; i++)
            {
               jredis.incr("test2");
            }
            jredis.quit();
        } catch (Exception e) {
        }
    }
}
输出
103408 //使用了pipeline
104598 //没有使用

测试结果不是很明显，这应该是跟个人测试环境有关。我是在本身win链接虚拟机的linux。网络延迟比较小。因此pipeline
优点不明显。若是网络延迟小的话，最好仍是不用pipeline。除了增长复杂外，带来的性能提高不明显。

更多精彩内容请关注：http://bbs.superwu.cn 

关注超人学院微信二维码 

关注超人学院java免费学习交流群：