高并发写场景:库存扣减

在设计商品的库存扣减逻辑时,可能一开始想到的(伪)代码是:

<?php
/**
 * 商品库存扣减
 *
 * @param int $skuId 商品ID
 * @param int $num   库存扣减数量
 *
 * @return bool 扣减成功返回true,失败返回false
 */
function stock_decr($skuId, $num)
{
    $db = new DB();
    $db->beginTransaction();
    try {
        // 查询商品信息
        $skuInfo = $db->query("SELECT stock FROM sku where id = {$skuId}");
        if (empty($skuInfo)) {
            throw new Exception("商品不存在");
        }
        // 判断库存是否充足
        if ($skuInfo['stock'] < $num) {
            throw new Exception("库存不足");
        }
        // 计算新的库存值,并更新到数据表中
        $newStock = $skuInfo['stock'] - $num;
        $ok = $db->query("UPDATE sku SET stock = {$newStock} WHERE id = {$skuId} LIMIT 1");
        if (!$ok) {
            throw new Exception("库存扣减失败");
        }
        $db->commit();
        return true;
    } catch (Exception $e) {
        $db->rollBack();
        return false;
    }
}

比较容易看出,上面的代码在同一商品的高并发场景下会有超卖的问题。

方案一:悲观锁

使用FOR UPDATE语句锁住数据,不让其他人查询和修改:
在这里插入图片描述
这样一来,在并发时,只有一个请求可以拿到锁,其他请求都要卡在 SELECT 语句这个地方等待锁。相当于把并发请求变成串行执行,而且等待锁的请求越多,对 MySQL 的性能影响越大,因此这种方案也很少使用。

方案二:乐观锁

所谓乐观锁,就是在表中新增一个 version 字段,在并发请求下,多个请求 SELECT 到的 stock 和 version 是一样的,因此在第一个请求成功扣减库存后,需要对 version 字段加1;当第二个请求扣减库存时,由于 version 不匹配就会 UPDATE 不成功。为了提升库存扣减的成功率,可以进行适当次数的重试。伪代码:

function stock_decr($skuId, $num)
{
    $db = new DB();

    for ($i = 0; $i < 5; $i++) {
        $db->beginTransaction();
        try {
            // 查询商品信息
            $skuInfo = $db->query("SELECT stock,version FROM sku where id = {$skuId}");
            if (empty($skuInfo)) {
                throw new Exception("商品不存在");
            }
            // 判断库存是否充足
            if ($skuInfo['stock'] < $num) {
                throw new Exception("库存不足");
            }
            // 计算新的库存值,并更新到数据表中
            $newStock = $skuInfo['stock'] - $num;
            $newVersion = $skuInfo['version'] + 1;
            $ok = $db->query("UPDATE sku SET stock = {$newStock},version = {$newVersion} WHERE id = {$skuId} AND version = {$skuInfo['version']} LIMIT 1");
            if (!$ok) {
                throw new Exception("库存扣减失败", 100);
            }
            $db->commit();
            return true;
        } catch (Exception $e) {
            $db->rollBack();
            if ($e->getCode() !== 100) {
                return false;
            }
        }
    }

    return false;
}

但即使使用了乐观锁,在高并发时,由于都是针对同一个数据行执行 UPDATE 操作,必然会引起大量的请求相互竞争 InnoDB 的行锁,而且即使成功获得锁,也有很大可能会因为 version 不匹配导致 UPDATE 失败,进而不断重试。并发越大,竞争锁的线程就越多,这会严重影响数据库的性能。因此乐观锁并不适用于锁冲突十分严重的场景

方案三:基于Redis的悲观锁方案

Redis 与生俱来就拥有高效的读写性能,所以将库存扣减逻辑转移到 Redis 中来对性能提升十分有效。跟关系型数据库相似,Redis 也有对应的悲观锁 / 乐观锁实现方案。

悲观锁方案是结合使用 SETNXDECRBY命令实现库存扣减,首先使用 SETNX 命令获得锁,获取成功后再使用 DECRBY扣减库存,扣减成功后,释放获得的锁。其实跟方案一的FOR UPDATE加锁,逻辑上是一样的。如果获取锁失败可以进行适当的重试,不重试的话,会导致多个并发请求过来,只有一个能获取到锁,其它请求都会因获取锁失败而报错。

