必须用 lua 脚本,因为 redis 中 lua 脚本单线程原子执行,可将“读取→判断→扣减”三步合为一个原子操作;而 java 分步调用 get/decr 会导致并发超卖。

Redis 的 Lua 脚本配合 Java 可以在高并发下实现真正原子性的库存扣减,避免超卖。核心在于把“读取库存→判断是否足够→扣减”这三步全部放在 Redis 服务端执行,Java 不参与中间状态判断。
为什么必须用 Lua 脚本?
单纯用 Java + Redis 命令(比如先 GET 再 DECR)无法保证原子性:两个请求可能同时读到库存=1,都判断通过,接着都执行扣减,结果库存变成 -1 —— 这就是超卖。Lua 脚本在 Redis 中是单线程原子执行的,整个脚本运行期间不会有其他命令插入。
库存扣减 Lua 脚本怎么写?
一个安全、可复用的 Lua 脚本示例如下:
local key = KEYS[1]
local delta = tonumber(ARGV[1])
local current = tonumber(redis.call("GET", key))
if current == nil or current
return -1 -- 库存不足或 key 不存在
end
return redis.call("DECRBY", key, delta)
这个脚本返回值含义明确:
- -1:扣减失败(库存不足)
- ≥0 的整数:扣减后剩余库存值
Java 端如何调用并处理结果?
使用 Lettuce 或 Jedis 都可以,推荐 Lettuce(响应式、线程安全)。关键点:预加载脚本、传参规范、结果判别。
- 用 ScriptingCommands.evalSha() 或 eval() 执行,优先用 SHA 缓存提升性能
-
KEYS[1] 传库存 key(如
"item:1001:stock"),ARGV[1] 传要扣减的数量(字符串形式,如"1") - 检查返回值:若为 -1,直接抛异常或返回失败;否则视为成功,剩余库存值可选记录日志或用于后续逻辑
- 建议封装成工具方法,统一处理连接异常、脚本加载、结果解析
进阶防护:结合过期时间与初始化校验
Lua 脚本本身不解决初始库存缺失问题。实际部署需配套机制:
- 库存 key 初始化时,用 SET key value EX seconds 设置带过期时间的初始值,防止 key 永久丢失导致反复重建
- 首次扣减前,Java 可尝试用 SETNX 初始化库存(仅当 key 不存在时设置),但该操作需和 Lua 扣减解耦,避免引入新竞争点
- 对超卖极其敏感的场景(如秒杀),可额外在 Lua 脚本中加入时间戳或版本号校验,但会增加复杂度,通常非必需
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











