秒杀,抢购热卖商品高并发场景

2024-05-15 09:48

本文主要是介绍秒杀,抢购热卖商品高并发场景,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在秒杀,限时抢购这种大促销场景下,由于峰值流量较大,大量的并发读/写操作除了会导致后端的存储系统产生性能瓶颈外,还会出现传说中的超卖情况。什么是超卖呢?比如某商品的库存为1,此时用户A和用户B并发购买该商品,用户A提交订单后该商品的库存被修改为0,而此时用户B并不知道的情况下提交订单,该商品的库存再次被修改为-1这就是超卖现象。从项目大小本身的角度来说,有下面三种解决方案(MySQL数据库):

一 悲观锁(InnoDB行锁)

实现方法:

1.MySQL常用引擎有MYISAM和InnoDB,而InnoDB是mysql默认的引擎。MYISAM不支持行锁,而InnoDB支持行锁,所以首先要检查MySQL当前引擎是否是InnoDB。

2.每次从数据库表读取商品的时候都加上for update,如select * from xxxx for update,这样一来的话用户A在进行读操作时(还没释放),用户B就需要排队等,一直等到用户A释放才可以读取到进行下面的业务操作,这样可保证商品在没改变库存的情况被多个用户读取到。

缺点:大量的线程(用户)相互竞争InnoDB的行锁,并发越大时,等待的线程就越多,这会严重影响数据库TPS,导致RT线性上升,除了引发常见的数据库死锁外,最终还可能会引发系统出现雪崩。所以使用这种方案来解决的业务场景一定是提前知道了用户流量和评估好服务器性能并提前做过压力测试,之前笔者有项目业务场景是提前用户注册进来,在正式抢购中限制了只能多少人来参加,所以使用这种方案也可以解决当时情景。

注意:有很多人经常反映说按照此方式去操作锁没生效或者有其它问题,那就要看下自己的整体业务逻辑代码是否有问题了,一般我们去抢够商品的时候,是在一个方法里面,如果这个方法名是:buy(),我们进来的时候第一行代码就要开始加锁for update,然后中间去处理业务逻辑并修改商品库存update,最后记得提交commit,这样的话,后面的用户都在等待前面的commit,才能进去往下走。

比如用户A进来

先开启一个事务

begin;

select stock from good where id=1 for update;//查询good表某个商品中stock的数量

查出来后,在程序里在判断这个stock是否足够

最后再执行

update good set stock=stock-1 where id=1

最后在

commit

但是这个时候用户B也是select stock from good where id=1 for update,这个时候会出现被锁住,无法被读取。

二 乐观锁(版本控制)

简单的来说,就是在商品表中建立一个version字段,在高并发场景下,必然会导致多个用户拿到的stock和version版本一样,不过没关系,当用户A成功扣减商品库存后,需要将商品表中的version加1,当用户B再去扣减库存时,由于version不匹配,操作无效,为了提升库存扣减成功率,也可以适当进行重试,如果库存不足,则说明商品已经售完,反之扣减库存后version继续加1。

比如用户A进来

select stock,version from good where id=1 //首先去拿到库存和版本,比如当到当前版本是2

查出来后,在程序里在判断这个stock是否足够

最后再执行

update good set version=version+1,stock=stock-1 where id=1 and version=2

如果有其它用户同时拿到了这个版本2,并比用户A提前修改,这个时候用户A操作是失败的

可以进行重试,再次去拿到库存和版本,后面一样的操作

 

除了使用乐观锁version字段,还可以更加简单,就用实际库存数>=扣减库存数作为条件来替换version版本即可,因为update本身就带锁,采用这种方式更加直接,也充分利用了InnoDB引擎的行锁特征,大大提高了库存扣减的成功率。

如update good set stock=stock-1 where id =1 and stock>=1

 

缺点:以上两种方式,在并发较大时,所有的请求都到底了数据层进行操作,等于把压力全部丢给了数据库,如果系统前端不配合做限流消峰等处理,数据库压力会非常高,代价就很昂贵,所以尽量把这一层的压力往上面转移。

三 在redis中扣减库存

redis的读写能力本身远胜mysql关系数据库,因此在redis中实现库存扣减是个不错的代替方案,这样数据库中的存储的商品库存可以理解为实际库存,而redis中存储的商品库存则为实时库存。

