论坛 › Redis › Java 使用pipeline对redis进行批量读写

heberoxx 发表于 2017-12-22 07:29:14

Java 使用pipeline对redis进行批量读写

import redis.clients.jedis.Jedis;　　

import redis.clients.jedis.Pipeline;　　

import java.util.List;　　

　　

public>
public void test3Pipelined() {　　
Jedis jedis
= new Jedis("10.18.3.153", 7002);　　

　　
Pipeline pipeline
= jedis.pipelined();　　

long start = System.currentTimeMillis();　　

for (int i = 0; i < 1000; i++) {　　
pipeline.set(
"p" + i, "p" + i);　　

//List<Object> results = pipeline.syncAndReturnAll();      //---- 1　　
      }
　　
List<Object> results = pipeline.syncAndReturnAll();            // ------2
　　
long end = System.currentTimeMillis();
　　
System.out.println("Pipelined SET: " + ((end - start)/1000.0) + " seconds");
　　
jedis.disconnect();
　　
}
　　
public static void main(String []args){
　　
testRedisPipeline obj = new testRedisPipeline();
　　
obj.test3Pipelined();
　　

　　
}
　　
}

查看完整版本: Java 使用pipeline对redis进行批量读写