资讯专栏INFORMATION COLUMN

Lua在Redis的应用

aristark / 2626人阅读

摘要:全局变量保护为了防止不必要的数据泄漏进环境,脚本不允许创建全局变量。调用命令在内置的解析器中,调用和函数执行的命令。它们除了处理错误的行为不一样外,其他行为都保持一致。相关文章进入的世界在的应用

首发于 樊浩柏科学院

Redis 从 2.6 版本起,也已开始支持 Lua 脚本,我们可以更加得心应手地使用或扩展 Redis,特别是在高并发场景下 Lua 脚本提供了更高效、可靠的解决方案。

为什么要使用Lua

我们先看一个抢购场景下 商品库存 的问题,用 PHP 可简单实现为:

$key = "number:string";
$redis = new Redis();
$number = $redis->get($key);
if ($number <= 0) {
    return 0;
}
$redis->decr($key);
return $number--;

这段代码其实存在问题,高并发时会出现库存超卖的情况,因为上述操作在 Redis 中不是原子操作,会导致库存逻辑的判断失效。尽管可以通过优化代码来解决问题,比如使用 Decr 原子操作命令、或者使用 锁 的方式,但这里使用 Lua 脚本来解决。

local key = "number:string"
local number = tonumber(redis.call("GET", key))
if number <= 0 then
   return 0
end
redis.call("DECR", key)
return number--

这段脚本代码虽然是 Lua 语言编写( 进入Lua的世界),但是其实就是 PHP 版本的翻译版。那为什么这样,Lua 脚本就能解决库存问题了呢?

Redis 中嵌入 Lua 脚本,所具有的几个特性为:

原子操作:Redis 将整个 Lua 脚本作为一个原子执行,无需考虑并发,无需使用事务来保证数据一致性;

高性能:嵌入 Lua 脚本后,可以减少多个命令执行的网络开销,进而间接提高 Redis 性能;

可复用:Lua 脚本会保存于 Redis 中,客户端都可以使用这些脚本;

在Redis中嵌入Lua

使用Lua解析器

Redis 提供了 EVAL(直接执行脚本) 和 EVALSHA(执行 SHA1 值的脚本) 这两个命令,可以使用内置的 Lua 解析器执行 Lua 脚本。语法格式为:

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

EVALSHA sha1 numkeys key [key ...] arg [arg ...]

参数说明:

script / sha1:EVAL 命令的第一个参数为需要执行的 Lua 脚本字符,EVALSHA 命令的一个参数为 Lua 脚本的 SHA1 值

numkeys:表示 key 的个数

key [key ...]:从第三个参数开始算起,表示在脚本中所用到的那些 Redis 键(key),这些键名参数可以在 Lua 中通过全局数组 KYES[i] 访问

arg [arg ...]:附加参数,在 Lua 中通过全局数组 ARGV[i] 访问

EVAL 命令的使用示例:

> EVAL "return {KEYS[1],KEYS[2],ARGV[1],ARGV[2]}" 2 key1 key2 first second
1) "key1"
2) "key2"
3) "first"
4) "second"

每次使用 EVAL 命令都会传递需执行的 Lua 脚本内容,这样增加了宽带的浪费。Redis 内部会永久保存被运行在脚本缓存中,所以使用 EVALSHA(建议使用) 命令就可以根据脚本 SHA1 值执行对应的 Lua 脚本。

> SCRIPT LOAD "return "hello""
"1b936e3fe509bcbc9cd0664897bbe8fd0cac101b"
> EVALSHA 1b936e3fe509bcbc9cd0664897bbe8fd0cac101b 0
"hello"
Redis 中执行 Lua 脚本都是以原子方式执行,所以是原子操作。另外,redis-cli 命令行客户端支持直接使用--eval lua_file参数执行 Lua 脚本。

Redis 中有关脚本的命令除了 EVAL 和 EVALSHA 外,其他常用命令 如下:

