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

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

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

创建库存管理表

创建订单管理表

测试代码

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测试查看结果

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,这显然不符合实际逻辑的;

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

修改代码如下

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();//回滚
}
}

查看结果

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锁之后,对库存进行了有效的控制,很好的解决了第一段代码里面,因为并发引起的一些逻辑性的问题

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

相关文章

如何选择合适的 C++ Web 开发框架?
利用 C++ 框架构建高并发 Web 应用的策略
用 C++ 框架开发跨平台图形应用程序
golang框架中安全编码实践的最佳指南是什么?
golang框架与其他语言框架在设计理念上的区别有哪些?
C++ 图形框架与其他语言框架的比较