但是在并发较大的情况下,直接在redis中扣减库存也会导致商品出现超卖现象,因此必须引入分布式锁来避免超卖,关于分布式锁可以在我的物联网项目(八)简单分布式调度中查看。

大概实现方式是:数据库库存同步到redis中,当系统获取到分布式锁并成功扣减redis中的实时库存后,可以将消息写入到消息队列中,由消费者负责实际库存的扣减,由于采用了排队机制,并发写入数据库时的流量可控,因此数据库的负载压力保持在一个恒定的范围内,不会因为流量的影响而导致数据库性能下降,具体如图。

image.png

这篇关于秒杀,抢购热卖商品高并发场景的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/991489

相关文章

Java中&和&&以及|和||的区别、应用场景和代码示例

《Java中&和&&以及|和||的区别、应用场景和代码示例》:本文主要介绍Java中的逻辑运算符&、&&、|和||的区别,包括它们在布尔和整数类型上的应用,文中通过代码介绍的非常详细,需要的朋友可... 目录前言1. & 和 &&代码示例2. | 和 ||代码示例3. 为什么要使用 & 和 | 而不是总是使

Python异步编程中asyncio.gather的并发控制详解

《Python异步编程中asyncio.gather的并发控制详解》在Python异步编程生态中,asyncio.gather是并发任务调度的核心工具,本文将通过实际场景和代码示例,展示如何结合信号量... 目录一、asyncio.gather的原始行为解析二、信号量控制法:给并发装上"节流阀"三、进阶控制

Redis中高并发读写性能的深度解析与优化

《Redis中高并发读写性能的深度解析与优化》Redis作为一款高性能的内存数据库,广泛应用于缓存、消息队列、实时统计等场景,本文将深入探讨Redis的读写并发能力,感兴趣的小伙伴可以了解下... 目录引言一、Redis 并发能力概述1.1 Redis 的读写性能1.2 影响 Redis 并发能力的因素二、

Redis中如何实现商品秒杀

《Redis中如何实现商品秒杀》:本文主要介绍Redis中如何实现商品秒杀问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录技术栈功能实现步骤步骤一:准备商品库存数据步骤二:实现商品秒杀步骤三:优化Redis性能技术讲解Redis的List类型Redis的Set

Java中Runnable和Callable的区别和联系及使用场景

《Java中Runnable和Callable的区别和联系及使用场景》Java多线程有两个重要的接口,Runnable和Callable,分别提供一个run方法和call方法,二者是有较大差异的,本文... 目录一、Runnable使用场景二、Callable的使用场景三、关于Future和FutureTa

Nginx实现高并发的项目实践

《Nginx实现高并发的项目实践》本文主要介绍了Nginx实现高并发的项目实践,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录使用最新稳定版本的Nginx合理配置工作进程(workers)配置工作进程连接数(worker_co

JavaScript中的reduce方法执行过程、使用场景及进阶用法

《JavaScript中的reduce方法执行过程、使用场景及进阶用法》:本文主要介绍JavaScript中的reduce方法执行过程、使用场景及进阶用法的相关资料,reduce是JavaScri... 目录1. 什么是reduce2. reduce语法2.1 语法2.2 参数说明3. reduce执行过程

解读Redis秒杀优化方案(阻塞队列+基于Stream流的消息队列)

《解读Redis秒杀优化方案(阻塞队列+基于Stream流的消息队列)》该文章介绍了使用Redis的阻塞队列和Stream流的消息队列来优化秒杀系统的方案,通过将秒杀流程拆分为两条流水线,使用Redi... 目录Redis秒杀优化方案(阻塞队列+Stream流的消息队列)什么是消息队列?消费者组的工作方式每

JavaScript中的isTrusted属性及其应用场景详解

《JavaScript中的isTrusted属性及其应用场景详解》在现代Web开发中,JavaScript是构建交互式应用的核心语言,随着前端技术的不断发展,开发者需要处理越来越多的复杂场景,例如事件... 目录引言一、问题背景二、isTrusted 属性的来源与作用1. isTrusted 的定义2. 为

Python调用另一个py文件并传递参数常见的方法及其应用场景

《Python调用另一个py文件并传递参数常见的方法及其应用场景》:本文主要介绍在Python中调用另一个py文件并传递参数的几种常见方法,包括使用import语句、exec函数、subproce... 目录前言1. 使用import语句1.1 基本用法1.2 导入特定函数1.3 处理文件路径2. 使用ex