redis中pipeline的使用

先安装一个dos2unix工具
ubuntu下使用

apt-get install dos2unix

macOS中，使用

brew install dos2unix

准备如下文件

[email protected]:/redis/redis-4.0.1# cat pipeline.txt 
set mykey myvalue
sadd myset value1 value2
get mykey
scard myset

这个文本文件中每一行都必须以\r\n而不是\n结束，这个可以使用上面安装的工具

unix2dos pipeline.txt

通过管道一次性发送所有来自stdin的命令

[email protected]:/redis/redis-4.0.1# cat pipeline.txt | /usr/local/bin/redis-cli --pipe
All data transferred. Waiting for the last reply...
Last reply received from server.
errors: 0, replies: 4

极大减少往还延时的开销。

Jedis中的使用

package pdf;

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

public class JedisTest {

	public static void main(String[] args) {
		// TODO Auto-generated method stub
		Jedis jedis = new Jedis("192.168.8.147");
		jedis.auth("123456");
		Pipeline pipeline = jedis.pipelined();
		pipeline.set("user","huangbaokang");
		pipeline.sadd("lover", "zhanglulu");
		Response<String> user_res = pipeline.get("user");
		Response<Long> size_res = pipeline.scard("lover");
		pipeline.sync();
		System.out.println(user_res.get());
		System.out.println(size_res.get());
	}
}