redis 管道 队列

kernelsky

　　1 管道：
　　redis的pipeline(管道)功能在命令行中没有，但是redis是支持管道的，在java的客户端(jedis)中是可以使用的。
测试发现：
1：使用管道方式，插入1000条数据耗时37毫秒
Pipeline pipelined = jedis.pipelined();
for (int i = 0; i < 1000; i++) {
pipelined.set("test"+i, "test"+i);
}
pipelined.sync();
2：不使用管道方式，插入1000条数据耗时328毫秒
for (int i = 0; i < 1000; i++) {
jedis.set("test"+i, "test"+i);
}
　　当执行多个命令 并且命令之间没有关系(比如第二个命令需要第一个命令的返回值)
　　客户端向服务端发送请求  和服务端向客户端返回请求：一来一回 在访问数据量大的情况下，网络IO 时延很久
　　示意图如下：
　　

 
　　代码如下：

package bj.zm.redis;
import java.util.List;
import org.junit.Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;
/**
* 使用管道插入数据
* @author Administrator
*
* 结果：
with piple time is: 52
个数1000
not pipe time is: 124
*
*/
public class TestPieple {
Jedis jedis = new Jedis("192.168.1.110", 6379);
@Test
public void testno() {
long start_time = System.currentTimeMillis();
for (int i = 0; i < 1000; i++) {
jedis.set("key"+i, i+"");
}
System.out.println("not pipe time is: "+ (System.currentTimeMillis()-start_time));
}
@Test
public void testuse() {
Pipeline pipelined = jedis.pipelined();
long start_time = System.currentTimeMillis();
for (int i = 0; i < 1000; i++) {
pipelined.set("key_"+i, i+"");
}
List<Object> syncAndReturnAll = pipelined.syncAndReturnAll();
System.out.println("with piple time is: " + (System.currentTimeMillis()-start_time));
System.out.println("个数"+syncAndReturnAll.size()); // 得到1000个处理后返回的交互结果
}
}