Heim  >  Artikel  >  Backend-Entwicklung  >  Gemeinsame Nutzung von PHP-Multithreading-Lösungen

Gemeinsame Nutzung von PHP-Multithreading-Lösungen

小云云
小云云Original
2018-03-22 10:30:301853Durchsuche

Wir alle wissen, dass PHP selbst kein Multithreading unterstützt. Wie sollten wir also Multithreading in PHP implementieren? In diesem Artikel stellen wir Ihnen hauptsächlich die PHP-Multithreading-Lösung vor und hoffen, allen zu helfen.

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. Schauen wir uns also zunächst die Verwendung dieser Funktion an:

<?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, erfolgt die Erstellung des untergeordneten Prozesses fehlgeschlagen. Die erfolgreiche 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 Dies erleichtert das Verständnis. Wenn Ihr übergeordneter Prozess wissen möchte, ob 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, &#39;.&#39;, &#39;&#39;); 
  
    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][&#39;body&#39;] = NoticeOrder::getSendData($v[&#39;waybill_id&#39;]); 
  
      } else { 
        $send_data[$k][&#39;body&#39;] = array($v[&#39;order_id&#39;] => array(&#39;extra&#39; => 16));  
      }  
      $data = json_encode($send_data[$k][&#39;body&#39;]); 
      $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\r\nHost:" . $host . "\r\n\r\n";  
        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&#39;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!\n"; 
        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(&#39;worker&#39;,array(1),2);

2. Der wahre Weg, Multithreading in PHP zu realisieren

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

Gemeinsame Nutzung von PHP-Multithreading-Lösungen

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

Gemeinsame Nutzung von PHP-Multithreading-Lösungen



Gemeinsame Nutzung von PHP-Multithreading-Lösungen

Suchen Sie Version 2 auf der nächsten Seite

und laden Sie sie herunter. Diese Version 2 kann nur mit PHP5 verwendet werden

Herunterladen Kommen Sie herunter und installieren Sie:

Oder Sie können es direkt 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 von –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  
/etc/init.d/php-fpm restart
Verwandte Empfehlungen:

Detaillierte Erläuterung des Multithreading-Mechanismus des Browsers

Detaillierte Erläuterung von PHP-Multithreading-Beispiele

PHPs Unterstützung und Verwendung von Multithread-Programmierung

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

Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn