Wie geht PHP mit vielen gleichzeitigen Anfragen für Snap-up-Funktionen um?

Bei vielen gleichzeitigen Anfragen kann es leicht zu zwei Problemen mit Parametern kommen

1. Datenfehler führen zu überverkauften Produkten.

2. Häufige Datenbankoperationen führen zu Leistungseinbußen.

Dieser Artikel stellt Ihnen vor allem detailliert vor, wie PHP Anfragen mit hoher Parallelität für Snap-Up-Funktionen verarbeitet. Ich hoffe, dass er Ihnen weiterhelfen kann.

Testumgebung

Windows7
Apache2.4.9
php5.5.12
PHP-Framework yii2.0
Tool Apache Bench (Apache seit Mit Tools für viele gleichzeitige Anfragen.

Übliche Verarbeitungsmethode

Die Codeidee ist aus dem Controller ersichtlich. Überprüfen Sie zunächst den Produktbestand. Wenn der Lagerbestand größer als 0 ist, wird der Lagerbestand um 1 reduziert, gleichzeitig werden Bestellungen produziert und Daten zu Eilkäufern eingegeben.

// 常规代码处理高并发
  public function actionNormal(){
    // 查询库存
    $stock = Goods::find()->select('stock')->where(['goods_id'=>100001])->asArray()->one();
    // 判断该商品是否还有库存
    if ($stock['stock']>0) {
      // 库存减一
      Goods::updateAllCounters(['stock' => -1],['goods_id'=>100001]);

      // 生产订单（另外功能，暂且随机赋值）
      $order = $this->build_order();

      // 秒杀信息入库
      $model = new Highly();
      $model->order_id = $order;
      $model->goods_name = '秒杀商品';
      $model->buy_time = date('Y-m-d H:i:s',time());
      $model->mircrotime = microtime(true);
      if($model->save()===false){
        echo '未能成功抢购！';
      }else{
        echo &#39;恭喜你，订单<b>&#39;.$order.&#39;</b>抢购成功&#39;;
      }

    }else{
      echo &#39;已被抢购一空！&#39;;
    }
  }

Nachdem Sie den Produktbestand auf 20 festgelegt haben, konfigurieren Sie gleichzeitige Anforderungen von 200 bis ca.

ab -n 200 -c 200 http//localhost/highly/normal

Das Ausführungsergebnis ergab, dass der Lagerbestand negativ wurde und das Produkt überverkauft war.

Der Grund ist relativ einfach, bei vielen gleichzeitigen Anfragen. Bevor Bestellungen erstellt und Lagerbestände reduziert werden, werden zunächst die Lagerergebnisse abgefragt.

Optimierung 1: Bestandsdatentyp ändern

Die erste Optimierungsmethode beginnt mit der Datenbank. Da die Abfrageergebnisse ungenau sind, werde ich versuchen, den Lagerbestand zu reduzieren. Ändern Sie den Datentyp des Inventars in „Unsigned“ (darf keine negativen Werte haben).

Der Code ähnelt immer noch dem oben genannten, außer dass eine Beurteilung vorgenommen wird, bei der der Lagerbestand um 1 reduziert wird. Vermeiden Sie Meldefehler.

public function actionNormal(){
    // 查询库存
    $stock = Goods::find()->select('stock')->where(['goods_id'=>100001])->asArray()->one();
    // 判断该商品是否还有库存
    if ($stock['stock']>0) {
      // 库存减一
      if(Goods::updateAllCounters(['stock' => -1],['goods_id'=>100001])===false){
        echo "已被抢购一空!";
        return false;
      }

      // 生产订单（另外功能，暂且随机赋值）
      $order = $this->build_order();

      // 秒杀信息入库
      $model = new Highly();
      $model->order_id = $order;
      $model->goods_name = '秒杀商品';
      $model->buy_time = date('Y-m-d H:i:s',time());
      $model->mircrotime = microtime(true);
      if($model->save()===false){
        echo '未能成功抢购！';
      }else{
        echo &#39;恭喜你，订单<b>&#39;.$order.&#39;</b>抢购成功&#39;;
      }

    }else{
      echo &#39;已被抢购一空！&#39;;
    }
  }

Dieses Mal werden die gleichen 200 Parallelitätsausführungsergebnisse gefunden. Die Daten sind korrekt und es liegt keine Überverkaufssituation vor.
Die Idee ist eigentlich relativ einfach. Da der Bestand nicht negativ sein darf und der Bestand gleich 0 ist, wird ein Fehler gemeldet, wenn noch Werte übergeben werden. Die Anfrage wurde abgebrochen.

Diese Optimierungsmethode vermeidet einen Überverkauf von Produkten. Andererseits üben Anfragen immer noch Druck auf die Datenbank aus. Wenn mehrere Funktionen diese Datenbank verwenden, sinkt die Leistung erheblich.

Optimierung 2: redis

Verwenden Sie die Atomizität des Redis-Listentyps Pop. Führen Sie vor dem Betrieb der Datenbank eine Überprüfung durch. Wenn die Ware ausverkauft ist, sind keine weiteren Datenbankoperationen zulässig.

// redis list 高并发测试
  public function actionRedis(){
    $redis = \Yii::$app->redis;
    // $redis->lpush('mytest',1);
    $order = $this->build_order();
    // echo $order;die;
    // echo $redis->llen('mytest');
    $reg = $redis->lpop('mytest');
    if (!$reg) {
      echo "笨蛋！已经被抢光啦！";
      return false;
    }
    $redis->close();
    $model = new Highly();
    $model->order_id = $order;
    $model->goods_name = '秒杀商品';
    $model->buy_time = date('Y-m-d H:i:s',time());
    $model->mircrotime = microtime(true);

    if($model->save()===false){
      echo '未能成功抢购！';
    }else{
      echo &#39;恭喜你，订单<b>&#39;.$order.&#39;</b>抢购成功&#39;;
    }
  }
  // 给redis添加商品
  public function actionInsertgoods(){
    $count = yii::$app->request->get(&#39;count&#39;,0);
    if (empty($count)) {
      echo &#39;大兄弟，你还没告诉我需要上架多少商品呢!&#39;;
      return false;
    }
    $redis = \Yii::$app->redis;
    for ($i=0; $i < $count; $i++) { 
      $redis->lpush(&#39;mytest&#39;,1);
    }
    echo &#39;成功添加了&#39;.$redis->llen(&#39;mytest&#39;).&#39;件商品。&#39;;
    $redis->close();

  }

Für diesen Code habe ich zwei Methoden geschrieben. Die erste Methode ist der Flash-Sale-Code und die zweite Methode besteht darin, die Menge für die Flash-Sale-Produkte festzulegen. Um das Testen zu erleichtern, gehe ich hier relativ einfach vor.

Nach dem Test ist die Anzahl der von der Datenbank generierten Bestellungen normal und es gibt keine Probleme. Dadurch wird das Problem einer Leistungseinbuße vermieden, die durch die Anforderung der Datenbank verursacht wird. Gleichzeitig ist die Abfragegeschwindigkeit der In-Memory-Datenbank Redis viel schneller als die von MySQL.

Verwandte Empfehlungen:

Knoten-Single-Thread-Implementierung des Prinzips der hohen Parallelität

PHP und Redis implementieren Registrierungsstatistiken für hohe Parallelität

Detaillierte Erläuterung von Beispielen für Eilkauf- und Flash-Sale-Funktionen unter hoher Parallelität mit PHP und Redis

Das obige ist der detaillierte Inhalt vonWie geht PHP mit vielen gleichzeitigen Anfragen für Snap-up-Funktionen um?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!