高并发下超卖问题及如何解决

2021-08-29 分类：Mysql 作者：admin 阅读（22）

一般电子商务网站会有团购，秒杀等活动，而这样的活动特点是请求量激增，数以万计的用户会抢购一个商品，这样会面临活动商品库存有限，高并发下如何控制库存不出现超卖的问题。

注意：

我们的数据存放在MySQL中
使用的语言是Java

为何会发生超卖

一般库存扣除的逻辑代码如下：

//remainder为剩余库存数量
int remainder=statement.query("select remainder from stock where stock_id='$STOCK_ID$'");

//amount为本次订单抢购数量
if(remainder>=amount!=0){
   statement.execute("update stock set remainder=remainder-amount where stock_id='$STOCK_ID$'")
}

//remainder为剩余库存数量

int remainder=statement.query("select remainder from stock where stock_id='$STOCK_ID$'");

//amount为本次订单抢购数量

if(remainder>=amount!=0){

statement.execute("update stock set remainder=remainder-amount where stock_id='$STOCK_ID$'")

}

防止超卖我们首先想到的是通过事务去解决这个问题：

startTransaction();//开启事务

try{
   //remainder为剩余库存数量
   int remainder=statement.query("select remainder from stock where   stock_id='$STOCK_ID$'");

   //amount为本次订单抢购数量
   if(remainder>=amount!=0){
       statement.execute("update stock set remainder=remainder-amount where stock_id='$STOCK_ID$'")
   } 
 }catch(Exception e){
    rollback();//回滚
}

commit();//提交事务

startTransaction();//开启事务

try{

//remainder为剩余库存数量

int remainder=statement.query("select remainder from stock where stock_id='$STOCK_ID$'");

//amount为本次订单抢购数量

if(remainder>=amount!=0){

statement.execute("update stock set remainder=remainder-amount where stock_id='$STOCK_ID$'")

}

}catch(Exception e){

rollback();//回滚

}

commit();//提交事务

上面的事务下执行逻辑其实隐藏一个很大的漏洞-有可能库存会变为负数(即超卖),具体分析如下：

由于是高并发，假设有三个用户a,b,c同时抢购该物品，并进入到了这个事务中，这三个用户查到的库存数是一样的(MySQL rr级别下总是读取事务开始时的行数据)
然后进入到update，假设这三个用户同时进入update操作，这个时候由于行级锁的排他性限制，MySQL会将update操作串行化
上面update执行完后，有可能会发生库存变为负数的情况(超卖)

高并发下，引入缓存解决超卖

主要思路是：

首先在团购秒杀开始前将需要的物品库存信息放入缓存中
使用锁来处理其并发请求
将缓存中的数据同步到数据库。

我们此处使用redis作为缓存。

应用操作redis减库存的大体思路为：

首先通过redis api监听相关物品的库存信息，在事务开启前保证该物品库存信息无人修改
获取现有库存信息，判断库存不为0并且当前库存量大于等于订单所需数量
满足上述2的话则进行扣除操作
如果在1的过程中有别人更新了该物品库存信息版本，则重试
直到库存为0或者剩余库存不满足当前订单扣除数量退出

具体代码如下:

public void secondBuyProduct(Jedis jedis, String stockId, int orders) {
        //CAS重试
        while (true) {
            try {
                //监视key,如果在后续事务执行之前key的值被其他命令所改动，那么事务将被打断
                jedis.watch(stockId);

                int prdNum = Integer.parseInt(jedis.get(stockId));
                //判断库存是否满足订单数量要求
                if (prdNum > 0 && prdNum - orders >= 0)) {

                    Transaction transaction = jedis.multi();
                    //减库存并写入
                    transaction.set(stockId, String.valueOf(prdNum - orders));

                    List<Object> res = transaction.exec();
                    //事务提交后如果为null,说明key值在本次事务提交前已经被改变，本次事务不执行。
                    if (res != null && !res.isEmpty()) {
                        System.out.println("抢购成功！");
                        break;
                    }

                } else {
                    System.err.println("被抢光了！");
                    break;
                }
            } catch (Exception e) {
                System.err.println("抢购出错：" + e.toString());
                e.printStackTrace();
            } finally {
                jedis.unwatch();
            }
        }
    }

public void secondBuyProduct(Jedis jedis, String stockId, int orders) {

//CAS重试

while (true) {

try {

//监视key,如果在后续事务执行之前key的值被其他命令所改动，那么事务将被打断

jedis.watch(stockId);

int prdNum = Integer.parseInt(jedis.get(stockId));

//判断库存是否满足订单数量要求

if (prdNum > 0 && prdNum - orders >= 0)) {

Transaction transaction = jedis.multi();

//减库存并写入

transaction.set(stockId, String.valueOf(prdNum - orders));

List<Object> res = transaction.exec();

//事务提交后如果为null,说明key值在本次事务提交前已经被改变，本次事务不执行。

if (res != null && !res.isEmpty()) {

System.out.println("抢购成功！");

break;

}

} else {

System.err.println("被抢光了！");

break;

}

} catch (Exception e) {

System.err.println("抢购出错：" + e.toString());

e.printStackTrace();

} finally {

jedis.unwatch();

}

来源：https://www.jianshu.com/p/4ee19a4d2a01

「三年博客，如果觉得我的文章对您有用，请帮助本站成长」

赞(0) 打赏

标签：

上一篇：Swoole和hyperf

下一篇：java实现微服务

你可能感兴趣

Redis实现分布式锁的7种方案，及正确使用姿势！

golang中mysql连接池使用性能结论

mysql group by 组内排序方法

Redis 中 BitMap 的使用场景

Myisam 存储引擎的优势

redis常用命令大全

数据库设计冗余和快照

redis 其他

redis 批量拉取与更新

redis conf info

共有 0 - 高并发下超卖问题及如何解决

点击这里取消回复。

博客简介

admin（6年前 (2020-03-09)）
分别用不同厚度的筏板定义，画图后这设置筏板变截面处理。 http://f.fwxgx.co...
评：新文章！
admin（6年前 (2020-03-09)）
分别用不同厚度的筏板定义，画图后这设置筏板变截面处理。 http://f.fwxgx.co...
评：新文章！
admin（6年前 (2020-03-09)）
新增一个框架图！ http://biji.jinli.vip/wp-content/upl...
评：新文章！
一位WordPress评论者（6年前 (2020-02-13)）
嗨，这是一条评论。要开始审核、编辑及删除评论，请访问仪表盘的“评论”页面。评论者头像来自...
评：世界，您好！

高并发下超卖问题及如何解决

你可能感兴趣

共有 0 - 高并发下超卖问题及如何解决

点击这里取消回复。

博客简介

最近更新

随机文章

热门标签

精彩评论