php 高併發下 秒殺處理思路

時間  2019-12-19
標籤 php 併發 秒殺 處理 思路 欄目 PHP 简体版
原文   原文鏈接

1.用額外的單進程處理一個隊列，下單請求放到隊列裏，一個個處理，就不會有併發的問題了，可是要額外的後臺進程以及延遲問題，不予考慮。php

2.數據庫樂觀鎖，大體的意思是先查詢庫存，而後立馬將庫存+1，而後訂單生成後，在更新庫存前再查詢一次庫存，看看跟預期的庫存數量是否保持一致，不一致就回滾，提示用戶庫存不足。mysql

3.根據update結果來判斷，咱們能夠在sql2的時候加一個判斷條件update ... where 庫存>0，若是返回false，則說明庫存不足，並回滾事務。面試

4.藉助文件排他鎖，在處理下單請求的時候，用flock鎖定一個文件，若是鎖定失敗說明有其餘訂單正在處理，此時要麼等待要麼直接提示用戶"服務器繁忙"ajax

 

搶購、秒殺是日常很常見的場景，面試的時候面試官也常常會問到，好比問你淘寶中的搶購秒殺是怎麼實現的等等。

搶購、秒殺實現很簡單，可是有些問題須要解決，主要針對兩個問題：

1、高併發對數據庫產生的壓力
2、競爭狀態下如何解決庫存的正確減小（"超賣"問題）

第一個問題，對於PHP來講很簡單，用緩存技術就能夠緩解數據庫壓力，好比memcache，redis等緩存技術。
第二個問題就比較複雜點：

常規寫法：
查詢出對應商品的庫存，看是否大於0，而後執行生成訂單等操做，可是在判斷庫存是否大於0處，若是在高併發下就會有問題，致使庫存量出現負數。redis

<?php
$conn=mysql_connect("localhost","big","123456");
if(!$conn){
echo "connect failed";
exit;
}
mysql_select_db("big",$conn);
mysql_query("set names utf8");

$price=10;
$user_id=1;
$goods_id=1;
$sku_id=11;
$number=1;

//生成惟一訂單
function build_order_no(){
return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//記錄日誌
function insertLog($event,$type=0){
global $conn;
$sql="insert into ih_log(event,type)
values('$event','$type')";
mysql_query($sql,$conn);
}

//模擬下單操做
//庫存是否大於0
$sql="select number from ih_store where goods_id='$goods_id' and sku_id='$sku_id'";
//解鎖 此時ih_store數據中goods_id='$goods_id' and sku_id='$sku_id' 的數據被鎖住(注3)，其它事務必須等待這次事務 提交後才能執行
$rs=mysql_query($sql,$conn);
$row=mysql_fetch_assoc($rs);
if($row['number']>0){//高併發下會致使超賣
$order_sn=build_order_no();
//生成訂單
$sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price)
values('$order_sn','$user_id','$goods_id','$sku_id','$price')";
$order_rs=mysql_query($sql,$conn);

//庫存減小
$sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog('庫存減小成功');
}else{
insertLog('庫存減小失敗');
}
}else{
insertLog('庫存不夠');
}sql

出現這種狀況怎麼辦呢？來看幾種優化方法：

優化方案1：將庫存字段number字段設爲unsigned，當庫存爲0時，由於字段不能爲負數，將會返回false數據庫

//庫存減小
$sql="update ih_store set number=number-{$number} where sku_id='$sku_id' and number>0";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog('庫存減小成功');
}緩存

優化方案2：使用MySQL的事務，鎖住操做的行服務器

<?php
$conn=mysql_connect("localhost","big","123456");
if(!$conn){
echo "connect failed";
exit;
}
mysql_select_db("big",$conn);
mysql_query("set names utf8");

$price=10;
$user_id=1;
$goods_id=1;
$sku_id=11;
$number=1;

//生成惟一訂單號
function build_order_no(){
return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//記錄日誌
function insertLog($event,$type=0){
global $conn;
$sql="insert into ih_log(event,type)
values('$event','$type')";
mysql_query($sql,$conn);
}

//模擬下單操做
//庫存是否大於0
mysql_query("BEGIN"); //開始事務
$sql="select number from ih_store where goods_id='$goods_id' and sku_id='$sku_id' FOR UPDATE";//此時這條記錄被鎖住,其它事務必須等待這次事務提交後才能執行
$rs=mysql_query($sql,$conn);
$row=mysql_fetch_assoc($rs);
if($row['number']>0){
//生成訂單
$order_sn=build_order_no();
$sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price)
values('$order_sn','$user_id','$goods_id','$sku_id','$price')";
$order_rs=mysql_query($sql,$conn);

//庫存減小
$sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog('庫存減小成功');
mysql_query("COMMIT");//事務提交即解鎖
}else{
insertLog('庫存減小失敗');
}
}else{
insertLog('庫存不夠');
mysql_query("ROLLBACK");
}併發

