jedis调用redis之pipeline

package com.alex.xiyoubang;

import java.util.Date;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;

public class jedisPipeline {

static Jedis jedis = new Jedis("192.168.1.171", 6379);

public static void testUnUsePipeline() {
long start = new Date().getTime();
System.out.println(jedis.flushDB());
for (int i = 0; i < 10; i++) {
jedis.set("name" + i, i + "");
jedis.get("name" + i);// 每个操作都发送请求给redis-server
}
long end = new Date().getTime();
System.out.println(jedis.keys("name*"));
System.out.println("unuse pipeline cost:" + (end - start) + "ms");

}

public static void testUsePipeline() {
long start = new Date().getTime();

jedis.flushDB();
Pipeline p = jedis.pipelined();
for (int i = 0; i < 10; i++) {
p.set("age" + i, i + "");
p.get("age" + i);
}
p.sync();// 一次性发给redis-server
System.out.println(jedis.keys("age*"));
long end = new Date().getTime();
System.out.println("use pipeline cost:" + (end - start) + "ms");
}

public static void main(String[] args) {
testUnUsePipeline();
testUsePipeline();
}
}