在这里,有人可能会有疑惑:Redis本身就是串行执行命令的,不存在并发的问题,为什么还要先用 SETNX 锁住数据呢?直接使用 DECRBY 命令扣减库存,然后判断返回值是否大于等于0不就可以了吗?

是的,这样也是可以的,但是这样库存值有可能会变成负数。比如现有库存是10,同时来了100个请求,每个请求扣减 1 个库存,等全部请求执行完毕后(10个请求成功,90个失败),库存值就会变成 -90;

还有一种情况,假设现有库存是 1,来了一个请求是要买10个商品的,DECRBY后得到的值是 -9,小于0于是返回错误给用户。这时候还没结束,我们还要将库存从 -9 恢复为原本的 1,这样其它用户才能购买。但是因为我们在 DECRBY 之前没有先查询现有库存是多少,不知道原来的库存是 1,所以恢复不了!如果我们改为在 DECRBY 之前,先查询库存有多少,那么就又会回到原来的并发问题,无解。

因此,用 SETNX 锁住数据是有必要的。

代码示例:

function stock_decr($skuId, $num)
    {
        $conn = new Redis();

        for ($i = 0; $i < 5; $i++) {
            // 获取悲观锁
            $lockKey = 'lock:pessimistic';
            $ok = $conn->set($lockKey, 1, ['EX' => 120, 'NX']);
            if (!$ok) {
                continue;
            }
            try {
                // 获取库存
                $skuKey = "sku:$skuId";
                $stock = $conn->get($skuKey);
                if ($stock === false) {
                    throw new Exception("商品不存在");
                }
                $stock = intval($stock);
                if ($stock < $num) {
                    throw new Exception("库存不足");
                }
                $ok = $conn->decrBy($skuKey, $num);
                if ($ok === false) {
                    throw new Exception("库存扣减失败");
                }
                return true;
            } catch (Exception $e) {
                return false;
            } finally {
                $conn->del($lockKey);
            }
        }

        return false;
    }

方案四:基于Redis的乐观锁方案

乐观锁方案需要结合使用 WATCHMULTIDECRBYEXECUNWATCH命令。WATCH命令用于监视一个或多个key,MULTI命令用于将事务块内的多条命令按顺序加入到队列,最后由EXEC命令原子性地进行提交执行,UNWATCH命令用于取消监视。示例:

127.0.0.1:6379> WATCH sku:123
OK
127.0.0.1:6379> MULTI
127.0.0.1:6379> DECRBY sku:123 10
QUEUED
127.0.0.1:6379> EXEC
1) (integer) 88
127.0.0.1:6379> UNWATCH sku:123
OK

上述示例中,首先使用WATCH命令监视商品的库存key,然后通过MULTI命令标记一个事务的开始,当库存扣减命令(DECRBY)成功添加进队列后,执行EXEC命令提交事务,如果在此过程中,监视的 key 的值发生了变化,那么事务会执行失败;最后使用 UNWATCH命令取消掉对库存 key 的监视。

在同一商品的高并发库存扣减场景下,因为库存key的值会变化得很快,所以EXEC执行的成功率会比较低,往往需要通过重试来提高成功率。

方案五:基于Redis的嵌入lua脚本方案(推荐)

先写一段扣减库存的 Lua 示例代码:

local sku = KEYS[1]
local num = tonumber(ARGV[1])
local stock = tonumber(redis.call('GET', sku))
local result = 0

if (stock >= num)
then
    redis.call('DECRBY', sku, num)
    result = 1
end
return result

在 Redis 中,我们可以使用 EVALEVALSHA 命令执行 Lua 脚本代码,但使用 EVAL 命令客户端每次都要重复向 Redis 传递一段相同的 Lua 代码,网络开销较大。而 EVALSHA 命令则是从 Redis 中获取已经缓存好的脚本执行,网络开销较小,但需要先使用 SCRIPT LOAD 命令把 Lua 脚本加载到 Redis。综上,推荐使用 EVALSHA 命令。

Lua 脚本中的代码,Redis会把它们当作单条命令执行,所以是原子性的。而且在这个方案中,我们并没有使用到悲观锁 或者 乐观锁,因此性能上会更好,推荐使用此种方案。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mfbz.cn/a/9388.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Go是一门面向对象编程语言吗