複製代碼

優化方案3：使用非阻塞的文件排他鎖

<?php
$conn=mysql_connect("localhost","root","123456");
if(!$conn){
echo "connect failed";
exit;
}
mysql_select_db("big-bak",$conn);
mysql_query("set names utf8");

$price=10;
$user_id=1;
$goods_id=1;
$sku_id=11;
$number=1;

//生成惟一訂單號
function build_order_no(){
return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//記錄日誌
function insertLog($event,$type=0){
global $conn;
$sql="insert into ih_log(event,type)
values('$event','$type')";
mysql_query($sql,$conn);
}

$fp = fopen("lock.txt", "w+");
if(!flock($fp,LOCK_EX | LOCK_NB)){
echo "系統繁忙，請稍後再試";
return;
}
//下單
$sql="select number from ih_store where goods_id='$goods_id' and sku_id='$sku_id'";
$rs=mysql_query($sql,$conn);
$row=mysql_fetch_assoc($rs);
if($row['number']>0){//庫存是否大於0
//模擬下單操做
$order_sn=build_order_no();
$sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price)
values('$order_sn','$user_id','$goods_id','$sku_id','$price')";
$order_rs=mysql_query($sql,$conn);

//庫存減小
$sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog('庫存減小成功');
flock($fp,LOCK_UN);//釋放鎖
}else{
insertLog('庫存減小失敗');
}
}else{
insertLog('庫存不夠');
}
fclose($fp);

複製代碼

優化方案4：使用redis隊列，由於pop操做是原子的，即便有不少用戶同時到達，也是依次執行，推薦使用（mysql事務在高併發下性能降低很厲害，文件鎖的方式也是）
先將商品庫存如隊列

<?php
$store=1000;
$redis=new Redis();
$result=$redis->connect('127.0.0.1',6379);
$res=$redis->llen('goods_store');
echo $res;
$count=$store-$res;
for($i=0;$i<$count;$i++){
$redis->lpush('goods_store',1);
}
echo $redis->llen('goods_store');

搶購、描述邏輯
  1. <?php
  2. $conn=mysql_connect("localhost","big","123456");
  3. if(!$conn){
  4.     echo "connect failed";
  5.     exit;
  6. }
  7. mysql_select_db("big",$conn);
  8. mysql_query("set names utf8");
  9.   
  10. $price=10;
  11. $user_id=1;
  12. $goods_id=1;
  13. $sku_id=11;
  14. $number=1;
  15.   
  16. //生成惟一訂單號
  17. function build_order_no(){
  18.   return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
  19. }
  20. //記錄日誌
  21. function insertLog($event,$type=0){
  22.     global $conn;
  23.     $sql="insert into ih_log(event,type)
  24.     values('$event','$type')";
  25.     mysql_query($sql,$conn);
  26. }
  27.   
  28. //模擬下單操做
  29. //下單前判斷redis隊列庫存量
  30. $redis=new Redis();
  31. $result=$redis->connect('127.0.0.1',6379);
  32. $count=$redis->lpop('goods_store');
  33. if(!$count){
  34.     insertLog('error:no store redis');
  35.     return;
  36. }
  37.   
  38. //生成訂單
  39. $order_sn=build_order_no();
  40. $sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price)
  41. values('$order_sn','$user_id','$goods_id','$sku_id','$price')";
  42. $order_rs=mysql_query($sql,$conn);
  43.   
  44. //庫存減小
  45. $sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
  46. $store_rs=mysql_query($sql,$conn);
  47. if(mysql_affected_rows()){
  48.     insertLog('庫存減小成功');
  49. }else{
  50.     insertLog('庫存減小失敗');
  51. }
複製代碼

上述只是簡單模擬高併發下的搶購，真實場景要比這複雜不少，不少注意的地方，如搶購頁面作成靜態的，經過ajax調用接口。再如上面的會致使一個用戶搶多個，思路：須要一個排隊隊列和搶購結果隊列及庫存隊列。高併發狀況，先將用戶進入排隊隊列，用一個線程循環處理從排隊隊列取出一個用戶，判斷用戶是否已在搶購結果隊列，若是在，則已搶購，不然未搶購，庫存減1，寫數據庫，將用戶入結果隊列。我之間作商城項目的時候，在秒殺這一塊我直接用的redis，這段時間看了看上面的幾種方法，雖然各有不一樣，可是實現目的都同樣的，各位本身選擇，開心就好。

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程