首頁  >  文章  >  後端開發  >  php是怎麼解決高併發的

php是怎麼解決高併發的

王林
王林原創
2019-09-19 17:57:084079瀏覽

php是怎麼解決高併發的

PHP解決高並發問題

我們知道在多執行緒寫入同一個檔案的時候,會存有「執行緒安全」的問題(多個執行緒同時執行同一段程式碼,如果每次執行結果和單執行緒運行的結果是一樣的,結果和預期相同,就是執行緒安全的)。如果是MySQL資料庫,可以使用它自帶的鎖定機制很好的解決問題,但是,在大規模並發的場景中,是不建議使用MySQL的。

秒殺和搶購的場景中,還有另一個問題,就是“超發”,如果在這方面控制不慎,會產生發送過多的情況。我們也曾經聽說過,某些電商搞搶購活動,買家成功拍攝後,商家卻不承認訂單有效,拒絕出貨。這裡的問題,也許不一定是商家姦詐,而是系統技術層面有超發風險所導致的。

1、悲觀鎖定思路

解決線程安全的思路很多,可以從「悲觀鎖」的方向開始討論。

悲觀鎖,也就是在修改資料的時候,採用鎖定狀態,排除外部請求的修改。遇到加鎖的狀態,就必須等待。

php是怎麼解決高併發的

雖然上述的方案的確解決了線程安全的問題,但是,別忘記,我們的場景是「高並發」。也就是說,會很多這樣的修改請求,每個請求都需要等待“鎖”,某些線程可能永遠沒有機會搶到這個“鎖”,這種請求就會死在那裡。

同時,這種請求會很多,瞬間增加系統的平均回應時間,結果是可用連線數被耗盡,系統陷入異常。

2、FIFO佇列思路

那好,那麼我們稍微修改一下上面的場景,我們直接將請求放入佇列中的,採用FIFO(First Input First Output,先進先出),這樣的話,我們就不會導致某些請求永遠取得不到鎖。看到這裡,是不是有點強行把多線程變成單線程的感覺哈。

php是怎麼解決高併發的

然後,我們現在解決了鎖定的問題,全部要求採用「先進先出」的佇列方式來處理。那麼新的問題來了,高並發的場景下,因為請求很多,很可能一瞬間將隊列內存“撐爆”,然後系統又陷入到了異常狀態。

或設計一個極大的記憶體佇列,也是一種方案,但是,系統處理完一個佇列內請求的速度根本無法和瘋狂湧入佇列中的數目相比。也就是說,佇列內的請求會越累積越多,最終Web系統平均回應時候還是會大幅下降,系統還是陷入異常。

3、檔案鎖的想法

對於日IP不高或說並發數不是很大的應用,一般不用考慮這些!用一般的文件操作方法完全沒有問題。但如果並發高,在我們對文件進行讀寫操作時,很有可能多個進程對進一文件進行操作,如果這時不對文件的訪問進行相應的獨佔,就容易造成數據丟失

最佳化方案4:使用非阻塞的檔案排他鎖

<?php
//优化方案4:使用非阻塞的文件排他锁
include (&#39;./mysql.php&#39;);
//生成唯一订单号
function build_order_no(){
  return date(&#39;ymd&#39;).substr(implode(NULL, array_map(&#39;ord&#39;, str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//记录日志
function insertLog($event,$type=0){
    global $conn;
    $sql="insert into ih_log(event,type)
    values(&#39;$event&#39;,&#39;$type&#39;)";
    mysqli_query($conn,$sql);
}
$fp = fopen("lock.txt", "w+");
if(!flock($fp,LOCK_EX | LOCK_NB)){
    echo "系统繁忙,请稍后再试";
    return;
}
//下单
$sql="select number from ih_store where goods_id=&#39;$goods_id&#39; and sku_id=&#39;$sku_id&#39;";
$rs =  mysqli_query($conn,$sql);
$row = $rs->fetch_assoc();
if($row[&#39;number&#39;]>0){//库存是否大于0
    //模拟下单操作
    $order_sn=build_order_no();
    $sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price)
    values(&#39;$order_sn&#39;,&#39;$user_id&#39;,&#39;$goods_id&#39;,&#39;$sku_id&#39;,&#39;$price&#39;)";
    $order_rs =  mysqli_query($conn,$sql);
    //库存减少
    $sql="update ih_store set number=number-{$number} where sku_id=&#39;$sku_id&#39;";
    $store_rs =  mysqli_query($conn,$sql);
    if($store_rs){
      echo &#39;库存减少成功&#39;;
        insertLog(&#39;库存减少成功&#39;);
        flock($fp,LOCK_UN);//释放锁
    }else{
      echo &#39;库存减少失败&#39;;
        insertLog(&#39;库存减少失败&#39;);
    }
}else{
  echo &#39;库存不够&#39;;
    insertLog(&#39;库存不够&#39;);
}
fclose($fp);
 ?>

以上內容僅供參考!

推薦教學:PHP影片教學

#

以上是php是怎麼解決高併發的的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn