PHP et Redis mettent en œuvre des achats urgents et des ventes flash avec une forte concurrence

Cet article partage principalement avec vous PHP et Redis pour mettre en œuvre des achats précipités et des ventes flash dans des conditions de concurrence élevée. Les achats précipités et les ventes flash sont des scénarios très courants. Lors des entretiens, les intervieweurs vous demandent souvent, par exemple, ce qu'est la vente flash. sur Taobao ? Comment le mettre en œuvre, etc., j'espère que cela pourra aider tout le monde

C'est très simple de mettre en place des ventes flash et des ventes flash, mais il y a certains problèmes qui doivent être résolus, principalement en se concentrant sur deux problèmes :

1. L'appariement à haute concurrence La pression générée par la base de données
2. Comment résoudre la bonne réduction des stocks (problème de "survente") dans des conditions de concurrence

Le Le premier problème est très simple pour PHP. La base de données peut être atténuée en utilisant la technologie de mise en cache Pressure, telle que Memcache, Redis et d'autres technologies de mise en cache.
La deuxième question est plus compliquée :

Écriture conventionnelle :
Interroger le stock du produit correspondant pour voir s'il est supérieur à 0, puis effectuer des opérations telles que générer une commande, mais quand juger si l'inventaire est supérieur à 0. S'il y a une concurrence élevée, il y aura des problèmes, entraînant un inventaire négatif.

<?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(&#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;)";
mysql_query($sql,$conn);
}
//模拟下单操作
//库存是否大于0
$sql="select number from ih_store where goods_id=&#39;$goods_id&#39; and sku_id=&#39;$sku_id&#39;";
//解锁 此时ih_store数据中goods_id=&#39;$goods_id&#39; and sku_id=&#39;$sku_id&#39; 的数据被锁住(注3)，其它事务必须等待此次事务 提交后才能执行
$rs=mysql_query($sql,$conn);
$row=mysql_fetch_assoc($rs);
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=mysql_query($sql,$conn);
//库存减少
$sql="update ih_store set number=number-{$number} where sku_id=&#39;$sku_id&#39;";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog(&#39;库存减少成功&#39;);
}else{
insertLog(&#39;库存减少失败&#39;);
}
}else{
insertLog(&#39;库存不够&#39;);
}
出现这种情况怎么办呢？来看几种优化方法：
优化方案1：将库存字段number字段设为unsigned，当库存为0时，因为字段不能为负数，将会返回false
//库存减少
$sql="update ih_store set number=number-{$number} where sku_id=&#39;$sku_id&#39; and number>0";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog(&#39;库存减少成功&#39;);
}
优化方案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(&#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;)";
mysql_query($sql,$conn);
}
//模拟下单操作
//库存是否大于0
mysql_query("BEGIN"); //开始事务
$sql="select number from ih_store where goods_id=&#39;$goods_id&#39; and sku_id=&#39;$sku_id&#39; FOR UPDATE";//此时这条记录被锁住,其它事务必须等待此次事务提交后才能执行
$rs=mysql_query($sql,$conn);
$row=mysql_fetch_assoc($rs);
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=mysql_query($sql,$conn);
//库存减少
$sql="update ih_store set number=number-{$number} where sku_id=&#39;$sku_id&#39;";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog(&#39;库存减少成功&#39;);
mysql_query("COMMIT");//事务提交即解锁
}else{
insertLog(&#39;库存减少失败&#39;);
}
}else{
insertLog(&#39;库存不够&#39;);
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(&#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;)";
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=&#39;$goods_id&#39; and sku_id=&#39;$sku_id&#39;";
$rs=mysql_query($sql,$conn);
$row=mysql_fetch_assoc($rs);
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=mysql_query($sql,$conn);
//库存减少
$sql="update ih_store set number=number-{$number} where sku_id=&#39;$sku_id&#39;";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog(&#39;库存减少成功&#39;);
flock($fp,LOCK_UN);//释放锁
}else{
insertLog(&#39;库存减少失败&#39;);
}
}else{
insertLog(&#39;库存不够&#39;);
}
fclose($fp);
优化方案4：使用redis队列，因为pop操作是原子的，即使有很多用户同时到达，也是依次执行，推荐使用（mysql事务在高并发下性能下降很厉害，文件锁的方式也是）
先将商品库存如队列
<?php
$store=1000;
$redis=new Redis();
$result=$redis->connect(&#39;127.0.0.1&#39;,6379);
$res=$redis->llen(&#39;goods_store&#39;);
echo $res;
$count=$store-$res;
for($i=0;$i<$count;$i++){
$redis->lpush(&#39;goods_store&#39;,1);
}
echo $redis->llen(&#39;goods_store&#39;);
抢购、描述逻辑
<?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(&#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;)";
mysql_query($sql,$conn);
}
//模拟下单操作
//下单前判断redis队列库存量
$redis=new Redis();
$result=$redis->connect(&#39;127.0.0.1&#39;,6379);
$count=$redis->lpop(&#39;goods_store&#39;);
if(!$count){
insertLog(&#39;error:no store redis&#39;);
return;
}
//生成订单
$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=mysql_query($sql,$conn);
//库存减少
$sql="update ih_store set number=number-{$number} where sku_id=&#39;$sku_id&#39;";
$store_rs=mysql_query($sql,$conn);
if(mysql_affected_rows()){
insertLog(&#39;库存减少成功&#39;);
}else{
insertLog(&#39;库存减少失败&#39;);
}

Ce qui précède n'est qu'une simple simulation d'achat précipité dans une concurrence élevée. Le scénario réel est beaucoup plus compliqué que cela. Il y a beaucoup de choses auxquelles il faut prêter attention, comme rendre la page d'achat précipitée statique. et appeler l'interface via ajax.

Ce qui précède amènera un utilisateur à récupérer plusieurs articles. L'idée est la suivante :
Une file d'attente, une file d'attente des résultats d'achat et une file d'attente d'inventaire sont nécessaires. En cas de concurrence élevée, entrez d'abord l'utilisateur dans la file d'attente, utilisez une boucle de thread pour supprimer un utilisateur de la file d'attente et déterminez si l'utilisateur est déjà dans la file d'attente des résultats d'achat urgent. Si c'est le cas, il a été cassé. vers le haut, sinon il n'est pas récupéré, l'inventaire est réduit de 1 et la base de données est écrite. Mettez l'utilisateur dans la file d'attente des résultats.
Lorsque je travaillais sur un projet de centre commercial, j'ai utilisé redis directement pour les ventes flash. Pendant ce temps, j'ai examiné les méthodes ci-dessus. Bien qu'elles soient différentes, elles atteignent toutes le même objectif. Soyez simplement heureux.

Recommandations associées :

php+redis implémente la fonction d'achat urgent

Comment php gère les demandes simultanées élevées pour les fonctions d'achat urgent

PHP implémente une fonction de capture simultanée via le verrouillage

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!