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 { /** * 不加锁 * @return string|void */ 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 '请求成功'; } /** * 加锁--悲观锁 * @return string|void */ 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 商品超卖内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
您可能感兴趣的文章:- 使用乐观锁解决超卖问题的代码实现
- java使用mysql和redis如何解决“商品超卖”
- 使用mysql悲观锁解决并发问题
- PHP+Redis链表解决高并发下商品超卖问题(实现原理及步骤)
- 使用Redis中间件解决商品秒杀活动中出现的超卖问题(使用Java多线程模拟高并发环境)
- spring hibernate mysql 使用中的问题及解决方法
- 简单的说一下MYSQL的AA复制和使用MMM解决MYSQL数据复制的问题
- 解决使用MySQL C-API开发应用时的连接超时问题
- 解决 ”不允许在查询中显式构造实体类型“问题及使用其他方法实现返回 List<Model对象>或者IQueryable<Model对象>对象
- 解决Mysql数据量大的时候 分页优化(使用limit)的问题
- windows2008 使用nginx 反向代理实现负载均衡解决HTTPS 证书问题
- 使用面向对象技术解决商品打折问题(一)
- 使用Hibernate和Mysql中文乱码问题解决
- 【C/S通信交互之Http篇】使用Curl与Jetty(Server)实现手机网游Http通信框架&解决curl.h头文件找不到问题
- CKEditor使用js结合CKFinder实现上传,解决项目路径问题
- 使用apache的TelnetClient实现java向telnet服务器发送命令并显示数据(解决乱码问题)
- ThinkPHP框架实现session跨域问题的解决方法
- 安装pdo_mysql 问题[解决阿里云使用wdlinux不支持pdo问题]
- 使用面向对象技术解决商品打折问题(二)
- mysql c++ connector 1.0.5 getString方法 使用过程中遇到汉字产生的乱码问题的解决方法