利用管道技术可以降低频繁调用redis方法的耗时,把多个redis操作一起提交,提升执行速度。也就是适合批量操作redis的时候使用。
public String getName() {
List<Response<String>> a=new ArrayList<>();
redisClient.executePipelined((RedisPipelinedRunner) pipeline->{
pipeline.set("one","hello1");
pipeline.set("two","hello2");
a.add(pipeline.set("three","hello3"));
pipeline.set("four","hello4");
pipeline.set("one","hello5");
Response<String> one = pipeline.get("one");
System.out.println("this is the="+one);
});
System.out.println("this is the="+a.get(0).get());
List<Response<String>> list=new ArrayList<>();
redisClient.executePipelined((RedisPipelinedRunner) pipeline->{
list.add(pipeline.get("two"));
list.add(pipeline.get("three"));
list.add(pipeline.get("four"));
list.add(pipeline.get("one"));
});
for (int i = 0; i < list.size(); i++) {
String s = list.get(i).get();
System.out.println("this is the="+s);
}
return null;
}
版权声明:本文为weixin_43975276原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。