thinkphp6使用mysql悲观锁解决商品超卖问题的实现

悲观介绍(百科):

悲观锁,正如其名,它指的是对数据被外界(包括本系统当前的其他事务,以及来自外部系统的事务处理)修改持保守态度,因此,在整个数据处理过程中,将数据处于锁定状态。悲观锁的实现,往往依靠数据库提供的锁机制(也只有数据库层提供的锁机制才能真正保证数据访问的排他性,否则,即使在本系统中实现了加锁机制,也无法保证外部系统不会修改数据)。

使用场景举例:以Mysql InnoDB为例

商品Goods表,假设商品的id为1,购买数量为1,status为1表示上架中,2表示下架。现在用户购买此商品,在不是高并发的情况下处理逻辑是:

  • 查找此商品的信息;
  • 检查商品库存是否大于购买数量;
  • 修改商品库存和销量;

上面这种场景在高并发访问的情况下很可能会出现问题。如果商品库存是100个,高并发的情况下可能会有1000个同时访问,在到达第2步的时候,都会检测通过。这样会出现商品库存是-900个的情况。显然着不满足需求!!!

商品表结构:


CREATE TABLE `goods` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(100) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',
  `status` tinyint(1) NOT NULL DEFAULT '1',
  `total` int(11) NOT NULL DEFAULT '0',
  `sell` int(11) NOT NULL DEFAULT '100',
  `price` decimal(10,2) NOT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;
 
INSERT INTO `test`.`goods`(`id`, `name`, `status`, `total`, `sell`, `price`) VALUES (1, '商品', 1, 0, 100, 15.00);

订单表结构:


CREATE TABLE `orders` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `uid` int(11) NOT NULL DEFAULT '0',
  `create_time` datetime NOT NULL,
  `status` tinyint(1) NOT NULL DEFAULT '1',
  `goods_id` int(11) NOT NULL DEFAULT '0',
  `order_no` varchar(200) COLLATE utf8_unicode_ci NOT NULL DEFAULT '',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COLLATE=utf8_unicode_ci;

使用悲观锁处理。

当我们在查询出goods信息后就把当前的数据锁定,直到我们修改完毕后再解锁。那么在这个过程中,因为goods被锁定了,就不会出现有第三者来对其进行修改了。

注:要使用悲观锁,我们必须关闭mysql数据库的自动提交属性,因为MySQL默认使用autocommit模式,也就是说,当你执行一个更新操作后,MySQL会立刻将结果进行提交。thinkphp6中使用事务,手动进行提交回滚。


<?PHP
 
namespace app\controller;
 
use app\BaseController;
use think\facade\Db;
 
class Test extends BaseController
{
 
    
    public function test_1()
    {
        $num = 1;
        $goods_id = 1;
        Db::startTrans();
        try {
            $where = [];
            $where['id'] = $goods_id;
            $where['status'] = 1;
            $goods_info = Db::table('goods')->where($where)->find();
            if (empty($goods_info)) {
                return '商品不存在';
            }
            $total = $goods_info['total'];
            $sell = $goods_info['sell'];
            if ($total < $num) {
                return '库存不足';
            }
            $data['total'] = $total-$num;
            $data['sell'] = $sell+$num;
            $res = Db::table('goods')->where(['id'=>$goods_id])->update($data);
            $order_data = [];
            $order_data['uid'] = rand(1000,9999);
            $order_data['status'] = 1;
            $order_data['create_time'] = date('Y-m-d H:i:s');
            $order_data['goods_id'] = $goods_id;
            $order_data['order_no'] = date('YmdHis').rand(1000,10000);
            $order_res = Db::table('orders')->insert($order_data);
            Db::commit();
        } catch (\Exception $e) {
            // 回滚事务
            Db::rollback();
            echo $e->getMessage();
            exit('rollback');
        }
        echo '请求成功';
    }
 
    
    public function test_2()
    {
        $num = 1;
        $goods_id = 1;
        Db::startTrans();
        try {
            $where = [];
            $where['id'] = $goods_id;
            $where['status'] = 1;
            $goods_info = Db::table('goods')->lock(true)->where($where)->find();
            if (empty($goods_info)) {
                return '商品不存在';
            }
            $total = $goods_info['total'];
            $sell = $goods_info['sell'];
            if ($total < $num) {
                return '库存不足';
            }
            $data['total'] = $total-$num;
            $data['sell'] = $sell+$num;
            $res = Db::table('goods')->where(['id'=>$goods_id])->update($data);
            $order_data = [];
            $order_data['uid'] = rand(1000,9999);
            $order_data['status'] = 1;
            $order_data['goods_id'] = $goods_id;
            $order_data['order_no'] = date('YmdHis').rand(1000,10000);
            $order_data['create_time'] = date('Y-m-d H:i:s');
            $order_res = Db::table('orders')->insert($order_data);
            Db::commit();
        } catch (\Exception $e) {
            // 回滚事务
            Db::rollback();
            echo $e->getMessage();
            exit('rollback');
 
        }
        echo '请求成功';
    }
 
}

