Redis之Lua脚本
wptr33 2025-01-17 13:13 23 浏览
Redis在2.6版本提供了Lua脚本支持,在Redis服务器启动阶段创建并初始化一个Lua环境,并将其嵌入到服务器中。lua脚本是一种由C编写的可嵌入的轻量级语言,详见Lua官网:http://www.lua.org。
Lua环境创建过程
Redis服务器在启动阶段通过C加载Lua lib创建其运行时环境,同时为了效率及安全性也对该运行时环境做了一系列的调整。具体如下:
- 创建一个基础的Lua环境lua_State。
- 加载lua函数库,注册了一些组件到lua运行时环境,如cjson、bit等。
- 移除了一些对Redis服务器非安全的函数,例如文件加loadfile、dofile等。
- 初始化lua脚本的存储结构lua_scripts字典。
- 注册Redis命令函数到lua运行时环境,如redis.call函数。
- 替换lua原有的可能带来副作用的函数,如随机函数,以及创建了排序函数。
- 创建lua_client,该客户端用于执行lua脚本中包含的Redis命令。
- 为了防止客户端在提交lua脚本引入额外的全局变量,Redis服务器对lua全局环境进行了保护,不能新增全局变量但已存在变量值可以被改变。
- 保存lua环境值redisServer。
lua随机函数及排序函数替换
Redis涉及到主从复制,如果同一个脚本在不同的服务器执行得到了不同的结果,可能带来一致性问题,因此Redis希望lua的一些函数不能带有副作用。例如lua的随机数函数,其可能导致主从服务器执行得到不同的结果。另外一个是排序函数,Redis希望同一个集合类型的每次查询结结果集内元素都是顺序一致的,为了消除这种不确定性,Redis创建了排序函数供lua脚本使用。
Lua客户端
伪客户端的存在是为了不影响Redis现有的架构,将lua脚本中的Redis命令交由其提交给Redis命令执行器,命令执行器将其视为一个客户端正常addReply给伪客户端,伪客户端再将结果返回给lua环境,最终到脚本执行完成,返回给实际请求的客户端。过程如下:
EVAL命令的执行过程
EVAL命令的格式:EVAL script numkeys KEYS ARGS
- script:脚本内容
- numkeys:脚本中指定键名的个数
- KEYS:键名集,通过全局变量KEYS数组表示,起始下标为1
- ARGS:键值参数集,通过全局变量ARGV数组表示,起始下标为1
- lua脚本发送到Redis服务器会对其内容计算校验和,然后缓存至lus_scripts字典中。
- Redis服务器会给每一个要执行的不同lua脚本生成一个唯一方法,该方法的名为:固定前缀 f_ +脚本sha1校验和。
- 该方法会被注册到lua环境,而且该方法涉及的参数KEYS与ARGV都会被加入到lua全局变量中供脚本执行时使用。
- lua脚本支持执行超时中断,通过在脚本执行前注册超时钩子方法来处理中断。
为什么EVAL命令的语义要求字面量不要直接写在lua脚本中?
因为lua脚本会被保存在Redis服务器的lus_scripts字典中,其中key就是脚本的sha1校验和,如果lua脚本中字面量写死在了脚本中,将会产生大量的不可重复使用的脚本对象在该字典中,脚本对象无法重复利用,会导致大量的内存占用及内存泄漏的风险。
lua脚本中断执行的实现原理?
如果脚本执行设置了超时钩子,那么脚本执行器将定期调用该钩子方法检测脚本是否已经超时执行,如果已经超时,该钩子方法会检测客户端是否有SCRIPT KILL命令或者SHUTDOWN NOSAVE命令请求,如果有则执行命令,中断脚本执行。SCRIPT KILL命令只能在脚本没有执行过任何写入操作时可用,如果脚本已经执行了写入操作,那么只能用SHUTDOWN NOSAVE命令来停止服务器,防止脏数据被写入到数据库。
脚本的复制
若服务器开启了AOF模式,那么EVAL命令记录到AOF文件中将会是MUTIL+EXEC(事务相关命令,详见我的主页《Reids之Transaction(事务)》),也就是说会将其当做一个Redis事务来记录。lua脚本本身包含了一个或者多个命令,在Redis服务端一次性执行,这和Redis事务实现类似。区别在于事务的命令在提交前暂存在事务队列,事务提交后依次执行,而lua脚本是命令打包到一个lua脚本中,执行脚本是通过伪客户端依次执行命令。
Redis Lua脚本和事务
从定义上来说, Redis 中的脚本本身就是一种事务, 所以任何在事务里可以完成的事, 在脚本里面也能完成。 并且一般来说, 使用脚本要来得更简单,并且速度更快。
因为脚本功能是 Redis 2.6 才引入的, 而事务功能则更早之前就存在了, 所以 Redis 才会同时存在两种处理事务的方法。
不过我们并不打算在短时间内就移除事务功能, 因为事务提供了一种即使不使用脚本, 也可以避免竞争条件的方法, 而且事务本身的实现并不复杂。
不过在不远的将来, 可能所有用户都会只使用脚本来实现事务也说不定。 如果真的发生这种情况的话, 那么我们将废弃并最终移除事务功能。
应用场景
lua脚本可谓是Redis能力倍增器,从一些优秀的Redis中间件就可以看出。例如Redisson,一款非常受欢迎的Redis客户端,该客户端实现了非常丰富的功能,比如:分布式锁(RedissonLock支持重入、RedLock等)、分布式集合(RQueue、RSet)等。该客户端中大量地使用了lua脚本来实现各种功能,后续我会进行深入的讲解。
一个Redisson中RedissonLock加/解锁使用lua的示例:
// ====【加锁】lua脚本=====================================
// 先执行exists key1命令,判断KEYS[1]是否存在
if (redis.call('exists', KEYS[1]) == 0)
then
// 不存在,执行hincrby key1 field命令,将ARGV[2]的值原子加1
// 并设置KEYS[1]的过期时间为ARGV[1]
// 返回nil
redis.call('hincrby', KEYS[1], ARGV[2], 1);
redis.call('pexpire', KEYS[1], ARGV[1]);
return nil;
end;
// 执行hexists key field命令,判断ARGV[2]是否存在
if (redis.call('hexists', KEYS[1], ARGV[2]) == 1)
then
// 存在,与上面then逻辑一致
redis.call('hincrby', KEYS[1], ARGV[2], 1);
redis.call('pexpire', KEYS[1], ARGV[1]);
return nil;
end;
// 若key存在且key field也存在,执行pttl key命令,返回KEYS[1]的过期时间
return redis.call('pttl', KEYS[1]);
// ====【解锁】lua脚本=====================================
// 执行hexists key1 field命令,判断判断ARGV[3]是否存在
if (redis.call('hexists', KEYS[1], ARGV[3]) == 0)
then
// 不存在,返回nil
return nil;
end;
// 执行hincrby key1 field命令,获取结果
local counter = redis.call('hincrby', KEYS[1], ARGV[3], -1);
if (counter > 0)
then
// counter大于0,执行pexpire key1 命令,设置key过期时间为ARGV[2]
redis.call('pexpire', KEYS[1], ARGV[2]);
return 0;
else
// 否则,执行del key命令,删除KEYS[1]
// 执行publish channel message命令,向KEYS[2]发送消息ARGV[1]
redis.call('del', KEYS[1]);
redis.call('publish', KEYS[2], ARGV[1]);
return 1;
end;
return nil;
从这两段脚本可以看出Redis集成lua脚本的强大之处,自由度非常高,客制化的实现非常的便捷。当然,如果将复杂的业务逻辑搬进来是要极其谨慎的,如果是一个非常耗时的脚本(操作大key、循环等)很有可能严重影响到服务器的吞吐量。如果不得不这么做,那么一定要记得设置执行超时时间。
以上就是Redis Lua脚本的介绍,如果各位还想了解更多,欢迎转发+评论+关注,Redis图解系列专栏持续更新中,欢迎进入我的主页查看更多。
- 上一篇:最强分布式锁工具:Redisson
- 下一篇:「分布式锁」三种分布式锁的实现
相关推荐
- redis的八种使用场景
-
前言:redis是我们工作开发中,经常要打交道的,下面对redis的使用场景做总结介绍也是对redis举报的功能做梳理。缓存Redis最常见的用途是作为缓存,用于加速应用程序的响应速度。...
- 基于Redis的3种分布式ID生成策略
-
在分布式系统设计中,全局唯一ID是一个基础而关键的组件。随着业务规模扩大和系统架构向微服务演进,传统的单机自增ID已无法满足需求。高并发、高可用的分布式ID生成方案成为构建可靠分布式系统的必要条件。R...
- 基于OpenWrt系统路由器的模式切换与网页设计
-
摘要:目前商用WiFi路由器已应用到多个领域,商家通过给用户提供一个稳定免费WiFi热点达到吸引客户、提升服务的目标。传统路由器自带的Luci界面提供了工厂模式的Web界面,用户可通过该界面配置路...
- 这篇文章教你看明白 nginx-ingress 控制器
-
主机nginx一般nginx做主机反向代理(网关)有以下配置...
- 如何用redis实现注册中心
-
一句话总结使用Redis实现注册中心:服务注册...
- 爱可可老师24小时热门分享(2020.5.10)
-
No1.看自己以前写的代码是种什么体验?No2.DooM-chip!国外网友SylvainLefebvre自制的无CPU、无操作码、无指令计数器...No3.我认为CS学位可以更好,如...
- Apportable:拯救程序员,IOS一秒变安卓
-
摘要:还在为了跨平台使用cocos2d-x吗,拯救objc程序员的奇葩来了,ApportableSDK:FreeAndroidsupportforcocos2d-iPhone。App...
- JAVA实现超买超卖方案汇总,那个最适合你,一篇文章彻底讲透
-
以下是几种Java实现超买超卖问题的核心解决方案及代码示例,针对高并发场景下的库存扣减问题:方案一:Redis原子操作+Lua脚本(推荐)//使用Redis+Lua保证原子性publicbo...
- 3月26日更新 快速施法自动施法可独立设置
-
2016年3月26日DOTA2有一个79.6MB的更新主要是针对自动施法和快速施法的调整本来内容不多不少朋友都有自动施法和快速施法的困扰英文更新日志一些视觉BUG修复就不翻译了主要翻译自动施...
- Redis 是如何提供服务的
-
在刚刚接触Redis的时候,最想要知道的是一个’setnameJhon’命令到达Redis服务器的时候,它是如何返回’OK’的?里面命令处理的流程如何,具体细节怎么样?你一定有问过自己...
- lua _G、_VERSION使用
-
到这里我们已经把lua基础库中的函数介绍完了,除了函数外基础库中还有两个常量,一个是_G,另一个是_VERSION。_G是基础库本身,指向自己,这个变量很有意思,可以无限引用自己,最后得到的还是自己,...
- China's top diplomat to chair third China-Pacific Island countries foreign ministers' meeting
-
BEIJING,May21(Xinhua)--ChineseForeignMinisterWangYi,alsoamemberofthePoliticalBureau...
- 移动工作交流工具Lua推出Insights数据分析产品
-
Lua是一个适用于各种职业人士的移动交流平台,它在今天推出了一项叫做Insights的全新功能。Insights是一个数据平台,客户可以在上面实时看到员工之间的交流情况,并分析这些情况对公司发展的影响...
- Redis 7新武器:用Redis Stack实现向量搜索的极限压测
-
当传统关系型数据库还在为向量相似度搜索的性能挣扎时,Redis7的RedisStack...
- Nginx/OpenResty详解,Nginx Lua编程,重定向与内部子请求
-
重定向与内部子请求Nginx的rewrite指令不仅可以在Nginx内部的server、location之间进行跳转,还可以进行外部链接的重定向。通过ngx_lua模块的Lua函数除了能实现Nginx...
- 一周热门
-
-
C# 13 和 .NET 9 全知道 :13 使用 ASP.NET Core 构建网站 (1)
-
因果推断Matching方式实现代码 因果推断模型
-
git pull命令使用实例 git pull--rebase
-
git pull 和git fetch 命令分别有什么作用?二者有什么区别?
-
面试官:git pull是哪两个指令的组合?
-
git 执行pull错误如何撤销 git pull fail
-
git fetch 和git pull 的异同 git中fetch和pull的区别
-
git pull 之后本地代码被覆盖 解决方案
-
还可以这样玩?Git基本原理及各种骚操作,涨知识了
-
git命令之pull git.pull
-
- 最近发表
- 标签列表
-
- git pull (33)
- git fetch (35)
- mysql insert (35)
- mysql distinct (37)
- concat_ws (36)
- java continue (36)
- jenkins官网 (37)
- mysql 子查询 (37)
- python元组 (33)
- mybatis 分页 (35)
- vba split (37)
- redis watch (34)
- python list sort (37)
- nvarchar2 (34)
- mysql not null (36)
- hmset (35)
- python telnet (35)
- python readlines() 方法 (36)
- munmap (35)
- docker network create (35)
- redis 集合 (37)
- python sftp (37)
- setpriority (34)
- c语言 switch (34)
- git commit (34)