本文首发自「慕课网」&#xff0c;想了解更多IT干货内容&#xff0c;程序员圈内热闻&#xff0c;欢迎关注"慕课网"&#xff01; 作者&#xff1a;tonybai|慕课网讲师 Go语言已经开源13年了&#xff0c;在近期TIOBE发布的2023年3月份的编程语言排行榜中&#xff0c;…

【hello Linux】Linux基本指令(下)

目录 1. more 指令&#xff1a;分批查看文件 1.1 more -n 文件名&#xff1a;查看文件前 n 行 1.2 more 文件名&#xff1a;屏幕输满 补充指令&#xff1a; 2. less 指令 2.1 less -N 文件名 2.2 /字符串&#xff1a;向下搜索“字符串”的功能 3. head 指令 3.1 head 文件名 3…

4.Java逻辑控制语句

Java逻辑控制语句 在实际生活中&#xff0c;我们的生活不是一成不变的&#xff0c;很多时候需要我们去选择&#xff0c;大到人生的十字路口&#xff0c;小到今天晚上吃什么&#xff0c;选择无处不在。小的选择决定了我们一件小事的走向&#xff0c;大的选择可能会改变我们人生…

基于多目标粒子群优化算法的计及光伏波动性的主动配电网有功无功协调优化(Matlab代码实现)

&#x1f4a5;&#x1f4a5;&#x1f49e;&#x1f49e;欢迎来到本博客❤️❤️&#x1f4a5;&#x1f4a5; &#x1f3c6;博主优势&#xff1a;&#x1f31e;&#x1f31e;&#x1f31e;博客内容尽量做到思维缜密&#xff0c;逻辑清晰&#xff0c;为了方便读者。 ⛳️座右铭&a…

JavaScript -- 对象

1. 概念 对象是 JavaScript 数据类型的一种&#xff0c;可以理解为是一种无序的数据集合 2. 对象的使用 2.1 对象的声明 let 对象名 {} let 对象名 new Object() 2.2 属性和方法 数据描述性的信息称为属性&#xff0c;如人的姓名、身高、年龄、性别等&#xff0c;一般是…

蓝桥杯之贪心

蓝桥杯之贪心1055.股票买卖II104.货仓选址AcWing112.雷达设备1235.付账问题1239.乘积最大K是奇数&#xff0c;需要转化为K是偶数的情况&#xff0c;于是先取一个数&#xff0c;为了使得结果最大&#xff0c;取最大的数&#xff08;正数的话绝对值最大&#xff0c;负数的话(K是奇…

java版工程项目管理系统源码 Spring Cloud+Spring Boot+Mybatis+Vue+ElementUI+前后端分离 功能清单

ava版工程项目管理系统 Spring CloudSpring BootMybatisVueElementUI前后端分离 功能清单如下&#xff1a; 首页 工作台&#xff1a;待办工作、消息通知、预警信息&#xff0c;点击可进入相应的列表 项目进度图表&#xff1a;选择&#xff08;总体或单个&#xff09;项目显示1…

托福高频真词List12 // 附托福TPO阅读真题

目录 4.5单词 生词 熟词 真题 4.5单词 生词 irreversiblepermanentadj.无法挽回的&#xff0c;永久的manipulateskillfully usedhandlev.操控monumentalenormousgreat and significantadj.极大的&#x1f9f8;retardslowv.放缓&#x1f9f8;subsistencesurvivaln.生存 wit…

Redis应用问题及解决

目录 一.缓存穿透 1.1 问题描述 1.2 解决方案 二.缓存击穿 2.1 问题描述 2.2 解决方案 三.缓存雪崩 3.1 问题描述 3.2 解决方案 当数据库压力变大&#xff0c;导致服务访问数据库响应变慢&#xff0c;导致服务的压力变大&#xff0c;最终可能导致服务宕机。 一.缓存穿透 1.1 …

【数据结构】栈与队列经典oj题

&#x1f680;write in front&#x1f680; &#x1f4dc;所属专栏&#xff1a;初阶数据结构 &#x1f6f0;️博客主页&#xff1a;睿睿的博客主页 &#x1f6f0;️代码仓库&#xff1a;&#x1f389;VS2022_C语言仓库 &#x1f3a1;您的点赞、关注、收藏、评论&#xff0c;是对…

