前面寫過利用文件鎖來處理高并發的問題的，現在我們說另外一個處理方式，利用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鎖之后，對庫存進行了有效的控制，很好的解決了第一段代碼里面，因為并發引起的一些邏輯性的問題
以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
您可能感興趣的文章:- php多進程并發編程防止出現僵尸進程的方法分析
- PHP高并發和大流量解決方案整理
- PHP 并發場景的幾種解決方案
- PHP下用Swoole實現Actor并發模型的方法
- php多進程模擬并發事務產生的問題小結
- PHP curl批處理及多請求并發實現方法分析
- php curl批處理實現可控并發異步操作示例
- PHP使用curl_multi實現并發請求的方法示例
- 詳解PHP服務器如何在有限的資源里最大提升并發能力
