Lösungen für gängige Parallelitätsszenarien in PHP

Übliche Lösungen sind wie folgt:

1. Verwenden Sie eine Warteschlange, starten Sie einen zusätzlichen Prozess, um die Warteschlange zu bearbeiten, und stellen Sie alle gleichzeitigen Anforderungen ein Wenn zusätzliche Prozesse seriell verarbeitet werden, ist keine zusätzliche Prozessunterstützung erforderlich und die Verarbeitungsverzögerung ist schwerwiegend.

2. Verwenden Sie Datenbanktransaktionsmerkmale, um atomare Aktualisierungen durchzuführen. Diese Methode basiert auf den Transaktionsmerkmalen der Datenbank.

3. Verwenden Sie bei der Bearbeitung einer Bestellanfrage Flock, um eine Datei zu sperren. Nur diejenigen, die die Sperre erfolgreich erhalten, können die Bestellung bearbeiten.

1. Redis-Transaktionsfunktionen nutzen

Redis-Transaktionen sind atomare Vorgänge, die sicherstellen können, dass die Daten während der Auftragsabwicklung nicht durch andere gleichzeitige Prozesse geändert werden.

Beispielcode:

<?php
$http = new swoole_http_server("0.0.0.0", 9509);  // 监听 9509
 
$http->set(array(
  &#39;reactor_num&#39; => 2, //reactor thread num
  &#39;worker_num&#39; => 4  //worker process num
));
 
$http->on(&#39;request&#39;, function (swoole_http_request $request, swoole_http_response $response) {
  $uniqid = uniqid(&#39;uid-&#39;, TRUE);  // 模拟唯一用户ID
  $redis = new Redis();
  $redis->connect(&#39;127.0.0.1&#39;, 6379);  // 连接 redis
 
  $redis->watch(&#39;rest_count&#39;); // 监测 rest_count 是否被其它的进程更改
 
  $rest_count = intval($redis->get("rest_count")); // 模拟唯一订单ID
  if($rest_count > 0){
    $value = "{$rest_count}-{$uniqid}"; // 表示当前订单，被当前用户抢到了
 
    // do something ... 主要是模拟用户抢到单后可能要进行的一些密集运算
    $rand = rand(100, 1000000);
    $sum=0;
    for ($i=0;$i<$rand;$i++){ $sum+=$i; }
 
   // redis 事务
    $redis->multi();
    $redis->lPush(&#39;uniqids&#39;, $value);
    $redis->decr(&#39;rest_count&#39;);
    $replies = $redis->exec(); // 执行以上 redis 事务
 
   // 如果 rest_count 的值被其它的并发进程更改了，以上事务将回滚
    if(!$replies){
      echo "订单 {$value} 回滚".PHP_EOL;
    }
  }
  $redis->unwatch();
});
 
$http->start();

Ab-Test verwenden

$ ab -t 20 -c 10 http://192.168.1.104:9509/

2. Datei-Exklusivsperre (Blockierungsmodus) verwenden

Wenn im Blockierungsmodus ein Prozess eine exklusive Dateisperre erwirbt, während andere Prozesse die Sperre belegen, bleibt der Prozess hängen und wartet darauf, dass andere Prozesse die Sperre aufheben, die Sperre selbst erwerben und dann fortfahren.

Beispielcode:

<?php
$http = new swoole_http_server("0.0.0.0", 9510);
 
$http->set(array(
  &#39;reactor_num&#39; => 2, //reactor thread num
  &#39;worker_num&#39; => 4  //worker process num
));
 
$http->on(&#39;request&#39;, function (swoole_http_request $request, swoole_http_response $response) {
 
  $uniqid = uniqid(&#39;uid-&#39;, TRUE);
  $redis = new Redis();
  $redis->connect(&#39;127.0.0.1&#39;, 6379);
 
  $fp = fopen("lock.txt", "w+");
 
  // 阻塞(等待)模式， 要取得独占锁定（写入的程序）
  if(flock($fp,LOCK_EX))  //锁定当前指针
  {
   // 成功取得锁后，放心处理订单
    $rest_count = intval($redis->get("rest_count"));
    $value = "{$rest_count}-{$uniqid}";
    if($rest_count > 0){
      // do something ...
      $rand = rand(100, 1000000);
      $sum=0;
      for ($i=0;$i<$rand;$i++){ $sum+=$i; }
 
      $redis->lPush(&#39;uniqids&#39;, $value);
      $redis->decr(&#39;rest_count&#39;);
    }
 
   // 订单处理完成后，再释放锁
    flock($fp,LOCK_UN);
  }
  fclose($fp);
 
});
 
$http->start();

Ab-Test verwenden

$ ab -t 20 -c 10 http://192.168.1.104:9510/

Empfohlenes Tutorial: PHP-Tutorial

Das obige ist der detaillierte Inhalt vonLösungen für gängige Parallelitätsszenarien in PHP. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!