Detaillierte Erläuterung, wie PHP Anfragen mit hoher Parallelität für Eilkäufe verarbeitet

Dieses Mal erkläre ich Ihnen ausführlich, wie PHP mit Eilkaufanfragen mit hoher Parallelität umgeht Das Folgende ist ein praktischer Fall, werfen wir einen Blick darauf. In diesem Artikel werden Eilverkäufe und Flash-Verkäufe als Beispiele aufgeführt. Stellen Sie vor, wie Sie die Datengenauigkeit unter Bedingungen hoher Parallelität sicherstellen können.

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

1. Datenfehler führen zu überverkauften Produkten.
2. Häufige Vorgänge in der Datenbank führen zu Leistungseinbußen.

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 es werden Eilkäuferdaten 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 '恭喜你，订单<b>'.$order.'</b>抢购成功';
      }
    }else{
      echo '已被抢购一空！';
    }
  }

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 Lagerbestandsergebnisse abgefragt.

Optimierung 1:

Bestand ändernDatentypDie 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, mit der Ausnahme, dass eine Beurteilung vorgenommen wird, bei der der Bestand 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 '恭喜你，订单<b>'.$order.'</b>抢购成功';
      }
    }else{
      echo '已被抢购一空！';
    }
  }

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:

redisVerwenden 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

mehr erlaubt.

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

Ich glaube, dass Sie die Methode beherrschen, nachdem Sie den Fall in diesem Artikel gelesen haben. Weitere spannende Informationen finden Sie in anderen verwandten Artikeln auf der chinesischen PHP-Website!

Empfohlene Lektüre:

Detaillierte Erläuterung der Implementierungsschritte des PHP+Ajax-Datei-Uploads ohne Aktualisierung

PHP-Implementierung von Der mehrdimensionale Array-Sortieralgorithmus hat Welche Möglichkeiten

Das obige ist der detaillierte Inhalt vonDetaillierte Erläuterung, wie PHP Anfragen mit hoher Parallelität für Eilkäufe verarbeitet. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!