Jtti广告广告
返回顶部
首页 > 资讯 > 后端开发 > PHP编程 >thinkphp6使用mysql悲观锁解决商品超卖问题的实现
  • 563
分享到

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

thinkphp6 商品超卖thinkphp6 mysql商品超卖 2021-06-14 20:06:24 563人浏览 绘本
摘要

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

悲观介绍(百科):

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

使用场景举例:以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

猜你喜欢
  • mysql实现悲观锁的方法
    这期内容当中小编将会给大家带来有关mysql实现悲观锁的方法,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。简介:悲观锁,正如其名,具有强烈的独占和排他特性。它指的是对数据...
    447
    2023-05-30
    mysql 悲观锁
  • 关于Thinkphp6的日志问题
    目录Thinkphp6的日志问题设置日志记录级别单一日志独立日志日志的写入时机日志通道Thinkphp6异常处理与日志异常处理日志手动记录日志关闭日志总结Thinkphp6的日志问题...
    774
    2023-05-30
    Thinkphp6的日志 Thinkphp6日志 关于Thinkphp6日志
  • mysql 乐观锁和悲观锁的具体使用
    目录悲观锁介绍(百科):1如果不采用锁,那么操作方法如下:2使用悲观锁来实现:补充:mysql select…for update的Row Lock与Table Lock乐观锁介绍:使用举例:以M...
    930
    2023-05-30
    mysql 乐观锁和悲观锁 mysql 乐观锁 mysql 悲观锁
  • mysql 乐观锁和悲观锁的具体使用
    目录悲观锁介绍(百科):1如果不采用锁,那么操作方法如下:2使用悲观锁来实现:补充:MySQL select…for update的Row Lock与Tabl...
    909
    2023-05-30
    mysql 乐观锁和悲观锁 mysql 乐观锁 mysql 悲观锁
  • MySQL悲观锁与乐观锁的实现方案
    目录前言实战 1、无锁2、悲观锁3、乐观锁总结前言 悲观锁和乐观锁是用来解决并发问题的两种思想,在不同的平台有着各自的实现。例如在Java中,synchronized就可以认为是悲观...
    936
    2023-05-30
    mysql悲观锁乐观锁定义 mysql乐观锁实现 mysql悲观锁怎么实现
  • MySQL乐观锁和悲观锁介绍
    乐观锁 乐观锁不是数据库自带的,需要我们自己去实现。乐观锁是指操作数据库时(更新操作),想法很乐观,认为这次的操作不会导致冲突,在操作数据时,并不进行任何其他的特殊处理(也就是不加锁),而在进行更新后,再去...
    673
    2023-05-30
    mysql 介绍 乐观
  • MySQL乐观锁和悲观锁如何实现
    这篇文章主要介绍了MySQL乐观锁和悲观锁如何实现的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇MySQL乐观锁和悲观锁如何实现文章都会有所收获,下面我们一起来看看吧。 ...
    772
    2023-05-30
    mysql
  • 悲观锁与乐观锁怎么在Mysql中使用
    悲观锁与乐观锁怎么在Mysql中使用?针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。悲观锁悲观锁,认为数据是悲观的。当我们查询数据的时候加上...
    279
    2023-05-30
    mysql 悲观锁 乐观锁
  • MySQL中乐观锁和悲观锁的区别
    这篇文章将为大家详细讲解有关MySQL中乐观锁和悲观锁的区别,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。悲观锁在关系数据库管理系统中,悲观并发控制(悲观锁...
    674
    2023-05-30
    mysql 乐观锁 悲观锁
  • MySQL乐观锁和悲观锁具体实现
    目录前言锁分类表结构悲观锁乐观锁适用场景总结前言 对于mysql中的乐观锁和悲观锁,可能很多的开发者还不是很熟悉,并不知道其中具体是如何实现的。本文就针对这个问题做一个实际案例演示,让你彻底明白这两种锁的区别。 锁分类 ...
    469
    2023-05-30
    MySQL乐观锁 MySQL悲观锁
  • Mybatis Generator Plugin悲观锁实现示例
    目录前言实现背景:实现Mybatis悲观锁完整代码前言 Mybatis Generator插件可以快速的实现基础的数据库CRUD操作,它同时支持JAVA语言和Kotlin语言,将程...
    820
    2023-05-30
    Mybatis Generator Plugin悲观锁 Mybatis Generator Plugin
  • 悲观锁,乐观锁的概念
    悲观锁:顾名思义,就是很悲观,它指的是对数据被外界(包括本系统当前的其他事务,以及来自其他事务,以及来自外部系统的事务处理)修改持保守态度,因此,在整个数据处理过程中,将数据处于锁定状态。悲观锁实现,往往依...
    247
    2023-05-30
    数据库
  • Mysql中悲观锁与乐观锁应用介绍
    目录1.锁2.悲观锁3.乐观锁4.如何选择1.锁 ​ 生活中:锁在我们身边无处不在,比如我出门玩去了需要把门锁上,比如我需要把钱放到保险柜里面,必须上锁以保证我财产的安全。 代码中:比如多个线程需要同时操作修改共享变量,...
    748
    2023-05-30
    Mysql悲观锁与乐观锁 Mysql悲观锁 Mysql乐观锁
  • MySQL中乐观锁和悲观锁是什么
    这篇文章给大家分享的是有关MySQL中乐观锁和悲观锁是什么的内容。小编觉得挺实用的,因此分享给大家做个参考。一起跟随小编过来看看吧。数据库管理系统中并发控制的任务是确保在多个事务同时存取数据库中同一数据不破...
    473
    2023-05-30
    mysql 乐观锁 悲观锁
  • 悲观锁和乐观锁是什么
    悲观锁和乐观锁是什么?很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。乐观锁( Optimistic Locking )乐观锁( ...
    341
    2023-05-30
    悲观锁 乐观锁
  • redis乐观锁与悲观锁的实战
    目录概念乐观锁悲观锁乐观锁示例悲观锁示例总结提升概念 Redis是一个内存中的键值存储系统,支持多种数据结构,如字符串、哈希、列表等。Redis提供了两种锁机制,即乐观锁和悲观锁。 乐观锁 乐观锁是一种乐观的并发控制策略...
    899
    2023-05-30
    redis 乐观锁 悲观锁 redis 乐观锁 redis 悲观锁
  • 如何在mysql中使用悲观锁与乐观锁析
    如何在mysql中使用悲观锁与乐观锁析,针对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。一、悲观锁顾名思义,就是对于数据的处理持悲观态度,总认...
    579
    2023-05-30
    mysql
  • 详解Java中的悲观锁与乐观锁
    目录一、悲观锁二、乐观锁三、CAS四、AtomicXXX五、CAS中的ABA问题六、ABA问题解决方案七、使用CAS会引起的问题八、Synchronized锁优化九、偏向锁十、轻量级...
    331
    2023-05-30
    悲观锁与乐观锁 Java锁
  • 什么是悲观锁和乐观锁
    什么是悲观锁和乐观锁?很多新手对此不是很清楚,为了帮助大家解决这个难题,下面小编将为大家详细讲解,有这方面需求的人可以来学习下,希望你能有所收获。 悲观锁(Pessimistic Lock), 顾...
    639
    2023-05-30
    悲观锁 乐观锁
  • Yii框架实现乐观锁与悲观锁流程详解
    目录一、在Yii中实现乐观锁1、在yii中实现乐观锁步骤2、Yii中实现乐观锁3、实现乐观锁二、在Yii中实现悲观锁1、在yii中实现悲观锁的步骤2、yii中悲观锁实现一、在Yii中...
    307
    2023-05-30
    Yii乐观锁与悲观锁 Yii悲观锁 Yii乐观锁
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作