Einfache PHP-Multithreading-Lösung

Einfache PHP-Multithreading-Lösung

Wenn wir Projekte durchführen, haben wir einige Anforderungen, insbesondere Daten Die Antwortverarbeitung nimmt viel Zeit in Anspruch. Da es sich bei PHP um eine Skriptsprache mit kurzem Lebenszyklus handelt, ist die Datenverarbeitung von PHP nach den standardmäßigen 30 Sekunden noch nicht abgeschlossen und der Lebenszyklus von PHP ist beendet.

Zu diesem Zeitpunkt müssen Sie eine asynchrone gleichzeitige Verarbeitungsstrategie verwenden, dh mehrere Anforderungen, die von einem PHP-Aufruf ausgegeben werden können, können nicht nacheinander ausgeführt werden, sondern können asynchron ausgeführt werden Gleichzeitig werden einige Anforderungen im Hintergrund verwendet, um Daten zu verarbeiten, und einige Anforderungen werden verwendet, um den Antwortstatus im Hintergrund zu akzeptieren und einige einfache Interaktionen mit Benutzern basierend auf dem Status durchzuführen.

Aber hier kommt das Problem. Wir alle wissen, dass PHP selbst kein Multithreading unterstützt. Wie sollten wir also Multithreading in PHP implementieren?

Drei Methoden der PHP-Simulation, um Multithreading zu erreichen

1. PHP-Multithreading unter Linux

Die folgenden Dinge sind die Quelle Da die Funktion pcntl_fork von PHP von der Implementierung des Betriebssystem-Fork abhängt, gelten die in diesem Artikel behandelten Dinge nur für Linux/Unix. Werfen wir also zunächst einen Blick auf die Verwendung dieser Funktion. Im PHP-Handbuch heißt es:

