摘要：前面寫過利用文件鎖來處理高并發(fā)的問題的，現(xiàn)在我們說另外一個處理方式，利用的鎖來解決高并發(fā)的問題先看沒有利用事務的時候并發(fā)的后果創(chuàng)建庫存管理表創(chuàng)建訂單管理表測試代碼我們預置庫存是十個，然后執(zhí)行測試查看結果

前面寫過利用文件鎖來處理高并發(fā)的問題的，現(xiàn)在我們說另外一個處理方式，利用Mysql的鎖來解決高并發(fā)的問題

先看沒有利用事務的時候并發(fā)的后果

創(chuàng)建庫存管理表

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

創(chuàng)建訂單管理表

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);
    }
}

我們預置庫存是十個，然后執(zhí)行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，這顯然不符合實際邏輯的;

下面我們來看利用數(shù)據庫行鎖來解決這個問題

修改代碼如下

$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鎖之后，對庫存進行了有效的控制，很好的解決了第一段代碼里面，因為并發(fā)引起的一些邏輯性的問題