PHP利用Mysql锁解决高并发的方法

php  /  管理员 发布于 7年前   162

前面写过利用文件锁来处理高并发的问题的，现在我们说另外一个处理方式，利用Mysql的锁来解决高并发的问题

先看没有利用事务的时候并发的后果

创建库存管理表

CREATE TABLE `storage` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `number` int(11) DEFAULT NULL, PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=latin1

创建订单管理表

CREATE TABLE `order` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `number` int(11) DEFAULT NULL, PRIMARY KEY (`id`)) ENGINE=InnoDB AUTO_INCREMENT=34 DEFAULT CHARSET=latin1

测试代码

$pdo = new PDO('mysql:host=127.0.0.1;port=3306; dbname=test','root','123456');$sql="select `number` from storage where id=1 limit 1";$res = $pdo->query($sql)->fetch();$number = $res['number'];if($number>0){  $sql ="insert into `order` VALUES (null,$number)";    $order_id = $pdo->query($sql);  if($order_id)  {    $sql="update storage set `number`=`number`-1 WHERE id=1";    $pdo->query($sql);  }}

我们预置库存是十个，然后执行ab测试查看结果

mysql> select * from storage  -> ;+----+--------+| id | number |+----+--------+| 1 |   -2 |+----+--------+1 row in set (0.00 sec)mysql> select * from `order`;+----+--------+| id | number |+----+--------+| 22 |   10 || 23 |   10 || 24 |   8 || 25 |   8 || 26 |   7 || 27 |   6 || 28 |   4 || 29 |   3 || 30 |   2 || 31 |   2 || 32 |   2 || 33 |   1 |+----+--------+12 rows in set (0.00 sec)

得到了订单共有12个，而库存表的库存也减到了-2，这显然不符合实际逻辑的;

下面我们来看利用数据库行锁来解决这个问题

修改代码如下

$pdo = new PDO('mysql:host=127.0.0.1;port=3306; dbname=test','root','123456');$pdo->beginTransaction();//开启事务$sql="select `number` from storage where id=1 for UPDATE ";//利用for update 开启行锁$res = $pdo->query($sql)->fetch();$number = $res['number'];if($number>0){  $sql ="insert into `order` VALUES (null,$number)";  $order_id = $pdo->query($sql);  if($order_id)  {    $sql="update storage set `number`=`number`-1 WHERE id=1";    if($pdo->query($sql))    {      $pdo->commit();//提交事务    }    else    {      $pdo->rollBack();//回滚    }  }  else  {    $pdo->rollBack();//回滚  }}

查看结果

mysql> select * from storage;+----+--------+| id | number |+----+--------+| 1 |   0 |+----+--------+1 row in set (0.00 sec)mysql> select * from `order`;+----+--------+| id | number |+----+--------+| 1 |   10 || 2 |   9 || 3 |   8 || 4 |   7 || 5 |   6 || 6 |   5 || 7 |   4 || 8 |   3 || 9 |   2 || 10 |   1 |+----+--------+10 rows in set (0.00 sec)

很明显在利用了mysql锁之后，对库存进行了有效的控制，很好的解决了第一段代码里面，因为并发引起的一些逻辑性的问题

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

您可能感兴趣的文章:

• Mysql查询正在执行的事务以及等待锁的操作方式
• 基于更新SQL语句理解MySQL锁定详解
• PHP+MySQL高并发加锁事务处理问题解决方法
• MySQL锁机制与用法分析
• MySQL如何查看元数据锁阻塞在哪里
• MySQL语句加锁的实现分析
• Mysql使用kill命令解决死锁问题(杀死某条正在执行的sql语句)
• MYSQL 解锁与锁表介绍
• 一次Mysql死锁排查过程的全纪录
• MySQL对于各种锁的概念理解