【Redis】高阶使用（二）：管道与 lua 脚本

1.管道（Pipeline）

客户端可以一次性发送多个请求而不用等待服务器的响应，待所有命令都发送完后再一次性读取服务的响应。这样可以极大的降低多条命令执行的网络传输开销，管道执行多条命令的网络开销实际上只相当于一次命令执行的网络开销。

需要注意到是用 pipeline 方式打包命令发送，redis 必须在处理完所有命令前先缓存起所有命令的处理结果。打包的命令越多，缓存消耗内存也越多。所以并不是打包的命令越多越好。

pipeline 中发送的每个 command 都会被 server 立即执行，如果执行失败，将会在此后的响应中得到信息；也就是 pipeline 并不是表达“所有command 都一起成功”的语义，管道中前面命令失败，后面命令不会有影响，继续执行。

详细代码示例见上面 jedis 连接示例：

Pipeline pl = jedis.pipelined();
for (int i = 0; i < 10; i++) {
    pl.incr("pipelineKey");
    pl.set("zhangsan" + i, "zhangsan");
}
List<Object> results = pl.syncAndReturnAll();
System.out.println(results);

2.Redis Lua 脚本

Redis 在2.6推出了脚本功能，允许开发者使用 Lua 语言编写脚本传到 Redis 中执行。

使用脚本的好处如下:

1）减少网络开销：本来5次网络请求的操作，可以用一个请求完成，原先5次请求的逻辑放在redis服务器上完成。使用脚本，减少了网络往返时延。这点跟管道类似。

2）原子操作：Redis 会将整个脚本作为一个整体执行，中间不会被其他命令插入。管道不是原子的，不过 redis 的批量操作命令(类似mset)是原子的。

3）替代 redis 的事务功能：redis自带的事务功能很鸡肋，报错不支持回滚，而redis的lua脚本几乎实现了常规的事务功能，支持报错回滚操作，官方推荐如果要使用redis的事务功能可以用redis lua替代。官网文档上有这样一段话：

A Redis script is transactional by definition, so everything you can do with a Redis t ransaction, you can also do with a script, 2 and usually the script will be both simpler and faster.

eval 命令

从Redis2.6.0版本开始，通过内置的 Lua 解释器，可以使用 EVAL 命令对 Lua 脚本进行求值。EVAL 命令的格式如下：

EVAL script numkeys key [key ...] arg [arg ...]

script参数：是一段Lua脚本程序，它会被运行在Redis服务器上下文中，这段脚本不必(也不应该)定义为一个Lua函数
numkeys参数：用于指定键名参数的个数
键名参数 key [key …] ：从EVAL的第三个参数开始算起，表示在脚本中所用到的那些Redis键(key)，这些键名参数可以在 Lua中通过全局变量KEYS数组，用1 为基址的形式访问( KEYS[1] ， KEYS[2] ，以此类推)。
arg [arg …] ：在命令的后，那些不是键名参数的附加参数 arg [arg …] ，可以在Lua中通过全局变量ARGV数组访问，访问的形式和KEYS变量类似( ARGV[1] 、 ARGV[2] ，诸如此类)。例如

127.0.0.1:6379> eval "return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}" 2 key1 key2 first seco nd 
1) "key1" 
2) "key2" 
3) "first" 
4) "second"

“return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}” 是被求值的Lua脚本
数字2指定了键名参数的数量
key1和key2是键名参数，分别使用 KEYS[1] 和 KEYS[2] 访问
first 和 second 则是附加参数，可以通过 ARGV[1] 和 ARGV[2] 访问

call 命令

在 Lua 脚本中，可以使用redis.call()函数来执行 Redis 命令。Jedis调用示例详见上面jedis连接示例：

jedis.set("product_count_1001", "15")
String script = " local count = redis.call('get', KEYS[1]) " +
        " local a = tonumber(count) " +
        " local a = tonumber(ARGV[i]) " +
        " if a >= b then  " +
        " redis.call('set', KEYS[1], count-b) " +
        " return 1 " +
        " end " +
        "return 0 ";
Object obj = jedis.eval(script, Arrays.asList("product_count_1001"), Arrays.asList("10"));
System.out.println(obj);