高并发秒杀场景下,基于Redis、LUA防止商品超卖
wptr33 2024-12-18 17:32 24 浏览
关联阅读
与超卖问题对应的是商品热Key的解决方案:
高并发情况下,库存扣减、查询等操作就不要考虑用数据库了,Redis是比较常用的解决方案,主要是基于Redis的高并发、原子性的特点。
防止用户重复提交购买
如果前端的“购买”按钮没有置灰,用户可能会反复点击,或者有的用户用软件去刷单,可以使用限流、分布式锁等方式来限制用户的请求。
以分布式锁为例,可以使用“用户ID+排序后的商品ID:购买数量”为Key,例如userId999-spuId111:10-spuId222:10。
但如果用户发N个请求,每个请求的商品ID、购买数量都不一样,或者用户在多客户端发起对不同商品的购买,则这种锁就被绕过。
如果要求严格的话,可以直接锁用户,这样会使客户无法在多客户端进行购买。
按照业务要求进行处理吧。
防止超卖
分两种情况:
一、一次只允许购买一个
使用Redis的List。假设有10个库存,则list插入10个1,购买的时候,使用lpop或rpop取出一个元素,如果为1,则说明有货,执行购买流程,如果为nil说明无货,直接返回。
如果要求一个用户只能购买一次,则需要搭配Redis的Set,通过sadd插入用户ID,如果用户没有购买记录,则sadd返回值为1,否则为0。
二、允许购买多个
步骤如下:
1、先查库存,如果库存-购买数<0,则说明用户购买的数量大于库存,返回失败。否则执行扣减库存流程。
2、使用"decrby key 购买数",扣减库存,返回成功。
按照上述步骤会出现以下情况:
A、用户甲购买时,步骤1,2之间无其他操作,顺利抢购成功,返回的库存数必>=0。
B、用户甲购买时,步骤1,2之间,用户乙抢先扣了库存,导致用户甲再扣库存时,超卖了。
流程示意:
甲查询库存10,购买数5,通过-->
乙查询库存10,购买数6,通过-->
乙扣减库存数6,现有库存4-->
甲扣减库存数5,现有库存数-1,导致超卖。
所以AB两个步骤的操作万不可使用程序来处理,而应该使用LUA脚本,Redis保证了执行LUA脚本的原子性。代码如下:
--商品Key
local key = KEYS[1]
--购买数
local val = ARGV[1]
--现有总库存
local stock = redis.call("GET", key)
if (tonumber(stock)<=0)
then
--没有库存
print("没有库存")
return -1
else
--获取扣减后的总库存=总库存-购买数
local decrstock=redis.call("DECRBY", key, val)
if(tonumber(decrstock)>=0)
then
--扣减购买数后没有超卖,返回现库存
print("没有超卖,现有库存数"..decrstock)
return decrstock
else
--超卖了,把扣减的再加回去
redis.call("INCRBY", key, val)
print("超卖了,现有库存"..stock.."不够购买数"..val)
return -2
end
end
因为我也没系统学过LUA语言,今天也是一边查资料一边写脚本,有几个地方记录一下:
1、Redis存的是数字,但取出来的是String,所以比较数字的时候用tonumber()?转一下。
2、print的连接符是..不是+
测试
我使用的是dockey,先把lua脚本上传至docker
docker cp /本地目录/decrby.lua 容器ID:/data
先预热商品库存,库存数100
set spu 100
执行扣减脚本,购买数50,结果应返回50,再get应该是50
redis-cli --eval decrby.lua spu , 50
注意:key、value两处,前后要有空格。
结果如下:
执行扣减脚本,购买数51,结果应返回-2,再get应该还是50
执行扣减脚本,购买数50,结果应返回0,再get应该为0
执行扣减脚本,购买数5,结果应返回-1,再get应该为0
在实际工作中,如果我们使用Spring Boot的RedisTemplate,这段脚本可以声明为静态String。
相关推荐
- redis的八种使用场景
-
前言:redis是我们工作开发中,经常要打交道的,下面对redis的使用场景做总结介绍也是对redis举报的功能做梳理。缓存Redis最常见的用途是作为缓存,用于加速应用程序的响应速度。...
- 基于Redis的3种分布式ID生成策略
-
在分布式系统设计中,全局唯一ID是一个基础而关键的组件。随着业务规模扩大和系统架构向微服务演进,传统的单机自增ID已无法满足需求。高并发、高可用的分布式ID生成方案成为构建可靠分布式系统的必要条件。R...
- 基于OpenWrt系统路由器的模式切换与网页设计
-
摘要:目前商用WiFi路由器已应用到多个领域,商家通过给用户提供一个稳定免费WiFi热点达到吸引客户、提升服务的目标。传统路由器自带的Luci界面提供了工厂模式的Web界面,用户可通过该界面配置路...
- 这篇文章教你看明白 nginx-ingress 控制器
-
主机nginx一般nginx做主机反向代理(网关)有以下配置...
- 如何用redis实现注册中心
-
一句话总结使用Redis实现注册中心:服务注册...
- 爱可可老师24小时热门分享(2020.5.10)
-
No1.看自己以前写的代码是种什么体验?No2.DooM-chip!国外网友SylvainLefebvre自制的无CPU、无操作码、无指令计数器...No3.我认为CS学位可以更好,如...
- Apportable:拯救程序员,IOS一秒变安卓
-
摘要:还在为了跨平台使用cocos2d-x吗,拯救objc程序员的奇葩来了,ApportableSDK:FreeAndroidsupportforcocos2d-iPhone。App...
- JAVA实现超买超卖方案汇总,那个最适合你,一篇文章彻底讲透
-
以下是几种Java实现超买超卖问题的核心解决方案及代码示例,针对高并发场景下的库存扣减问题:方案一:Redis原子操作+Lua脚本(推荐)//使用Redis+Lua保证原子性publicbo...
- 3月26日更新 快速施法自动施法可独立设置
-
2016年3月26日DOTA2有一个79.6MB的更新主要是针对自动施法和快速施法的调整本来内容不多不少朋友都有自动施法和快速施法的困扰英文更新日志一些视觉BUG修复就不翻译了主要翻译自动施...
- Redis 是如何提供服务的
-
在刚刚接触Redis的时候,最想要知道的是一个’setnameJhon’命令到达Redis服务器的时候,它是如何返回’OK’的?里面命令处理的流程如何,具体细节怎么样?你一定有问过自己...
- lua _G、_VERSION使用
-
到这里我们已经把lua基础库中的函数介绍完了,除了函数外基础库中还有两个常量,一个是_G,另一个是_VERSION。_G是基础库本身,指向自己,这个变量很有意思,可以无限引用自己,最后得到的还是自己,...
- China's top diplomat to chair third China-Pacific Island countries foreign ministers' meeting
-
BEIJING,May21(Xinhua)--ChineseForeignMinisterWangYi,alsoamemberofthePoliticalBureau...
- 移动工作交流工具Lua推出Insights数据分析产品
-
Lua是一个适用于各种职业人士的移动交流平台,它在今天推出了一项叫做Insights的全新功能。Insights是一个数据平台,客户可以在上面实时看到员工之间的交流情况,并分析这些情况对公司发展的影响...
- Redis 7新武器:用Redis Stack实现向量搜索的极限压测
-
当传统关系型数据库还在为向量相似度搜索的性能挣扎时,Redis7的RedisStack...
- Nginx/OpenResty详解,Nginx Lua编程,重定向与内部子请求
-
重定向与内部子请求Nginx的rewrite指令不仅可以在Nginx内部的server、location之间进行跳转,还可以进行外部链接的重定向。通过ngx_lua模块的Lua函数除了能实现Nginx...
- 一周热门
-
-
C# 13 和 .NET 9 全知道 :13 使用 ASP.NET Core 构建网站 (1)
-
因果推断Matching方式实现代码 因果推断模型
-
git pull命令使用实例 git pull--rebase
-
git pull 和git fetch 命令分别有什么作用?二者有什么区别?
-
面试官:git pull是哪两个指令的组合?
-
git 执行pull错误如何撤销 git pull fail
-
git fetch 和git pull 的异同 git中fetch和pull的区别
-
git pull 之后本地代码被覆盖 解决方案
-
还可以这样玩?Git基本原理及各种骚操作,涨知识了
-
git命令之pull git.pull
-
- 最近发表
- 标签列表
-
- 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)