mysql處理高并發(fā)，防止庫(kù)存超賣

????????先來(lái)就庫(kù)存超賣的問(wèn)題作描述：一般電子商務(wù)網(wǎng)站都會(huì)遇到如團(tuán)購(gòu)、秒殺、特價(jià)之類的活動(dòng)，而這樣的活動(dòng)有一個(gè)共同的特點(diǎn)就是訪問(wèn)量激增、上千甚至上萬(wàn)人搶購(gòu)一個(gè)商品。然而，作為活動(dòng)商品，庫(kù)存肯定是很有限的，如何控制庫(kù)存不讓出現(xiàn)超買，以防止造成不必要的損失是眾多電子商務(wù)網(wǎng)站程序員頭疼的問(wèn)題，這同時(shí)也是最基本的問(wèn)題。

從技術(shù)方面剖析，很多人肯定會(huì)想到事務(wù)，但是事務(wù)是控制庫(kù)存超賣的必要條件，但不是充分必要條件。

舉例：

總庫(kù)存：4個(gè)商品

請(qǐng)求人：a、1個(gè)商品 b、2個(gè)商品 c、3個(gè)商品

程序如下：

beginTranse(開(kāi)啟事務(wù))

try{

??? $result = $dbca->query('select amount from s_store where postID = 12345');

??? if(result->amount > 0){

????????//quantity為請(qǐng)求減掉的庫(kù)存數(shù)量

????????$dbca->query('update s_store set amount = amount -?quantity?where postID = 12345');

????}

}catch($e Exception){

????rollBack(回滾)

}

commit(提交事務(wù))

????

????以上代碼就是我們平時(shí)控制庫(kù)存寫(xiě)的代碼了，大多數(shù)人都會(huì)這么寫(xiě)，看似問(wèn)題不大，其實(shí)隱藏著巨大的漏洞。數(shù)據(jù)庫(kù)的訪問(wèn)其實(shí)就是對(duì)磁盤(pán)文件的訪問(wèn)，數(shù)據(jù)庫(kù)中的表其實(shí)就是保存在磁盤(pán)上的一個(gè)個(gè)文件，甚至一個(gè)文件包含了多張表。例如由于高并發(fā)，當(dāng)前有三個(gè)用戶a、b、c三個(gè)用戶進(jìn)入到了這個(gè)事務(wù)中，這個(gè)時(shí)候會(huì)產(chǎn)生一個(gè)共享鎖，所以在select的時(shí)候，這三個(gè)用戶查到的庫(kù)存數(shù)量都是4個(gè)，同時(shí)還要注意，mysql innodb查到的結(jié)果是有版本控制的，再其他用戶更新沒(méi)有commit之前(也就是沒(méi)有產(chǎn)生新版本之前)，當(dāng)前用戶查到的結(jié)果依然是就版本；

????然后是update，假如這三個(gè)用戶同時(shí)到達(dá)update這里，這個(gè)時(shí)候update更新語(yǔ)句會(huì)把并發(fā)串行化，也就是給同時(shí)到達(dá)這里的是三個(gè)用戶排個(gè)序，一個(gè)一個(gè)執(zhí)行，并生成排他鎖，在當(dāng)前這個(gè)update語(yǔ)句commit之前，其他用戶等待執(zhí)行，commit后，生成新的版本；這樣執(zhí)行完后，庫(kù)存肯定為負(fù)數(shù)了。但是根據(jù)以上描述，我們修改一下代碼就不會(huì)出現(xiàn)超買現(xiàn)象了，代碼如下：

beginTranse(開(kāi)啟事務(wù))

try{

????//quantity為請(qǐng)求減掉的庫(kù)存數(shù)量
??? $dbca->query('update s_store set amount = amount -?quantity?where postID = 12345');

??? $result = $dbca->query('select amount from s_store where postID = 12345');

??? if(result->amount < 0){

?????? throw new Exception('庫(kù)存不足');

????}

}catch($e Exception){

????rollBack(回滾)

}

commit(提交事務(wù))

?

另外，更簡(jiǎn)潔的方法：

beginTranse(開(kāi)啟事務(wù))

try{

????//quantity為請(qǐng)求減掉的庫(kù)存數(shù)量
??? $dbca->query('update s_store set amount = amount -?quantity?where?amount>=quantity and?postID = 12345');

}catch($e Exception){

????rollBack(回滾)

}

commit(提交事務(wù))