php怎樣應對高並發

高並發下的資料安全性

我們知道在多執行緒寫入同一個檔案的時候，會出現「執行緒安全」的問題（多個執行緒同時執行同一段程式碼，如果每次運行結果和單執行緒運行的結果是一樣的，結果和預期相同，就是執行緒安全的）。

如果是MySQL資料庫，可以使用它自帶的鎖定機制很好的解決問題，但在大規模並發的場景中，是不建議使用MySQL的。秒殺和搶購的場景中，最關鍵的問題，就是“超發”，如果在這方面控制不慎，會導致實際產生的訂單比預售商品還多的問題。

超髮的原因：（推薦學習：PHP程式設計從入門到精通）

假設某個搶購場景中，我們一共只有100個商品，在最後一刻，我們已經消耗了99個商品，只剩下最後一個。這時候，系統發來多個並發請求，這批請求讀取到的商品餘裕都是1個，然後都通過了餘量的判斷，最終導致超發。

值得注意的是：記得將庫存欄位number欄位設為unsigned，當庫存為0時，因為unsigned欄位不能為負數，將會傳回false

##最佳化方案

優化1：使用MySQL的事務，鎖定作業的行    BEGIN  ;  SELECT  ...   FOR  UPDATE  ;   COMMIT   ;  ROLLBACK##

<?php
	//优化方案1：使用MySQL的事务，锁住操作的行
	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);
	}
	
	mysqli_query($conn,"BEGIN");  //开始事务
	$sql="select number from ih_store where goods_id=&#39;$goods_id&#39; and sku_id=&#39;$sku_id&#39; FOR UPDATE";//此时这条记录被锁住,其它事务必须等待此次事务提交后才能执行
	$rs=mysqli_query($conn,$sql);
	$row=$rs->fetch_assoc();
	
	if($row[&#39;number&#39;]>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;);
			mysqli_query($conn,"COMMIT");//事务提交即解锁
		}else{
		  echo &#39;库存减少失败&#39;;
			insertLog(&#39;库存减少失败&#39;);
		}
	}else{
		echo &#39;库存不够&#39;;
		insertLog(&#39;库存不够&#39;);
		mysqli_query($conn,"ROLLBACK");
	}

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

<?php
//优化方案2：使用非阻塞的文件排他锁
	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中文網其他相關文章！