命令 描述
SCRIPT EXISTS script [script ...] 查看脚本是是否保存在缓存中
SCRIPT FLUSH 从缓存中移除所有脚本
SCRIPT KILL 杀死当前运行的脚本
SCRIPT LOAD script 将脚本添加到缓存中,不立即执行
返回脚本SHA1值
数据类型的转换

由于 Redis 和 Lua 都有各自定义的数据类型,所以在使用执行完 Lua 脚本后,会存在一个数据类型转换的过程。

Lua 到 Redis 类型转换与 Redis 到 Lua 类型转换相同部分关系:

Lua 类型 Redis 返回类型 说明
number integer 浮点数会转换为整数
3.333-->3
string bulk
table(array) multi bulk
boolean false nil
> EVAL "return 3.333" 0
(integer) 3
> EVAL "return "fhb"" 0
"fhb"
> EVAL "return {"fhb", "lw", "lbf"}" 0
1) "fhb"
2) "lw"
3) "lbf"
> EVAL "return false" 0
(nil)

需要注意的是,从 Lua 转化为 Redis 类型比 Redis 转化为 Lua 类型多了一条 额外 规则:

Lua 类型 Redis 返回类型 说明
boolean true integer 返回整型 1
> EVAL "return true" 0
(integer) 1

总而言之,类型转换的原则 是将一个 Redis 值转换成 Lua 值,之后再将转换所得的 Lua 值转换回 Redis 值,那么这个转换所得的 Redis 值应该和最初时的 Redis 值一样。

全局变量保护

为了防止不必要的数据泄漏进 Lua 环境, Redis 脚本不允许创建全局变量。

-- 定义全局函数
function f(n)
    return n * 2
end
return f(4);

执行redis-cli --eval function.lua命令,会抛出尝试定义全局变量的错误:

(error) ERR Error running script (call to f_0a602c93c4a2064f8dc648c402aa27d68b69514f): @enable_strict_lua:8: user_script:1: Script attempted to create global variable "f"
Lua脚本调用Redis命令

Redis 创建了用于与 Lua 环境协作的组件—— 伪客户端,它负责执行 Lua 脚本中的 Redis 命令。

调用Redis命令

在 Redis 内置的 Lua 解析器中,调用 redis.call() 和 redis.pcall() 函数执行 Redis 的命令。它们除了处理错误的行为不一样外,其他行为都保持一致。调用 格式:

redis.call(command, [key ...], arg [arg ...] )

redis.pcall(command, [key ...], arg [arg ...] )

> EVAL "return redis.call("SET", "name", "fhb")" 0
> EVAL "return redis.pcall("GET", "name")" 0
"fhb"
Redis日志

在 Lua 脚本中,可以通过调用 redis.log() 函数来写 Redis 日志。格式为:

redis.log(loglevel, message)

loglevel 参数可以是 redis.LOG_DEBUG、redis.LOG_VERBOSE、redis.LOG_NOTICE、redis.LOG_WARNING 的任意值。

查看redis.conf日志配置信息:

# logleval必须一致才会记录
loglevel notice
logfile "/home/logs/redis.log"

Lua 写 Redis 日志示例:

> EVAL "redis.log(redis.LOG_NOTICE, "I am fhb")" 0
113:M 04 Sep 13:12:36.229 * I am fhb
案例 API 访问速率控制

通过 Lua 实现一个针对用户的 API 访问速率控制,Lua 代码如下:

local key = "rate.limit:string:" .. KEYS[1]
local limit = tonumber(ARGV[1])
local expire_time = tonumber(ARGV[2])
local times = redis.call("INCR", key)
if times == 1 then
    redis.call("EXPIRE", key, expire_time)
end
if times > limit then
    return 0
end
return 1

KEYS[1] 可以用 API 的 URI + 用户 uid 组成,ARGV[1] 为单位时间限制访问的次数,ARGV[2] 为限制的单位时间。

