Redis+Lua脚本防超卖是万能解?这3个致命漏洞你可能没发现!
wptr33 2025-06-10 18:37 20 浏览
在高并发秒杀场景中,Redis+Lua脚本常被视为防止超卖的“银弹”。然而,许多开发者因对其底层逻辑理解不足,踩中了致命漏洞却不自知。本文通过真实案例剖析三个隐藏极深的问题,并提供完整解决方案,助你避开技术深坑。
漏洞一:原子性误解——你以为的“原子”未必真原子
反例:库存扣减与业务逻辑分离
某电商平台使用如下Lua脚本扣减库存:
local stock = tonumber(redis.call('GET', KEYS[1]))
if stock >= tonumber(ARGV[1]) then
redis.call('DECRBY', KEYS[1], ARGV[1])
return 1
end
return 0
致命问题:虽然脚本本身是原子的,但开发者将订单生成逻辑放在脚本外执行。当扣减成功但生成订单失败时,库存无法回滚,导致商品永久性丢失。
正例:全链路原子化
优化方案将订单ID生成与库存扣减绑定:
local orderId = ARGV[2]
if stock >= buy_num then
redis.call('DECRBY', KEYS[1], buy_num)
redis.call('HSET', 'orders', orderId, userId) -- 订单记录写入Redis
return orderId
end
关键点:通过将订单操作写入Redis事务(后续异步落库),保证扣减与订单生成的原子性。
漏洞二:库存回滚黑洞——网络抖动引发雪崩
反例:无补偿机制的“裸奔脚本”
某票务系统在脚本中直接扣减库存,但未设计补偿逻辑。当客户端因网络超时重试时,导致重复
用户A请求 → 库存10→5(成功) → 网络超时未收到响应 → 自动重试 → 库存5→0(实际已超卖)
正例:令牌桶+唯一ID防重
结合Token Bucket与请求唯一标识:
local requestId = ARGV[3]
if redis.call('SETNX', 'req:'..requestId, '1') == 0 then
return -1 -- 请求重复
end
redis.call('EXPIRE', 'req:'..requestId, 10)
-- 继续执行扣减逻辑
通过请求ID去重,结合令牌桶限制并发量(如每秒1000令牌),即使网络重试也不会重复处理。
漏洞三:集群环境下的“假原子”——主从不一致陷阱
反例:跨节点库存校验失效
某跨境商城使用Redis Cluster,但未考虑跨节点操作。当主节点扣减成功而从节点未同步时,其他节点读取到脏数据:
节点A库存10 → 扣减为5(主节点)
节点B读取库存 → 仍显示10(从节点未同步)
→ 其他请求继续扣减 → 实际库存-5
正例:Redlock+版本号控制
- Redlock加锁:确保跨节点操作一致性
local lockKey = 'lock:'..KEYS[1]
if redis.call('SET', lockKey, '1', 'NX', 'PX', 30000) then
-- 执行扣减
else
return -2 -- 获取锁失败
end
- 版本号校验:通过Hash结构存储库存及版本
local stockInfo = redis.call('HGETALL', KEYS[1])
if tonumber(stockInfo[2]) >= buy_num then
redis.call('HSET', KEYS[1], 'stock', stockInfo[2]-buy_num, 'version', stockInfo[4]+1)
end
双重保障下,即使集群故障切换也能保证数据一致性。
综合防御方案设计
场景:万人秒杀活动
架构设计:
- 预处理阶段:
- 库存预热:通过Hash分片存储(如10个Key分摊1万库存)
HMSET stock:shard1 product_id 1000 stock:shard2 product_id 1000...
- 扣减阶段:
- 使用分片Key轮询扣减,避免单Key过热
- Lua脚本内集成:库存检查 → 扣减 → 订单预生成 → 分布式锁释放
- 补偿阶段:
- 定时任务扫描预订单状态,15分钟未支付则回滚库存
性能对比:
方案 | QPS | 超卖率 | 故障恢复时间 |
纯数据库 | 200 | 5% | >30s |
基础Lua脚本 | 5000 | 0.1% | 10s |
综合方案 | 12000 | 0% | 1s |
结语
Redis+Lua脚本不是“即插即用”的防超卖方案,需要结合业务场景设计多层防御:
- 原子性闭环:扣减与业务操作必须同属一个原子上下文
- 补偿机制:考虑网络抖动、重试等边界条件
- 集群感知:针对分布式环境设计数据一致性方案
技术没有银弹,唯有深入理解原理,方能真正驾驭高并发场景。看完若觉干货满满,不妨点赞收藏,你的认可是作者持续输出的动力!
相关推荐
- MySQL进阶五之自动读写分离mysql-proxy
-
自动读写分离目前,大量现网用户的业务场景中存在读多写少、业务负载无法预测等情况,在有大量读请求的应用场景下,单个实例可能无法承受读取压力,甚至会对业务产生影响。为了实现读取能力的弹性扩展,分担数据库压...
- 3分钟短文 | Laravel SQL筛选两个日期之间的记录,怎么写?
-
引言今天说一个细分的需求,在模型中,或者使用laravel提供的EloquentORM功能,构造查询语句时,返回位于两个指定的日期之间的条目。应该怎么写?本文通过几个例子,为大家梳理一下。学习时...
- 一文由浅入深带你完全掌握MySQL的锁机制原理与应用
-
本文将跟大家聊聊InnoDB的锁。本文比较长,包括一条SQL是如何加锁的,一些加锁规则、如何分析和解决死锁问题等内容,建议耐心读完,肯定对大家有帮助的。为什么需要加锁呢?...
- 验证Mysql中联合索引的最左匹配原则
-
后端面试中一定是必问mysql的,在以往的面试中好几个面试官都反馈我Mysql基础不行,今天来着重复习一下自己的弱点知识。在Mysql调优中索引优化又是非常重要的方法,不管公司的大小只要后端项目中用到...
- MySQL索引解析(联合索引/最左前缀/覆盖索引/索引下推)
-
目录1.索引基础...
- 你会看 MySQL 的执行计划(EXPLAIN)吗?
-
SQL执行太慢怎么办?我们通常会使用EXPLAIN命令来查看SQL的执行计划,然后根据执行计划找出问题所在并进行优化。用法简介...
- MySQL 从入门到精通(四)之索引结构
-
索引概述索引(index),是帮助MySQL高效获取数据的数据结构(有序),在数据之外,数据库系统还维护者满足特定查询算法的数据结构,这些数据结构以某种方式引用(指向)数据,这样就可以在这些数据结构...
- mysql总结——面试中最常问到的知识点
-
mysql作为开源数据库中的榜一大哥,一直是面试官们考察的重中之重。今天,我们来总结一下mysql的知识点,供大家复习参照,看完这些知识点,再加上一些边角细节,基本上能够应付大多mysql相关面试了(...
- mysql总结——面试中最常问到的知识点(2)
-
首先我们回顾一下上篇内容,主要复习了索引,事务,锁,以及SQL优化的工具。本篇文章接着写后面的内容。性能优化索引优化,SQL中索引的相关优化主要有以下几个方面:最好是全匹配。如果是联合索引的话,遵循最...
- MySQL基础全知全解!超详细无废话!轻松上手~
-
本期内容提醒:全篇2300+字,篇幅较长,可搭配饭菜一同“食”用,全篇无废话(除了这句),干货满满,可收藏供后期反复观看。注:MySQL中语法不区分大小写,本篇中...
- 深入剖析 MySQL 中的锁机制原理_mysql 锁详解
-
在互联网软件开发领域,MySQL作为一款广泛应用的关系型数据库管理系统,其锁机制在保障数据一致性和实现并发控制方面扮演着举足轻重的角色。对于互联网软件开发人员而言,深入理解MySQL的锁机制原理...
- Java 与 MySQL 性能优化:MySQL分区表设计与性能优化全解析
-
引言在数据库管理领域,随着数据量的不断增长,如何高效地管理和操作数据成为了一个关键问题。MySQL分区表作为一种有效的数据管理技术,能够将大型表划分为多个更小、更易管理的分区,从而提升数据库的性能和可...
- MySQL基础篇:DQL数据查询操作_mysql 查
-
一、基础查询DQL基础查询语法SELECT字段列表FROM表名列表WHERE条件列表GROUPBY分组字段列表HAVING分组后条件列表ORDERBY排序字段列表LIMIT...
- MySql:索引的基本使用_mysql索引的使用和原理
-
一、索引基础概念1.什么是索引?索引是数据库表的特殊数据结构(通常是B+树),用于...
- 一周热门
-
-
C# 13 和 .NET 9 全知道 :13 使用 ASP.NET Core 构建网站 (1)
-
程序员的开源月刊《HelloGitHub》第 71 期
-
详细介绍一下Redis的Watch机制,可以利用Watch机制来做什么?
-
假如有100W个用户抢一张票,除了负载均衡办法,怎么支持高并发?
-
Java面试必考问题:什么是乐观锁与悲观锁
-
如何将AI助手接入微信(打开ai手机助手)
-
redission YYDS spring boot redission 使用
-
SparkSQL——DataFrame的创建与使用
-
一文带你了解Redis与Memcached? redis与memcached的区别
-
如何利用Redis进行事务处理呢? 如何利用redis进行事务处理呢英文
-
- 最近发表
- 标签列表
-
- git pull (33)
- git fetch (35)
- mysql insert (35)
- mysql distinct (37)
- concat_ws (36)
- java continue (36)
- jenkins官网 (37)
- mysql 子查询 (37)
- python元组 (33)
- mybatis 分页 (35)
- vba split (37)
- redis watch (34)
- python list sort (37)
- nvarchar2 (34)
- mysql not null (36)
- hmset (35)
- python telnet (35)
- python readlines() 方法 (36)
- munmap (35)
- docker network create (35)
- redis 集合 (37)
- python sftp (37)
- setpriority (34)
- c语言 switch (34)
- git commit (34)