thinkphp 8.0 秒杀接口通过redis预热库存、decr/lpop原子扣减、异步队列落库及nginx+php双限流实现高并发解耦,确保毫秒响应与零超卖。

用 ThinkPHP 8.0 构建高并发秒杀接口原型,核心是把“库存校验→下单触发→订单落库”三步彻底解耦,让前端请求在毫秒级返回结果,不卡住 PHP-FPM 进程,也不直接冲击 MySQL。
预热库存到 Redis
秒杀开始前,把商品 ID 对应的可用库存一次性推入 Redis List,并同步写入计数器键。
执行 php think seckill:preload --goods-id=1001 --stock=500 命令,该命令会调用预热脚本:先 【用 LPUSH 往 goods:1001:stock 列表推入 500 个 1】,再 SET goods:1001:stock_count 500。注意:列表值必须为可识别的唯一标识(如 token 或用户 ID),不能全填 1,否则无法追踪谁抢到了;若用 1 简单占位,后续 RPOP 后需额外生成订单号并绑定用户上下文。
这一步必须在活动开始前完成,且不可在接口中动态补库存——否则并发写入会导致计数器与列表长度不一致。
接口层原子扣减与快速响应
用户点击秒杀按钮时,接口只做两件事:原子扣减库存计数器、决定是否进队列。
方法一:用 Redis DECR 做硬校验
第一步:执行 $left = $redis->decr('goods:1001:stock_count')
第二步:若 $left >= 0,说明还有库存,立即调用 Queue::push(SeckillOrderJob::class, $payload) 投递任务;否则执行 $redis->incr('goods:1001:stock_count') 回滚计数器并返回 “已售罄”。【DECR 失败后不回滚就会导致库存永久为负】
方法二:用 EXISTS + LPOP 组合防重
先 $redis->exists('goods:1001:stock') 确认列表存在,再 $token = $redis->rpop('goods:1001:stock')。若 $token 为空,直接返回失败;若非空,才投递带 $token 的任务。此法适合需精确控制“一人一单”或需记录抢购凭证的场景。
订单异步消费与 DB 落库
后台常驻 worker 消费队列,执行真正耗时的数据库操作。
启动命令:php think queue:listen --queue=seckill_order --delay=0 --memory=128 --sleep=3。监听 seckill_order 队列,失败任务不自动重试超过 3 次,避免死循环打爆 DB。
在 app/job/SeckillOrderJob.php 的 fire() 方法中:
① 开启事务:Db::startTrans()
② 执行带条件的 UPDATE:Db::name('seckill_product')->where(['id' => $data['product_id'], 'stock' => ['>', 0]])->update(['stock' => Db::raw('stock - 1')]),返回影响行数为 0 则抛异常
③ 创建订单记录,写入 seckill_order 表
④ 提交事务,删除队列任务
注意:MySQL 层的 WHERE stock > 0 是最后一道防线,防止 Redis 和 DB 库存不一致时出现超卖;但不能仅依赖它——因为高并发下多个请求可能同时通过 WHERE 判断,造成幻读。
限流与熔断兜底
光靠 Redis 不够,Nginx 和 PHP 层必须双保险限流。
Nginx 配置段加入:limit_req zone=seckill burst=100 nodelay;
对应 zone 定义:limit_req_zone $binary_remote_addr zone=seckill:10m rate=500r/s;。这能拦截 90% 的无效刷量请求。
PHP 层补充令牌桶:在控制器前置中间件中调用 Redis::eval() 脚本判断令牌余量,每秒发放 300 个,最大积压 600 个。若返回 false,直接返回 HTTP 429,不进任何业务逻辑。
php免费学习视频:立即使用
踏上前端学习之旅,开启通往精通之路!从前端基础到项目实战,循序渐进,一步一个脚印,迈向巅峰!











