您好,登錄后才能下訂單哦!
本篇文章為大家展示了PHP中并發(fā)問(wèn)題的解決方法,代碼簡(jiǎn)明扼要并且容易理解,絕對(duì)能使你眼前一亮,通過(guò)這篇文章的詳細(xì)介紹希望你能有所收獲。
1、使用隊(duì)列,額外起一個(gè)進(jìn)程處理隊(duì)列,并發(fā)請(qǐng)求都放到隊(duì)列中,由額外進(jìn)程串行處理,并發(fā)問(wèn)題就不存在了,但是要額外進(jìn)程支持以及處理延遲嚴(yán)重,本文不先不討論這種方法。
2、利用數(shù)據(jù)庫(kù)事務(wù)特征,做原子更新,此方法需要依賴數(shù)據(jù)庫(kù)的事務(wù)特性。
3、借助文件排他鎖,在處理下單請(qǐng)求的時(shí)候,用flock鎖定一個(gè)文件,成功拿到鎖的才能處理訂單。
一、利用 Redis 事務(wù)特征
redis 事務(wù)是原子操作,可以保證訂單處理的過(guò)程中數(shù)據(jù)沒(méi)有被其它并發(fā)的進(jìn)程修改。
示例代碼:
<?php $http = new swoole_http_server("0.0.0.0", 9509); // 監(jiān)聽(tīng) 9509 $http->set(array( 'reactor_num' => 2, //reactor thread num 'worker_num' => 4 //worker process num )); $http->on('request', function (swoole_http_request $request, swoole_http_response $response) { $uniqid = uniqid('uid-', TRUE); // 模擬唯一用戶ID $redis = new Redis(); $redis->connect('127.0.0.1', 6379); // 連接 redis $redis->watch('rest_count'); // 監(jiān)測(cè) rest_count 是否被其它的進(jìn)程更改 $rest_count = intval($redis->get("rest_count")); // 模擬唯一訂單ID if($rest_count > 0){ $value = "{$rest_count}-{$uniqid}"; // 表示當(dāng)前訂單,被當(dāng)前用戶搶到了 // do something ... 主要是模擬用戶搶到單后可能要進(jìn)行的一些密集運(yùn)算 $rand = rand(100, 1000000); $sum=0; for ($i=0;$i<$rand;$i++){ $sum+=$i; } // redis 事務(wù) $redis->multi(); $redis->lPush('uniqids', $value); $redis->decr('rest_count'); $replies = $redis->exec(); // 執(zhí)行以上 redis 事務(wù) // 如果 rest_count 的值被其它的并發(fā)進(jìn)程更改了,以上事務(wù)將回滾 if(!$replies){ echo "訂單 {$value} 回滾".PHP_EOL; } } $redis->unwatch(); }); $http->start();
使用 ab 測(cè)試
$ ab -t 20 -c 10 http://192.168.1.104:9509/
二、利用文件排他鎖(阻塞模式)
阻塞模式下,如果進(jìn)程在獲取文件排他鎖時(shí),其它進(jìn)程正在占用鎖的話,此進(jìn)程會(huì)掛起等待其它進(jìn)程釋放鎖后,并自己獲取到鎖后,再往下執(zhí)行。
示例代碼:
<?php $http = new swoole_http_server("0.0.0.0", 9510); $http->set(array( 'reactor_num' => 2, //reactor thread num 'worker_num' => 4 //worker process num )); $http->on('request', function (swoole_http_request $request, swoole_http_response $response) { $uniqid = uniqid('uid-', TRUE); $redis = new Redis(); $redis->connect('127.0.0.1', 6379); $fp = fopen("lock.txt", "w+"); // 阻塞(等待)模式, 要取得獨(dú)占鎖定(寫入的程序) if(flock($fp,LOCK_EX)) //鎖定當(dāng)前指針 { // 成功取得鎖后,放心處理訂單 $rest_count = intval($redis->get("rest_count")); $value = "{$rest_count}-{$uniqid}"; if($rest_count > 0){ // do something ... $rand = rand(100, 1000000); $sum=0; for ($i=0;$i<$rand;$i++){ $sum+=$i; } $redis->lPush('uniqids', $value); $redis->decr('rest_count'); } // 訂單處理完成后,再釋放鎖 flock($fp,LOCK_UN); } fclose($fp); }); $http->start();
使用 ab 測(cè)試
$ ab -t 20 -c 10 http://192.168.1.104:9510/
上述內(nèi)容就是PHP中并發(fā)問(wèn)題的解決方法,你們學(xué)到知識(shí)或技能了嗎?如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備,歡迎關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。