Comment empêcher la survente de l'inventaire de produits dans des conditions de concurrence élevée en PHP

Cet article vous apporte des connaissances pertinentes sur PHP, qui introduit principalement des problèmes liés à la prévention des stocks de marchandises survendus dans des conditions de concurrence élevée, résolvant principalement la pression de la concurrence élevée sur la base de données et comment résoudre le problème de la concurrence. d'inventaire de produits survendus, j'espère que cela sera utile à tout le monde.

Vous pouvez consulter les cas de test basés sur cet article via "Test de haute concurrence PHP : étude de cas sur la prévention de la survente des stocks". [Apprentissage recommandé : "Tutoriel PHP"]

Dans le système du centre commercial, les ventes précipitées et les ventes flash sont des scénarios marketing très courants. Au cours d'une certaine période de temps, un grand nombre d'utilisateurs visitent le centre commercial pour y passer des commandes. Il y a deux problèmes principaux qui doivent être résolus :

• La pression d'une concurrence élevée sur la base de données

• Comment résoudre l'inventaire survendu de marchandises sous concurrence ; la base de données

Pour la première question, utiliser la mise en cache est utilisée pour éviter d'exploiter directement la base de données, comme en utilisant Redis. Comment résoudre le problème de stock de produits survendu dans une situation concurrentielle

Pour la deuxième question, il faut se concentrer sur l'explication. Méthode d'écriture conventionnelle : interrogez l'inventaire du produit correspondant, déterminez si la quantité d'inventaire est supérieure à 0, puis effectuez des opérations telles que la génération d'une commande. Cependant, lors de la détermination si l'inventaire est supérieur à 0, il y aura des problèmes. dans des conditions de concurrence élevée, ce qui entraîne une quantité de stock négative.

Test table sql

Importez les données de la table suivante dans la base de données

<strong>/*
Navicat MySQL Data Transfer

Source Server         : 01 本地localhost
Source Server Version : 50553
Source Host           : localhost:3306
Source Database       : test

Target Server Type    : MYSQL
Target Server Version : 50553
File Encoding         : 65001

Date: 2020-11-06 14:31:35
*/

SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for products
-- ----------------------------
DROP TABLE IF EXISTS `products`;
CREATE TABLE `products` (
  `id` int(10) NOT NULL AUTO_INCREMENT COMMENT &#39;ID&#39;,
  `title` varchar(50) DEFAULT NULL COMMENT &#39;货品名称&#39;,
  `store` int(11) DEFAULT &#39;0&#39; COMMENT &#39;货品库存&#39;,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COMMENT=&#39;货品表&#39;;

-- ----------------------------
-- Records of products
-- ----------------------------
INSERT INTO `products` VALUES (&#39;1&#39;, &#39;稻花香大米&#39;, &#39;20&#39;);

-- ----------------------------
-- Table structure for order_log
-- ----------------------------
DROP TABLE IF EXISTS `order_log`;
CREATE TABLE `order_log` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `content` varchar(255) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT &#39;日志内容&#39;,
  `c_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT &#39;创建时间&#39;,
  PRIMARY KEY (`id`)
) ENGINE=MyISAM DEFAULT CHARSET=latin1;

-- ----------------------------
-- Table structure for order
-- ----------------------------
DROP TABLE IF EXISTS `order`;
CREATE TABLE `order` (
  `oid` bigint(20) unsigned NOT NULL DEFAULT &#39;0&#39; COMMENT &#39;订单号&#39;,
  `product_id` int(11) DEFAULT &#39;0&#39; COMMENT &#39;商品ID&#39;,
  `number` int(11) DEFAULT &#39;0&#39; COMMENT &#39;购买数量&#39;,
  `c_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT &#39;创建时间&#39;,
  PRIMARY KEY (`oid`)
) ENGINE=MyISAM DEFAULT CHARSET=latin1 COMMENT=&#39;订单表&#39;;</strong>

Code de traitement des commandes

<?php

db();
global $con;

//step1 接收下单参数
$product_id = 1;// 商品ID
$buy_num = 1;// 购买数量

//step2 查询商品信息
$sql = "select * from products where id={$product_id}";
$result = mysqli_query($con, $sql);
$row = mysqli_fetch_assoc($result);

//step3 判断商品下单数量是否大于商品库存数量
//此处在高并发下，可能出现上一个下单后还没来得及更新库存，下一个下单判断库存数不是最新的库存
if ($row[&#39;store&#39;] > 0) {

    sleep(1);
    //step4 更新商品库存数量（减去下单数量）
    $sql = "update products set store=store-{$buy_num} where id={$product_id}";
    if (mysqli_query($con, $sql)) {
        echo "更新成功";
        //step5 生成订单号创建订单
        $oid = build_order_no();
        create_order($oid, $product_id, $buy_num);
        insertLog(&#39;库存减少成功，下单成功&#39;);
    } else {
        echo "更新失败";
        insertLog(&#39;库存减少失败&#39;);
    }

} else {
    echo "没有库存";
    insertLog(&#39;库存不够&#39;);
}

function db()
{
    global $con;
    $con = new mysqli(&#39;localhost&#39;,&#39;root&#39;,&#39;root&#39;,&#39;test&#39;);
    if (!$con) {
        echo "数据库连接失败";
    }
}

/**
 * 生成唯一订单号
 */
function build_order_no()
{
    return date(&#39;Ymd&#39;) . str_pad(mt_rand(1, 99999), 5, &#39;0&#39;, STR_PAD_LEFT);
}

function create_order($oid, $product_id, $number)
{
    global $con;
    $sql = "INSERT INTO `order` (oid, product_id, number) values(&#39;$oid&#39;, &#39;$product_id&#39;, &#39;$number&#39;)";
    mysqli_query($con, $sql);
}

/**
 * 记录日志
 */
function insertLog($content)
{
    global $con;
    $sql = "INSERT INTO `order_log` (content) values(&#39;$content&#39;)";
    mysqli_query($con, $sql);
}

Définissez le champ du champ d'inventaire sur non signé

Parce que les champs d'inventaire ne peuvent pas être un nombre négatif. Lors de la mise à jour de l'inventaire du produit après avoir passé une commande, si un nombre négatif se produit, false sera renvoyé

<strong><?php
db();
global $con;

//step1 接收下单参数
$product_id = 1;// 商品ID
$buy_num = 1;// 购买数量

//step2 查询商品信息
$sql = "select * from products where id={$product_id} for UPDATE";//利用for update 开启行锁
$result = mysqli_query($con, $sql);
$row = mysqli_fetch_assoc($result);

//step3 判断商品下单数量是否大于商品库存数量
if ($row[&#39;store&#39;] > 0) {

    sleep(1);
    //step4 更新商品库存数量（减去下单数量）
    $sql = "update products set store=store-{$buy_num} where id={$product_id}";
    if (mysqli_query($con, $sql)) {
        echo "更新成功";
        //step5 生成订单号创建订单
        $oid = build_order_no();
        create_order($oid, $product_id, $buy_num);
        insertLog(&#39;库存减少成功，下单成功&#39;);
    } else {
        // 如果出现负数将返回false
        echo "更新失败";
        insertLog(&#39;库存减少失败&#39;);
    }
} else {
    //商品已经抢购完
    echo "没有库存";
    insertLog(&#39;库存不够&#39;);
}

function db()
{
    global $con;
    $con = new mysqli(&#39;localhost&#39;,&#39;root&#39;,&#39;root&#39;,&#39;test&#39;);
    if (!$con) {
        echo "数据库连接失败";
    }
}

/**
 * 生成唯一订单号
 */
function build_order_no()
{
    return date(&#39;Ymd&#39;) . str_pad(mt_rand(1, 99999), 5, &#39;0&#39;, STR_PAD_LEFT);
}

function create_order($oid, $product_id, $number)
{
    global $con;
    $sql = "INSERT INTO `order` (oid, product_id, number) values(&#39;$oid&#39;, &#39;$product_id&#39;, &#39;$number&#39;)";
    mysqli_query($con, $sql);
}

/**
 * 记录日志
 */
function insertLog($content)
{
    global $con;
    $sql = "INSERT INTO `order_log` (content) values(&#39;$content&#39;)";
    mysqli_query($con, $sql);
}</strong>

Utilisez la transaction mysql pour verrouiller la ligne de l'opération

Pendant le processus de traitement de la commande, la transaction en utilisant MySQL, vous passerez la commande Verrouillage des données de la ligne de produits

<strong><?php
db();
global $con;

//step1 接收下单参数
$product_id = 1;// 商品ID
$buy_num = 1;// 购买数量

mysqli_query($con, "BEGIN"); //开始事务

//step2 查询商品信息
$sql = "select * from products where id={$product_id} for UPDATE";//利用for update 开启行锁
$result = mysqli_query($con, $sql);
$row = mysqli_fetch_assoc($result);

//step3 判断商品下单数量是否大于商品库存数量
if ($row[&#39;store&#39;] > 0) {

    sleep(1);
    //step4 更新商品库存数量（减去下单数量）
    $sql = "update products set store=store-{$buy_num} where id={$product_id}";
    if (mysqli_query($con, $sql)) {
        echo "更新成功";
        //step5 生成订单号创建订单
        $oid = build_order_no();
        create_order($oid, $product_id, $buy_num);
        insertLog(&#39;库存减少成功，下单成功&#39;);
        mysqli_query($con, "COMMIT");//事务提交即解锁
    } else {
        echo "更新失败";
        insertLog(&#39;库存减少失败&#39;);
        mysqli_query($con, "ROLLBACK");//事务回滚即解锁
    }
} else {
    //商品已经抢购完
    echo "没有库存";
    insertLog(&#39;库存不够&#39;);
    mysqli_query($con, "ROLLBACK");//事务回滚即解锁
}

function db()
{
    global $con;
    $con = new mysqli(&#39;localhost&#39;,&#39;root&#39;,&#39;root&#39;,&#39;test&#39;);
    if (!$con) {
        echo "数据库连接失败";
    }
}

/**
 * 生成唯一订单号
 */
function build_order_no()
{
    return date(&#39;Ymd&#39;) . str_pad(mt_rand(1, 99999), 5, &#39;0&#39;, STR_PAD_LEFT);
}

function create_order($oid, $product_id, $number)
{
    global $con;
    $sql = "INSERT INTO `order` (oid, product_id, number) values(&#39;$oid&#39;, &#39;$product_id&#39;, &#39;$number&#39;)";
    mysqli_query($con, $sql);
}

/**
 * 记录日志
 */
function insertLog($content)
{
    global $con;
    $sql = "INSERT INTO `order_log` (content) values(&#39;$content&#39;)";
    mysqli_query($con, $sql);
}</strong>

Utiliser le verrouillage exclusif de fichier non bloquant

Lors du traitement d'une demande de commande, utilisez flock pour verrouiller un fichier. Si le verrouillage échoue, cela signifie que d'autres commandes. sont en cours de traitement, vous pouvez soit attendre, soit directement. L'utilisateur est informé que "le serveur est occupé" et le compteur stocke le nombre de produits achetés pour éviter d'interroger la base de données. Mode de blocage (attente) : pendant la simultanéité, lorsqu'il y a une deuxième demande d'utilisateur, le programme attendra que la première demande d'utilisateur se termine, libérera le verrou et obtiendra le verrouillage du fichier avant que le programme continue de s'exécuter.

<strong><?php
db();
global $con;

//step1 接收下单参数
$product_id = 1;// 商品ID
$buy_num = 1;// 购买数量

$fp = fopen(&#39;lock.txt&#39;, &#39;w&#39;);
if (flock($fp, LOCK_EX)) {   //文件独占锁,阻塞
    //step2 查询商品信息
    $sql = "select * from products where id={$product_id}";
    $result = mysqli_query($con, $sql);
    $row = mysqli_fetch_assoc($result);

    //step3 判断商品下单数量是否大于商品库存数量
    if ($row[&#39;store&#39;] > 0) {
        //处理订单
        sleep(1);
        //step4 更新商品库存数量（减去下单数量）
        $sql = "update products set store=store-{$buy_num} where id={$product_id}";
        if (mysqli_query($con, $sql)) {
            echo "更新成功";
            //step5 生成订单号创建订单
            $oid = build_order_no();
            create_order($oid, $product_id, $buy_num);
            insertLog(&#39;库存减少成功，下单成功&#39;);
        } else {
            echo "更新失败";
            insertLog(&#39;库存减少失败&#39;);
        }
    } else {
        //商品已经抢购完
        echo "没有库存";
        insertLog(&#39;库存不够&#39;);
    }
    flock($fp, LOCK_UN); //释放锁

}
fclose($fp);

function db()
{
    global $con;
    $con = new mysqli(&#39;localhost&#39;,&#39;root&#39;,&#39;root&#39;,&#39;test&#39;);
    if (!$con) {
        echo "数据库连接失败";
    }
}

/**
 * 生成唯一订单号
 */
function build_order_no()
{
    return date(&#39;Ymd&#39;) . str_pad(mt_rand(1, 99999), 5, &#39;0&#39;, STR_PAD_LEFT);
}

function create_order($oid, $product_id, $number)
{
    global $con;
    $sql = "INSERT INTO `order` (oid, product_id, number) values(&#39;$oid&#39;, &#39;$product_id&#39;, &#39;$number&#39;)";
    mysqli_query($con, $sql);
}

/**
 * 记录日志
 */
function insertLog($content)
{
    global $con;
    $sql = "INSERT INTO `order_log` (content) values(&#39;$content&#39;)";
    mysqli_query($con, $sql);
}</strong>

Mode non bloquant : lors de la concurrence, le premier utilisateur demande et obtient le verrouillage du fichier. Les utilisateurs qui demandent plus tard reviendront directement au système étant occupé, veuillez réessayer plus tard

<?php
db();
global $con;

//step1 接收下单参数
$product_id = 1;// 商品ID
$buy_num = 1;// 购买数量

$fp = fopen(&#39;lock.txt&#39;, &#39;w&#39;);
if (flock($fp, LOCK_EX|LOCK_NB)) {   //文件独占锁,非阻塞
    //step2 查询商品信息
    $sql = "select * from products where id={$product_id}";
    $result = mysqli_query($con, $sql);
    $row = mysqli_fetch_assoc($result);

    //step3 判断商品下单数量是否大于商品库存数量
    if ($row[&#39;store&#39;] > 0) {
        //处理订单
        sleep(1);
        //step4 更新商品库存数量（减去下单数量）
        $sql = "update products set store=store-{$buy_num} where id={$product_id}";
        if (mysqli_query($con, $sql)) {
            echo "更新成功";
            //step5 生成订单号创建订单
            $oid = build_order_no();
            create_order($oid, $product_id, $buy_num);
            insertLog(&#39;库存减少成功，下单成功&#39;);
        } else {
            echo "更新失败";
            insertLog(&#39;库存减少失败&#39;);
        }
    } else {
        //商品已经抢购完
        echo "没有库存";
        insertLog(&#39;库存不够&#39;);
    }
    flock($fp, LOCK_UN); //释放锁

} else {
    //系统繁忙，请稍后再试
    echo "系统繁忙，请稍后再试";
    insertLog(&#39;系统繁忙，请稍后再试&#39;);
}
fclose($fp);

function db()
{
    global $con;
    $con = new mysqli(&#39;localhost&#39;,&#39;root&#39;,&#39;root&#39;,&#39;test&#39;);
    if (!$con) {
        echo "数据库连接失败";
    }
}

/**
 * 生成唯一订单号
 */
function build_order_no()
{
    return date(&#39;Ymd&#39;) . str_pad(mt_rand(1, 99999), 5, &#39;0&#39;, STR_PAD_LEFT);
}

function create_order($oid, $product_id, $number)
{
    global $con;
    $sql = "INSERT INTO `order` (oid, product_id, number) values(&#39;$oid&#39;, &#39;$product_id&#39;, &#39;$number&#39;)";
    mysqli_query($con, $sql);
}

/**
 * 记录日志
 */
function insertLog($content)
{
    global $con;
    $sql = "INSERT INTO `order_log` (content) values(&#39;$content&#39;)";
    mysqli_query($con, $sql);
}

Utiliser la file d'attente redis

Parce que l'opération pop est atomique, même si de nombreux utilisateurs arrivent en même temps, ils le feront être exécuté dans l'ordre. Il est recommandé d'utiliser

• Les performances des transactions MySQL diminuent considérablement en cas de concurrence élevée, et la méthode de verrouillage de fichier est également

  
  

1. Inventoriez d'abord le produit dans la file d'attente Redis

• <?php
  
  db();
  global $con;
  
  // 查询商品信息
  $product_id = 1;
  $sql = "select * from products where id={$product_id}";
  $result = mysqli_query($con, $sql);
  $row = mysqli_fetch_assoc($result);
  $store = $row[&#39;store&#39;];
  
  // 获取商品在redis缓存的库存
  $redis = new Redis();
  $result = $redis->connect(&#39;127.0.0.1&#39;, 6379);
  $key = &#39;goods_store_&#39; . $product_id;
  $res = $redis->llen($key);
  $count = $store - $res;
  
  for ($i=0; $i<$count; $i++) {
      $redis->lpush($key, 1);
  }
  echo $redis->llen($key);
  
  function db()
  {
      global $con;
      $con = new mysqli(&#39;localhost&#39;,&#39;root&#39;,&#39;root&#39;,&#39;test&#39;);
      if (!$con) {
          echo "数据库连接失败";
      }
  }

  2. Logique d'achat précipité et de vente flash

  <?php
  
  db();
  global $con;
  
  //step1 接收下单参数
  $product_id = 1;// 商品ID
  $buy_num = 1;// 购买数量
  
  //step2 下单前判断redis队列库存量
  $redis = new Redis();
  $result = $redis->connect(&#39;127.0.0.1&#39;,6379);
  $count = $redis->lpop(&#39;goods_store_&#39; . $product_id);
  if (!$count) {
      insertLog(&#39;error:no store redis&#39;);
      return &#39;秒杀结束，没有商品库存了&#39;;
  }
  
  sleep(1);
  //step3 更新商品库存数量（减去下单数量）
  $sql = "update products set store=store-{$buy_num} where id={$product_id}";
  if (mysqli_query($con, $sql)) {
      echo "更新成功";
      //step4 生成订单号创建订单
      $oid = build_order_no();
      create_order($oid, $product_id, $buy_num);
      insertLog(&#39;库存减少成功，下单成功&#39;);
  } else {
      echo "更新失败";
      insertLog(&#39;库存减少失败&#39;);
  }
  
  function db()
  {
      global $con;
      $con = new mysqli(&#39;localhost&#39;,&#39;root&#39;,&#39;root&#39;,&#39;test&#39;);
      if (!$con) {
          echo "数据库连接失败";
      }
  }
  
  /**
   * 生成唯一订单号
   */
  function build_order_no()
  {
      return date(&#39;Ymd&#39;) . str_pad(mt_rand(1, 99999), 5, &#39;0&#39;, STR_PAD_LEFT);
  }
  
  function create_order($oid, $product_id, $number)
  {
      global $con;
      $sql = "INSERT INTO `order` (oid, product_id, number) values(&#39;$oid&#39;, &#39;$product_id&#39;, &#39;$number&#39;)";
      mysqli_query($con, $sql);
  }
  
  /**
   * 记录日志
   */
  function insertLog($content)
  {
      global $con;
      $sql = "INSERT INTO `order_log` (content) values(&#39;$content&#39;)";
      mysqli_query($con, $sql);
  }

redis prévention du verrouillage optimiste Survente

<?php

$redis =new Redis();
$redis->connect("127.0.0.1", 6379);
$redis->watch(&#39;sales&#39;);//乐观锁 监视作用 set()  初始值0
$sales = $redis->get(&#39;sales&#39;);

$n = 20;// 库存
if ($sales >= $n) {
    exit(&#39;秒杀结束&#39;);
}

//redis开启事务
$redis->multi();
$redis->incr(&#39;sales&#39;); //将 key 中储存的数字值增一 ,如果 key 不存在，那么 key 的值会先被初始化为 0 ，然后再执行 INCR 操作。
$res = $redis->exec(); //成功1 失败0

if ($res) {
    //秒杀成功
    $con = new mysqli(&#39;localhost&#39;,&#39;root&#39;,&#39;root&#39;,&#39;test&#39;);
    if (!$con) {
        echo "数据库连接失败";
    }

    $product_id = 1;// 商品ID
    $buy_num = 1;// 购买数量
    sleep(1);

    $sql = "update products set store=store-{$buy_num} where id={$product_id}";

    if (mysqli_query($con, $sql)) {
        echo "秒杀完成";
    }

} else {
    exit(&#39;抢购失败&#39;);
}

Apprentissage 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!