如何使用Redis的Lua脚本原子化特性实现分布式高并发秒杀减库存锁

大辰酱_7725

大辰酱_7725

2026-05-26

255人浏览

原创

必须用lua脚本实现原子扣减,因redis单线程执行可避免查库存、判断、扣减三步间的竞态导致超卖;基础脚本用get+decrby,增强版支持一人一单、销量统计与hash存储。

如何使用redis的lua脚本原子化特性实现分布式高并发秒杀减库存锁

直接用 Redis 的 Lua 脚本实现秒杀库存扣减,核心是把“查库存→判断是否足够→扣减”这三步压缩进一个脚本,在 Redis 单线程内原子执行,彻底避开应用层竞争和网络往返延迟。它比分布式锁更轻量、更高效,也比数据库锁更扛压。

为什么必须用 Lua 脚本做原子扣减

秒杀时成千上万请求几乎同时到达,如果在 PHP 或 Java 里先 GET 库存、再 if 判断、再 DECRBY,中间必然存在时间窗口:多个请求读到同一数值(比如 10),都判断“够”,结果一起扣减,导致超卖。Lua 脚本由 Redis 服务端一次性解析执行,中间不被打断,天然串行,从根源上消灭竞态。

Redis Skill - 高性能缓存管理
Redis Skill - 高性能缓存管理

Redis 缓存和数据结构管理技能。通过自然语言操作 Redis,支持 String、Hash、List、Set、ZSet、Stream 等数据结构操作。当用户提到 Redis、缓存、消息队列、会话存储时使用此技能。

下载

基础 Lua 脚本写法(字符串类型库存)

适用于单 SKU、简单库存场景:

  • Redis 中预设库存键:SET sku:1001:stock 100
  • Lua 脚本(decr_stock.lua)内容:
if redis.call("GET", KEYS[1]) >= tonumber(ARGV[1]) then
  return redis.call("DECRBY", KEYS[1], ARGV[1])
else
  return -1
end
  • PHP 调用示例:$result = $redis->eval(file_get_contents('decr_stock.lua'), ['sku:1001:stock'], [1]);
  • 返回值含义:正数表示扣减后剩余库存;-1 表示库存不足

增强版脚本(支持一人一单 + Hash 结构)

真实业务需防刷、记销量、支持限购,推荐用 Hash 存储多字段:

  • 初始化:HSET sku:1001 stock 100 sold 0
  • Lua 脚本逻辑:
local stock = tonumber(redis.call("HGET", KEYS[1], "stock"))
local sold = tonumber(redis.call("HGET", KEYS[1], "sold"))
local need = tonumber(ARGV[1])
local userId = ARGV[2]
local boughtKey = "bought:" .. KEYS[1]

-- 检查是否已买过
if redis.call("SISMEMBER", boughtKey, userId) == 1 then
  return -2 -- 已参与
end

-- 检查库存是否充足
if (stock - sold) >= need then
  redis.call("HINCRBY", KEYS[1], "sold", need)
  redis.call("SADD", boughtKey, userId)
  return stock - sold - need -- 返回剩余可售
else
  return -1 -- 库存不足
end
  • 调用时传入:$redis->eval($script, ['sku:1001'], [1, 'user_12345']);
  • 脚本内完成:一人一单校验、库存计算、销量累加、买家标记,全部原子

关键注意事项

  • 脚本必须幂等且无副作用:不能调用随机函数、不能依赖外部状态、不能有循环或超长计算,否则会阻塞 Redis 其他请求
  • 避免在脚本里访问数据库或发 HTTP 请求:Lua 运行在 Redis 内部,只允许 Redis 命令
  • 提前加载脚本(推荐):用 SCRIPT LOAD 获取 SHA1 值,后续用 EVALSHA 执行,减少网络传输和解析开销
  • 库存回滚要靠业务层补救:Lua 扣减成功后,若后续订单创建失败,需异步补偿(如发 MQ 回滚库存),脚本本身不处理回滚

相关专题

更多
什么是分布式
什么是分布式

分布式是一种计算和数据处理的方式,将计算任务或数据分散到多个计算机或节点中进行处理。本专题为大家提供分布式相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.11

2033

5

分布式和微服务的区别
分布式和微服务的区别

分布式和微服务的区别在定义和概念、设计思想、粒度和复杂性、服务边界和自治性、技术栈和部署方式等。本专题为大家提供分布式和微服务相关的文章、下载、课程内容,供大家免费下载体验。

2023.10.07

3074

5

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.02

4509

19

内存数据库有哪些
内存数据库有哪些

内存数据库有Redis、Memcached、Apache Ignite、VoltDB、TimesTen、H2 Database、Aerospike、Oracle TimesTen In-Memory Database、SAP HANA和ache Cassandra。更多关于内存数据库相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.14

4055

11

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.02

7512

6

redis怎么做缓存服务器
redis怎么做缓存服务器

redis 作为缓存服务器的答案:redis 是一款开源、高性能、分布式的键值存储,可作为缓存服务器使用。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

643

6

redis怎么解决数据一致性
redis怎么解决数据一致性

redis 提供了两种一致性模型,以维护副本数据一致性:强一致性 (sync) 确保写操作仅在复制到所有从节点后才完成;最终一致性 (async) 则在主节点上写操作后认为已完成,牺牲一致性换取性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

756

6

mysql和redis怎么保证双写一致性
mysql和redis怎么保证双写一致性

确保 mysql 和 redis 双写一致性的技术包括:1、事务性更新:同时更新 mysql 和 redis,保证一致性;2、主从复制:mysql 主服务器更改同步到 redis 从服务器;3、基于事件的更新:mysql 记录更改并发送到 redis等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

7382

6

redis缓存一般存些什么数据
redis缓存一般存些什么数据

redis缓存中存储的数据类型包括:字符串、哈希、列表、集合、有序集合、位图、地理空间数据和hyperloglog。这些数据类型适用于存储各种数据,从简单信息到复杂对象和地理位置。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

1160

6

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习