<?php
$pid = pcntl_fork();
if ($pid == -1) {
         die(&#39;could not fork&#39;);
} else if ($pid) {
         // we are the parent
         pcntl_wait($status); //Protect against Zombie children
} else {
         // we are the child
}
?>

Erstellen Sie einen untergeordneten Prozess über pcntl_fork. Wenn der Rückgabewert -1 ist, ist die Erstellung des untergeordneten Prozesses fehlgeschlagen. Die Erstellung war erfolgreich. Die Prozess-ID wird an den übergeordneten Prozess zurückgegeben, und 0 wird an den untergeordneten Prozess zurückgegeben. Es ist schwer zu verstehen, daher sollte es so geschrieben werden:

<?php
$pid = pcntl_fork();
if($pid == -1){
         //创建失败咱就退出呗,没啥好说的
         die(&#39;could not fork&#39;);
}
else{
        if($pid){
                //从这里开始写的代码是父进程的,因为写的是系统程序,记得退出的时候给个返回值
                exit(0);
        }
        else{
                //从这里开始写的代码都是在新的进程里执行的,同样正常退出的话,最好也给一个返回值
                exit(0);
        }
}
?>

Diese Änderung wird Machen Sie es einfacher zu verstehen. Wenn Ihr übergeordneter Prozess wissen möchte, dass der untergeordnete Prozess normal beendet wird, können Sie den vorherigen pcntl_wait hinzufügen.

2. Durch stream_socket_client-Methode

function sendStream() { 
    $english_format_number = number_format($number, 4, '.', ''); 
  
    echo $english_format_number;  
    exit(); 
    $timeout = 10; 
    $result = array(); 
    $sockets = array(); 
    $convenient_read_block = 8192; 
    $host = "test.local.com"; 
    $sql = "select waybill_id,order_id from xm_waybill where status>40 order by update_time desc limit 1 ";  
    $data = Yii::app()->db->createCommand($sql)->queryAll(); 
    $id = 0; 
  
    foreach ($data as $k => $v) { 
      if ($k % 2 == 0) { 
        $send_data[$k]['body'] = NoticeOrder::getSendData($v['waybill_id']); 
  
      } else { 
        $send_data[$k]['body'] = array($v['order_id'] => array('extra' => 16));  
      }  
      $data = json_encode($send_data[$k]['body']); 
      $s = stream_socket_client($host . ":80", $errno, $errstr, $timeout, STREAM_CLIENT_ASYNC_CONNECT | STREAM_CLIENT_CONNECT); 
      if ($s) {  
        $sockets[$id++] = $s; 
        $http_message = "GET /php/test.php?data=" . $data . " HTTP/1.0
Host:" . $host . "
";  
        fwrite($s, $http_message); 
      } else {  
        echo "Stream " . $id . " failed to open correctly."; 
      }  
    } 
  
    while (count($sockets)) { 
  
      $read = $sockets; 
  
      stream_select($read, $w = null, $e = null, $timeout); 
       if (count($read)) {  
        /* stream_select generally shuffles $read, so we need to 
         compute from which socket(s) we're reading. */
        foreach ($read as $r) { 
  
          $id = array_search($r, $sockets); 
          $data = fread($r, $convenient_read_block); 
          if (strlen($data) == 0) { 
            echo "Stream " . $id . " closes at " . date(&#39;h:i:s&#39;) . ".<br>  "; 
            fclose($r); 
             unset($sockets[$id]); 
          } else { 
            $result[$id] = $data; 
          } 
        } 
      } else {  
        /* A time-out means that *all* streams have failed 
         to receive a response. */
        echo "Time-out!
"; 
        break; 
      }  
    }  
    print_r($result); 
  
  }

3. Ersetzen Sie Multithreading durch Multiprozess

function daemon($func_name,$args,$number){ 
  while(true){ 
    $pid=pcntl_fork(); 
    if($pid==-1){ 
      echo "fork process fail"; 
      exit(); 
    }elseif($pid){//创建的子进程 
  
      static $num=0; 
      $num++; 
      if($num>=$number){ 
        //当进程数量达到一定数量时候，就对子进程进行回收。 
        pcntl_wait($status); 
  
        $num--; 
      }  
    }else{ //为0 则代表是子进程创建的，则直接进入工作状态 
  
      if(function_exists($func_name)){ 
        while (true) { 
          $ppid=posix_getpid(); 
          var_dump($ppid); 
          call_user_func_array($func_name,$args); 
          sleep(2); 
        } 
      }else{ 
        echo "function is not exists"; 
      } 
      exit();   
    } 
  } 
}  
function worker($args){  
  //do something 
  
}  
daemon('worker',array(1),2);

2. Der wirkliche Weg, Multithreading in PHP zu realisieren

Der wirkliche Weg, Multithreading in PHP zu realisieren, kann durch die Installation der PHP-Erweiterung pthread erfolgen.

Klicken Sie hier, um https://github.com/krakjoe/pthreads herunterzuladen. Dieser Download ist jedoch Version 3, die nur mit PHP 7 verwendet werden kann. Wir müssen Version 2 verwenden

Aktualisieren Sie dann die Seite wie folgt und ziehen Sie sie nach unten:

Suchen Sie auf der nächsten Seite Version 2 Seite

Herunterladen, diese Version 2 kann nur mit PHP5 verwendet werden

Herunterladen und installieren:

Oder Sie können direkt wie folgt herunterladen:

cd /tools  
   wget https://github.com/krakjoe/pthreads/archive/v2.0.10.zip  
   unzip   v2.0.10.zip  
   cd pthreads-2.0.10  
   /usr/local/php/bin/phpize  
   ./configure --with-php-config=/usr/local/php/bin/php-config    
   make  
   make install

Hinweis : Ihr PHP muss beim Kompilieren aktiviert sein –enable-maintainer-zts

./configure --prefix=/usr/local/php --disable-fileinfo --enable-fpm --with-config- file-path=/etc --with-config-file-scan-dir=/etc/php.d --with-openssl --with-zlib --with-curl --enable-ftp --with-gd - -with-xmlrpc --with-jpeg-dir --with-png-dir --with-freetype-dir --enable-gd-native-ttf --enable-mbstring --with-mcrypt=/usr/local/ libmcrypt --enable-zip --with-mysql=/usr/local/mysql --without-pear --enable-maintainer-zts

vim /etc/php.ini 
添加
extension=pthreads.so

php neu starten /etc/init.d/php-fpm restart

Vielen Dank an alle fürs Lesen, ich hoffe, dass Sie viel davon profitieren werden.

Empfohlenes Tutorial: „PHP-Tutorial“

Das obige ist der detaillierte Inhalt vonEinfache PHP-Multithreading-Lösung. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!