使用jmeter工具测试,创建线程测试组:

关于使用jmeter创建测试高并发例子,可查看:使用JMeter进行高并发测试_左右..的博客-CSDN博客_jmeter高并发测试

这里模拟1s内1000个用户同时访问

 创建Http请求:

添加察看结果树:

 测试开始:

100个商品不加锁的结果:

100个商品库存,生成订单187个,超卖87个商品,这在项目开发中是绝对不允许的。

100个商品,加锁结果:

 加锁,得到解决。

到此这篇关于thinkphp6使用mysql悲观锁解决商品超卖问题的实现的文章就介绍到这了,更多相关thinkphp6 商品超卖内容请搜索编程界以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程界!

--结束END--

本文标题: thinkphp6使用mysql悲观锁解决商品超卖问题的实现

本文链接: https://www.lsjlt.com/news/49.html (转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

猜你喜欢

  • thinkphp6使用mysql悲观锁解决商品超卖问题的实现

    悲观锁介绍(百科):悲观锁,正如其名,它指的是对数据被外界(包括本系统当前的其他事务,以及来自外部系统的事务处理)修改持保守态度,因此,在整个数据处理过程中,将数据处于锁定状态。悲观锁的实现,往往依靠数据库提供的锁机制(也只有数据库层提供的锁机制才能真正保证数
  • Redis分布式锁解决秒杀超卖问题

    目录分布式锁应用场景单体锁的分类分布式锁核心逻辑分布式锁实现的问题——死锁和解决Redihttp://www.cppcns.coms解决删除别人锁的问题分布式锁应用场景秒杀环境下:订单服务从库存中心拿到库存数,如果库
  • Redis实现库存扣减的解决方案防止商品超卖

    在日常开发中有很多地方都有类似扣减库存的操作,比如电商系统中的商品库存,抽奖系统中的奖品库存等,基于redis实现扣减库存的具体实现,初始化库存回调函数(IStockCallback)扣减库存服务(StockService),感兴趣的朋友跟随小编一起看看吧
  • Redis中秒杀场景下超时与超卖问题的解决方案

    当我们在linux中使用ab来模拟高并发秒杀时可能会遇到两种问题,“超时和超卖”,本文就详细介绍了Redis中秒杀场景下超时与超卖问题的解决方案,感兴趣的可以了解一下
    阅读数:610 Redis 超时 Redis 超卖
  • 解决redis秒杀超卖的问题

    小编给大家分享一下解决redis秒杀超卖的问题,希望大家阅读完这篇文章后大所收获,下面让我们一起去探讨吧!首先,生成库存的计数量 public function kucun(){//有十个库存$count=10;//添加到redis lis
    阅读数:546 redis edi %d
  • IE6 position:fixed问题的解决方法

    IE6 position:fixed问题的解决方法,很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。向大家简单介绍一下解决IE6下position:fixed问题方
    阅读数:529 ie6 position fixed
  • PHP高并发情况下防止商品库存超卖

    商城系统中,抢购和秒杀是很常见的营销场景,在一定时间内有大量的用户访问商场下单,主要需要解决的问题有两个:1. 高并发对数
    阅读数:0 php 并发
  • 解决JS问题的ES6方法有哪些

    本篇内容介绍了“解决JS问题的ES6方法有哪些”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!1、如何隐藏所有指定的元素: const hid
    阅读数:230 es6 js
  • Thinkphp6.0中间件的具体使用

    目录全局中间件应用中间件路由中间件控制器中间件中间件传参6.0中间件分为系统中间件和应用中间件,系统中间件为核心框架内置的中间件,应用中间件是在应用里面创建的中间件。中间件的主要应用场景可以包括对HTTP请求的数据过滤、权限检测、请求拦截等行为,使用中间件能够
  • ie6下position:absolute属性不显示问题的解决方法

    本篇内容介绍了“ie6下position:absolute属性不显示问题的解决方法”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!在其它版本我
    阅读数:517 ie6 position
  • mysql处理高并发,防止库存超卖

    一般电子商务网站都会遇到如团购、秒杀、特价之类的活动,而这样的活动有一个共同的特点就是访问量激增、上千甚至上万人抢购一个商品。然而,作为活动商品,库存肯定是很有限的,如何控制库存不让出现超买,以防止造成不必要的损失是众多电子商务网站程序员头疼的问题,这同时也是
  • 6. 锁

    开发多用户、数据库驱动的应用时,最大的难点是:一方面要最大程度的利用数据库的并发访问,一方面还要确保每个用户能以一致的方式读取和修改数据,为此有了锁的机制。6.1 什么是锁锁机制用于管理对共享资源的并发访问。InnoDB除了会在行级别上对表数据上锁,也会在数据
    阅读数:327 6.
  • IE6、IE7、Firefox中margin问题的解决办法是什么

    这期内容当中小编将会给大家带来有关IE6、IE7、Firefox中margin问题的解决办法是什么,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。你对IE6/IE7/Firefox的margin问题解决办法
    阅读数:736 ie margin firefox
  • Mysql处理Duplicateentry‘6‘forkey‘PRIMARY‘问题及解决

    这篇文章主要介绍了Mysql处理Duplicateentry‘6‘forkey‘PRIMARY‘问题及解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
  • ES6箭头函数中this问题的示例分析

    小编给大家分享一下ES6箭头函数中this问题的示例分析,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!简要介绍:箭头函数中的this,指向与一般function定
    阅读数:483 es6 this
  • Android Studio 3.6运行模拟器时Emulator警告问题的解决方案

    手贱更新了android studio过后,编译不报错,只要启动模拟器就会报出两行emulator警告,关掉模拟器也会有警告,之前版本用的都好好的,怎么消除警告问题?Emulator: emulator: WARNING: Emulato
  • Spring Boot 2.6.x整合Swagger启动失败报错问题的完美解决办法

    这篇文章主要给大家介绍了关于Spring Boot 2.6.x整合Swagger启动失败报错问题的完美解决办法,文中通过实例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
  • 怎么使用mysql 5.6 information schema定位事务锁信息

    这篇文章将为大家详细讲解有关怎么使用mysql 5.6 information schema定位事务锁信息,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。引子mysql数据库在运行期间,随着业务体量增
    阅读数:724 information mysql schema
  • 解决IE6兼容性问题的常见方法有哪些

    今天就跟大家聊聊有关解决IE6兼容性问题的常见方法有哪些,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。解决IE6兼容性问题常见方法1、使用声明你必须经常在html网页头部放置一个声明
    阅读数:887 ie6
  • Thinkphp开源框架如何使用?

    (一)首先是准备工作下载thinkPHP框架最新版本,解压缩到你将要开发的项目位置。操作演示如图:  其中index.php是入口文件,即所有的请求都要经过此文件才能够完成。Application 是应用目录,在开发过程中,我们手动要操作的
    阅读数:883 开发 文件夹 如何