批量HGETTALL

这个例子演示通过 Lua 实现批量 HGETALL,当然也可以使用 管道 实现。

-- KEYS为uid数组
local users = {}
for i,uid in ipairs(KEYS) do
    local user = redis.call("hgetall", uid)
    if user ~= nil then
        table.insert(users, i, user)
    end
end
return users
注意事项

虽然使用 Lua 脚本给我们带来了许多便利,但是需要注意几个使用事项:

Lua 脚本在执行时是阻塞的,不应该在 Lua 脚本中有耗时的处理逻辑;

在集群模式时,Lua 脚本必须使用参数 key 传递需操作的 Redis 的 key,且要求所操作的 key 都在同一个 slot 节点上,可以使用以{}标记的 hash tag 方式解决。

相关文章 »

进入Lua的世界(2017-09-03)

Lua在Nginx的应用(2017-09-09)

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/37096.html

相关文章

  • RedisLuaRedis-py应用Lua

    摘要:命令使用解释器执行脚本。命令根据给定的校验码,执行缓存在服务器中的脚本。命令用于校验指定的脚本是否已经被保存在缓存当中。杀死当前正在运行的脚本。全局变量保护,为了防止不必要的数据泄漏进环境,脚本不允许创建全局变量。 基本命令 Redis 脚本使用 Lua 解释器来执行脚本。 Reids 2.6 版本通过内嵌支持 Lua 环境。执行脚本的常用命令为 EVAL。 EVAL script n...

    YancyYe 评论0 收藏0
  • RedisLuaRedis-py应用Lua

    摘要:命令使用解释器执行脚本。命令根据给定的校验码,执行缓存在服务器中的脚本。命令用于校验指定的脚本是否已经被保存在缓存当中。杀死当前正在运行的脚本。全局变量保护,为了防止不必要的数据泄漏进环境,脚本不允许创建全局变量。 基本命令 Redis 脚本使用 Lua 解释器来执行脚本。 Reids 2.6 版本通过内嵌支持 Lua 环境。执行脚本的常用命令为 EVAL。 EVAL script n...

    Elle 评论0 收藏0
  • go redigo执行lua脚本 实现原子操作

    摘要:今天记录的是在中执行脚本实现原子操作。这个时候就可以用到脚本来原子的执行这两条语句。我们可以很方便控制这些参数也可以很方便的执行脚本。 Lua Lua 是一种轻量小巧的脚本语言,用标准C语言编写并以源代码形式开放, 其设计目的是为了嵌入应用程序中,从而为应用程序提供灵活的扩展和定制功能。Lua可以在很多地方使用比如游戏开发、独立应用脚本、Web应用脚本、扩招和数据库插件等等。今天记录的...

    neroneroffy 评论0 收藏0
  • 基于RedisLua分布式限流

    摘要:和分布式限流本质上是一个集群并发问题,单进程单线程的特性,天然可以解决分布式集群的并发问题。的限流实现是微服务架构的网关组件,它基于和实现了令牌桶算法的限流功能,下面我们就来看一下它的原理和细节吧。基于模式,提供了限流过滤器。  Java单机限流可以使用AtomicInteger,RateLimiter或Semaphore来实现,但是上述方案都不支持集群限流。集群限流的应用场景有两个,...

    verano 评论0 收藏0
  • Redis 嵌入式开发

    摘要:嵌入式开发目前目前来说,我们使用的场景大多是仅仅将作为缓存系统来使用。这就是通过在进行嵌入式开发来提高网络效率的原理。 Redis 嵌入式开发 目前 目前来说,我们使用Redis的场景大多是仅仅将Redis作为缓存系统来使用。其实,Redis发展到现在,由于Redis的基于内存速度快,同时支持数据持久化等优良特点,业界很多地方,都是直接将Redis做为数据库使用。甚至,对于一些简单的应...

    Zachary 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<