PHP利用Mysql鎖解決高并發(fā)的方法

第PHP利用Mysql鎖解決高并發(fā)的方法前面寫過(guò)利用文件鎖來(lái)處理高并發(fā)的問(wèn)題的，現(xiàn)在我們說(shuō)另外一個(gè)處理方式，利用Mysql的鎖來(lái)解決高并發(fā)的問(wèn)題

先看沒(méi)有利用事務(wù)的時(shí)候并發(fā)的后果

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

CREATETABLE`storage`(

`id`int(11)unsignedNOTNULLAUTO_INCREMENT,

`number`int(11)DEFAULTNULL,

PRIMARYKEY(`id`)

)ENGINE=InnoDBAUTO_INCREMENT=2DEFAULTCHARSET=latin1

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

CREATETABLE`order`(

`id`int(11)unsignedNOTNULLAUTO_INCREMENT,

`number`int(11)DEFAULTNULL,

PRIMARYKEY(`id`)

)ENGINE=InnoDBAUTO_INCREMENT=34DEFAULTCHARSET=latin1

測(cè)試代碼

$pdo=newPDO('mysql:host=127.0.0.1;port=3306;dbname=test','root','123456');

$sql="select`number`fromstoragewhereid=1limit1";

$res=$pdo-query($sql)-fetch();

$number=$res['number'];

if($number0)

$sql="insertinto`order`VALUES(null,$number)";

$order_id=$pdo-query($sql);

if($order_id)

$sql="updatestorageset`number`=`number`-1WHEREid=1";

$pdo-query($sql);

我們預(yù)置庫(kù)存是十個(gè)，然后執(zhí)行ab測(cè)試查看結(jié)果

mysqlselect*fromstorage

+----+--------+

|id|number|

+----+--------+

|1|-2|

+----+--------+

1rowinset(0.00sec)

mysqlselect*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|

+----+--------+

12rowsinset(0.00sec)

得到了訂單共有12個(gè)，而庫(kù)存表的庫(kù)存也減到了-2，這顯然不符合實(shí)際邏輯的;

下面我們來(lái)看利用數(shù)據(jù)庫(kù)行鎖來(lái)解決這個(gè)問(wèn)題

修改代碼如下

$pdo=newPDO('mysql:host=127.0.0.1;port=3306;dbname=test','root','123456');

$pdo-beginTransaction();//開(kāi)啟事務(wù)

$sql="select`number`fromstoragewhereid=1forUPDATE";//利用forupdate開(kāi)啟行鎖

$res=$pdo-query($sql)-fetch();

$number=$res['number'];

if($number0)

$sql="insertinto`order`VALUES(null,$number)";

$order_id=$pdo-query($sql);

if($order_id)

$sql="updatestorageset`number`=`number`-1WHEREid=1";

if($pdo-query($sql))

$pdo-commit();//提交事務(wù)

else

$pdo-rollBack();//回滾

else

$pdo-rollBack();//回滾

查看結(jié)果

mysqlselect*fromstorage;

+----+--------+

|id|number|

+----+--------+

|1|0|

+----+------

1rowinset(0.00sec)

mysqlselect*from`order`;

+----+--------+

|id|number|

+----+--------+

|1|10|

|2|9|

|3|8|

|4|7|

|5|6|

|6|5|

|7|4|

|8|3|

|9|2|

|10|1|

+----+--------+

10rows