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

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

相关文章

MySQL常用字符串函数示例和场景介绍

《MySQL常用字符串函数示例和场景介绍》MySQL提供了丰富的字符串函数帮助我们高效地对字符串进行处理、转换和分析,本文我将全面且深入地介绍MySQL常用的字符串函数,并结合具体示例和场景,帮你熟练... 目录一、字符串函数概述1.1 字符串函数的作用1.2 字符串函数分类二、字符串长度与统计函数2.1

Java Stream流之GroupBy的用法及应用场景

《JavaStream流之GroupBy的用法及应用场景》本教程将详细介绍如何在Java中使用Stream流的groupby方法,包括基本用法和一些常见的实际应用场景,感兴趣的朋友一起看看吧... 目录Java Stream流之GroupBy的用法1. 前言2. 基础概念什么是 GroupBy?Stream

go动态限制并发数量的实现示例

《go动态限制并发数量的实现示例》本文主要介绍了Go并发控制方法,通过带缓冲通道和第三方库实现并发数量限制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录带有缓冲大小的通道使用第三方库其他控制并发的方法因为go从语言层面支持并发,所以面试百分百会问到

Go语言并发之通知退出机制的实现

《Go语言并发之通知退出机制的实现》本文主要介绍了Go语言并发之通知退出机制的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1、通知退出机制1.1 进程/main函数退出1.2 通过channel退出1.3 通过cont

java如何实现高并发场景下三级缓存的数据一致性

《java如何实现高并发场景下三级缓存的数据一致性》这篇文章主要为大家详细介绍了java如何实现高并发场景下三级缓存的数据一致性,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 下面代码是一个使用Java和Redisson实现的三级缓存服务,主要功能包括:1.缓存结构:本地缓存:使

C++中detach的作用、使用场景及注意事项

《C++中detach的作用、使用场景及注意事项》关于C++中的detach,它主要涉及多线程编程中的线程管理,理解detach的作用、使用场景以及注意事项,对于写出高效、安全的多线程程序至关重要,下... 目录一、什么是join()?它的作用是什么?类比一下:二、join()的作用总结三、join()怎么

在MySQL中实现冷热数据分离的方法及使用场景底层原理解析

《在MySQL中实现冷热数据分离的方法及使用场景底层原理解析》MySQL冷热数据分离通过分表/分区策略、数据归档和索引优化,将频繁访问的热数据与冷数据分开存储,提升查询效率并降低存储成本,适用于高并发... 目录实现冷热数据分离1. 分表策略2. 使用分区表3. 数据归档与迁移在mysql中实现冷热数据分

nginx -t、nginx -s stop 和 nginx -s reload 命令的详细解析(结合应用场景)

《nginx-t、nginx-sstop和nginx-sreload命令的详细解析(结合应用场景)》本文解析Nginx的-t、-sstop、-sreload命令,分别用于配置语法检... 以下是关于 nginx -t、nginx -s stop 和 nginx -s reload 命令的详细解析,结合实际应

Android kotlin中 Channel 和 Flow 的区别和选择使用场景分析

《Androidkotlin中Channel和Flow的区别和选择使用场景分析》Kotlin协程中,Flow是冷数据流,按需触发,适合响应式数据处理;Channel是热数据流,持续发送,支持... 目录一、基本概念界定FlowChannel二、核心特性对比数据生产触发条件生产与消费的关系背压处理机制生命周期

MyBatis-Plus 中 nested() 与 and() 方法详解(最佳实践场景)

《MyBatis-Plus中nested()与and()方法详解(最佳实践场景)》在MyBatis-Plus的条件构造器中,nested()和and()都是用于构建复杂查询条件的关键方法,但... 目录MyBATis-Plus 中nested()与and()方法详解一、核心区别对比二、方法详解1.and()