TP8.0高并发防超卖需Redis原子预扣减与数据库乐观锁闭环校验:先用DECRBY预扣并拦截库存不足请求,再通过version字段乐观锁更新DB,失败时手动回滚Redis库存,可选Lua脚本消除竞态。

TP8.0 高并发下防止库存超卖,需同时应对秒杀类请求的瞬时洪峰与数据库最终一致性要求——单靠 MySQL 行锁易瓶颈,纯 Redis 又难保事务回滚后库存不一致,必须让 Redis 原子预扣减和数据库乐观锁形成闭环校验。
第一步:Redis 层原子预扣减(拦截绝大多数超卖)
在 ThinkPHP8.0 的控制器中,使用 RedisTemplate 的 DECRBY 命令直接扣减库存键值,该操作由 Redis 单线程保证原子性,无需加锁。
执行 redis()->decrBy('stock:1001', $buyCount),返回值为扣减后剩余库存。若返回值 【小于 0】,立即终止流程并返回“库存不足”,不再进入数据库层。
这一步必须前置——它把 95% 以上超卖请求挡在 DB 外,避免无效事务压垮 MySQL。
第二步:数据库层乐观锁校验与落库(兜底强一致)
仅当 Redis 预扣成功(返回值 ≥ 0)后,才发起数据库更新。
查询当前商品记录,获取最新 stock 和 version 字段值。
构造 SQL 更新语句:UPDATE goods SET stock = stock - ?, version = version + 1 WHERE id = ? AND version = ? AND stock >= ?。
执行后检查影响行数:若为 0,说明版本已变或库存被其他请求抢先扣完 → 回滚 Redis(用 INCRBY 补回)、抛出业务异常;若为 1,则提交事务、记录订单。
第三步:异常路径下的 Redis 库存自动回滚
方法一:在数据库更新失败的 catch 块中,显式调用 redis()->incrBy('stock:1001', $buyCount) 补回预扣量。
方法二:启用 TP8.0 的 Db::transaction() 包裹整个流程,但需注意——Redis 操作无法纳入 DB 事务,必须手动补偿。
【务必在 try-catch 的 finally 或 catch 中执行回滚】,否则 Redis 库存永久丢失,导致少卖。
第四步:Lua 脚本加固原子性(可选高阶防护)
将 Redis 预扣减与库存判断合并为一段 Lua 脚本执行,彻底规避网络往返中的竞态窗口。
脚本内容示例:if redis.call("get", KEYS[1]) >= ARGV[1] then return redis.call("decrby", KEYS[1], ARGV[1]) else return -1 end。
在 TP8.0 中通过 redis()->eval($lua, ['stock:1001'], [$buyCount]) 调用,返回值为新库存或 -1。
这一步不是必须,但当 QPS 突破 5000+ 且 Redis 与应用间延迟波动较大时,能消除最后一次“读-判-写”间隙。


















