百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT技术 > 正文

高并发秒杀场景下,基于Redis、LUA防止商品超卖

wptr33 2024-12-18 17:32 21 浏览

关联阅读

秒杀场景设计的总结

简单列一下分布式高并发要做的事情

与超卖问题对应的是商品热Key的解决方案:

高并发下热Key解决方案总结

基于SpringBoot和ZK的热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。

相关推荐

MYSQL术语介绍:dynamic row format

InnoDB行格式。因为可变长度列值存储在保存行数据的页面之外,所以对于包含大对象的行非常有效。由于通常不会访问大字段来评估查询条件,因此不会经常将它们带入缓冲池,从而减少I/O操作并更好地利用缓...

阿里面试:MySQL Binlog有哪些格式?底层原理?优缺点?

binlog的格式也有三种:STATEMENT、ROW、MIXED,下面我详解binlog三种模式@mikechenStatement模式Statement模式:是基于SQL语句的复制(statem...

Mysql日期格式化显示“年月”(mysql日期格式化)

数据库中存储格式为DATE,如果只显示年月,就需要将日期数据格式化。下面通过两种方式对其格式化显示:...

看完这篇还不懂 MySQL 主从复制,可以回家躺平了

我们在平时工作中,使用最多的数据库就是MySQL...

MySQL binlog format (Statement、Row、Mixed) 二进制日志格式

MySQL的binlog日志作用是用来记录MySQL内部增删改查等对MySQL数据库有更新的内容的记录(对数据库的改动),对数据库的查询select或show等不会被binlog日志记录,主要用于数据...

性能优化-界面卡顿和丢帧(Choreographer 代码检测)

标签:ChoreographerUI卡顿UI丢帧本文将介绍3个知识点:获取系统UI刷新频率检测UI丢帧和卡顿输出UI丢帧和卡顿堆栈信息...

使用Java分析器优化代码性能,解决OOM问题

背景最近我一直在做性能优化,对一个单机应用做性能优化。主要是涉及到解析和导入导出相关的业务。大致说一下这个单机应用干嘛的:制作票样,类似于答题卡。发给某些人填写,然后通过单机python图像识别存到数...

面试必问的HashCode技术内幕(hashmap面试题原理)

3hashCode的内幕tips:面试常问/常用/常出错...

实战Netty!基于私有协议,怎样快速开发网络通信服务

私有协议编写目的本文档用于描述边缘计算单元(以下简称边缘盒)与上位机配置软件(以下简称上位机)之间进行的数据交互通信协议。通信方式...

C#工控上位机系列(2)- 串口通信/监控工具

工控机通常都带有很多串口(10个),而且可以通过Moxa卡扩展串口.但Moxa的串口和电脑自带的串口还是有点区别C#里面没区别,但之前VB6的MSComm控件有时就会有不一样的地方.支持串口通讯...

Java加密与解密之消息摘要算法1(消息摘要(hash函数编码法),又称数字指纹 ( ))

消息摘要算法有3大类,分别是:MD、SHA、MAC,通常用于数据完整性的验证。MD:MessageDigest消息摘要算法。包括:MD2,MD4,MD53种算法。SHA:SecureHashA...

zookeeper的Leader选举源码解析(zookeeper角色选举角色包括)

作者:京东物流梁吉超zookeeper是一个分布式服务框架,主要解决分布式应用中常见的多种数据问题,例如集群管理,状态同步等。为解决这些问题zookeeper需要Leader选举进行保障数据的强一致...

Java 中五种最常见加密算法:原理、应用与代码实现

引言在现代软件开发中,数据安全至关重要。无论是用户密码存储、敏感信息传输,还是系统间的通信,加密技术都扮演着核心角色。Java作为广泛使用的编程语言,通过javax.crypto和java.s...

干货|6招学会调用NFC的各个功能(调出nfc)

现在越来越多的手机支持NFC功能,这种轻松、安全、迅速的通信的无线连接技术,能够让我们的手机替代门禁卡、公交卡、银行卡甚至是车钥匙,那么怎么让APP中能够调用这个功能呢?今天小编就来教给大家!...

一文读懂流媒体协议之RTP 协议(rtp流媒体服务器)

一、简介1.1RTPRTP全名是Real-timeTransportProtocol(实时传输协议)。它是IETF提出的一个标准,对应的RFC文档为RFC3550(RFC1889为其过期版本)。...