Comment empêcher une concurrence élevée en php

1. Raisons de la surémission

Supposons que dans un scénario de vente précipitée, nous n'ayons que 100 produits au total, et au dernier Pour le moment, nous les avons consommés, 99 produits ont été achetés, il ne reste que le dernier. À ce moment-là, le système a envoyé plusieurs demandes simultanées. Les soldes de produits lus par ces demandes étaient tous de 99, puis ils ont tous rendu ce jugement de solde, ce qui a finalement conduit à une émission excessive.

Dans l'image ci-dessus, l'utilisateur simultané B a également "acheté avec succès", permettant à une personne supplémentaire d'obtenir le produit. Ce scénario est très facile à réaliser dans des situations de forte concurrence.

Idées de verrouillage de fichiers

Pour les applications où l'adresse IP quotidienne n'est pas élevée ou le nombre de concurrence n'est pas très grand, vous n'avez généralement pas besoin d'en tenir compte ! Il n’y a aucun problème avec les méthodes normales de manipulation de fichiers. Mais si la concurrence est élevée, lorsque nous lisons et écrivons des fichiers, il est très probable que plusieurs processus fonctionneront sur le fichier suivant. Si l'accès au fichier n'est pas exclusif à ce moment-là, cela entraînera facilement une perte de données.

Solution d'optimisation : utiliser le verrouillage exclusif de fichier non bloquant

<?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);

?>

Tutoriel recommandé : Tutoriel vidéo PHP

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!