[Jenkins自动化] 实现远端linux自动化部署方式(上篇)

目录 本篇文章简介: 简单易上手, 轻松实现jenkins实现自动化部署(上) 1. 安装jenkins方式 -> 1.1 windows版本 --->1.1.1 直接安装 修改安装路径 设置端口号 9000为例 ---> 1.1.2 创建工作空间即可 (起名为pzy) -> 1.2 linux版本(暂无) -> 1.3 docker版…

chapter-4-数据库语句

以下课程来源于MOOC学习—原课程请见&#xff1a;数据库原理与应用 考研复习 概述 SQL发展 注&#xff1a;关键词是哪些功能&#xff0c;尤其第一个create alter drop是定义功能 1.SQL功能强大&#xff0c;实现了数据定义、数据操纵、数据控制等功能 2.SQL语言简洁&#xff…

redis基础总结-常用命令

redis常用指令3. 常用指令3.1 key 操作分析3.1.1 key应该设计哪些操作&#xff1f;3.1.2 key 基本操作3.1.3 key 扩展操作&#xff08;时效性控制&#xff09;3.1.4 key 扩展操作&#xff08;查询模式&#xff09;3.2 数据库指令3.2.1 key 的重复问题3.2.2 解决方案3.2.3 数据库…

Linux Shell 实现一键部署Redis6

redis 前言 Redis&#xff08;Remote Dictionary Server )&#xff0c;即远程字典服务&#xff0c;是一个开源的使用ANSI C语言编写、支持网络、可基于内存亦可持久化的日志型、Key-Value数据库&#xff0c;并提供多种语言的API。 redis 参考 redis下载RedisDesktopManagerd…

ThreadPoolExecutor获取原始异常

ThreadPoolExecutor作用 ThreadPoolTaskExecutor是Spring框架提供的一个线程池实现&#xff0c;它是基于Java的ThreadPoolExecutor实现的。ThreadPoolTaskExecutor可以管理线程池中的线程&#xff0c;以满足多线程并发执行任务的需要。 FutureTask作用 FutureTask的主要作用…

SpringAMQP

SpringAMQP3.SpringAMQP3.1.Basic Queue 简单队列模型3.1.1.消息发送3.1.2.消息接收3.1.3.测试3.2.WorkQueue3.2.1.消息发送3.2.2.消息接收3.2.3.测试3.2.4.能者多劳3.2.5.总结3.3.发布/订阅3.4.Fanout3.4.1.声明队列和交换机3.4.2.消息发送3.4.3.消息接收3.4.4.总结3.5.Direct…

docker

1.docker安装 1.安装docker 2.配置docker加速器 3.docker的基本目录 /etc/docker/ docker的认证目录 /var/lib/docker/ docker的应用目录 2.docker容器 docker image pull nginx docker container stop nginx docker container rm $(docker container ps -aq) #q: --quiet …

代码随想录-62-530. 二叉搜索树的最小绝对差

目录前言题目1.二叉搜索树中序遍历特性介绍&#xff08;并且使用一个指针始终指向前一个&#xff09;全局变量2. 本题思路分析&#xff1a;&#xff08;中序遍历&#xff09;3. 算法实现4. 算法坑点前言 我在刷卡哥的“代码随想录”&#xff0c;自己的总结笔记均会放在“算法刷…

OpenCV基础之边缘检测与轮廓描绘

文章目录OpenCv基础之边缘检测与轮廓描绘Canny边缘检测图像轮廓绘制轮廓OpenCv基础之边缘检测与轮廓描绘 边缘检测&#xff1a;主要是通过一些手段检测数字图像中明暗变化剧烈&#xff08;即梯度变化比较大&#xff09;像素点&#xff0c;偏向于图像中像素点的变化。 轮廓检测…

CAN-FD协议

总目录链接>> AutoSAR入门和实战系列总目录 总目录链接>> AutoSAR BSW高阶配置系列总目录 文章目录CAN-FD协议**CAN-FD协议需要什么&#xff1f;**CAN-FD 协议的属性CAN-FD 协议中的安全性OSI 层中的 CAN-FD**CAN-FD物理层设计**CAN-FD 数据链路层数据链路层的…