开发者社区> 数据库> 正文

Redis下Lua脚本的复制模式

简介: 假设我们的Redis选择了主从架构, 和AOF持久化方式。我们执行一条写命令时, 该条命令会被发送到从服务器, 和追加到AOF文件中。当我们执行的不是一条命令, 而是Lua脚本时, 默认情况下, 整个Lua脚本的内容会进行复制, 但是存在一些特殊情况。

假设我们的Redis选择了主从架构, 和AOF持久化方式.

当我们执行一条写命令时, 该条命令会被发送到从服务器, 和追加到AOF文件中.

当我们执行的不是一条命令, 而是Lua脚本时, 默认情况下, 整个Lua脚本的内容会进行复制, 但是存在一些特殊情况, 我们来看一个例子, Lua脚本内容如下:

-- 当前时间
local now_time = redis.call('TIME');
-- 设置OPERATE_TIME值为当前秒数
redis.call('SET','OPERATE_TIME',now_time[1]);

默认执行的时候, 会报错如下:

 Write commands not allowed after non deterministic commands. Call redis.replicate_commands() at the start of your script in order to switch to single commands replication mode. 

翻译过来就是说, 写命令不被允许出现在‘非确定性命令’的后面, 请在脚本开始时调用redis.replicate_commands()来切换到命令复制模式.

修改之后的Lua脚本内容如下:

-- 开启单命令复制模式
redis.replicate_commands();
-- 当前时间
local now_time = redis.call('TIME');
-- 设置OPERATE_TIME值为当前秒数
redis.call('SET','OPERATE_TIME',now_time[1]);

再执行就不会报错, 然后我们到AOF文件下去查看一下, 我们发现追加的不是脚本内容, 而是MULTI...EXEC命令:

$1
0
*1
$5
MULTI
*3
$3
SET
$12
OPERATE_TIME
$10
1572855544
*1
$4
EXEC

回到脚本上来, 我们的脚本包含了TIME命令来获取系统时间, 这个命令在不同时间去执行返回的值肯定不一样, 如果在主从复制和AOF追加时, 直接复制整个脚本的内容, 那么肯定会造成执行时数据的不一致性.

所以, 在执行Lua时Redis默认不允许动态的不确定性的变量存在. 如果存在, 则需要开启命令复制模式, 即只复制Lua脚本里包含的写命令, 所有的写命令会被包装在MULTI ... EXEC里.

Redis官方, 把默认的复制整个脚本内容的模式定义为whole scripts replication, 把只复制脚本里写命令的模式定义为 script effects replication.

在命令复制模式下, 还可以选择是否对某个命令进行目标复制, 即是否需要复制到‘从服务器’和‘AOF文件’ , 如下:

redis.set_repl(redis.REPL_ALL) -- Replicate to AOF and slaves.
redis.set_repl(redis.REPL_AOF) -- Replicate only to AOF.
redis.set_repl(redis.REPL_SLAVE) -- Replicate only to slaves.
redis.set_repl(redis.REPL_NONE) -- Don't replicate at all.

举个例子:

redis.replicate_commands() -- 开启命令复制模式
redis.call('set','A','1')
redis.set_repl(redis.REPL_NONE) -- 不进行复制
redis.call('set','B','2')
redis.set_repl(redis.REPL_ALL) -- 复制到所有,即从服务器和AOF文件
redis.call('set','C','3')

在执行完脚本之后, 只有A和C的写操作会进行复制. 这种选择性复制的功能, 在需要过滤掉一些没必要的临时变量时有点用途, 但是提升不了太多性能, 而且操作有风险, 所以可以忽略掉此功能.

当然, 在执行Lua时, 并不是只有出现像TIME这样的非确定性命令时才可以开启命令复制模式, 如果你的脚本内容太多, 而写操作就只有几条, 那么为了提高效率也可以选择开启.

版权声明:本文中所有内容均属于阿里云开发者社区所有,任何媒体、网站或个人未经阿里云开发者社区协议授权不得转载、链接、转贴或以其他方式复制发布/发表。申请授权请邮件developerteam@list.alibaba-inc.com,已获得阿里云开发者社区协议授权的媒体、网站,在转载使用时必须注明"稿件来源:阿里云开发者社区,原文作者姓名",违者本社区将依法追究责任。 如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件至:developer2020@service.aliyun.com 进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
+ 订阅

分享数据库前沿,解构实战干货,推动数据库技术变革

其他文章