간단한 PHP 멀티스레딩 솔루션

간단한 PHP 멀티스레딩 솔루션

프로젝트를 진행하면서 몇 가지 요구 사항이 있었는데, 특히 PHP는 수명이 짧기 때문에 데이터 응답 처리에 많은 시간이 걸렸습니다. 스크립트 언어, 기본 30초가 지나면 PHP의 데이터 처리가 완료되지 않고 PHP의 수명 주기가 종료됩니다.

이때 비동기식 동시 처리 전략, 즉 하나의 PHP 호출에서 여러 요청을 실행할 필요가 있습니다. 이러한 요청은 순차적으로 실행되지 않지만 일부 요청은 비동기식으로 동시에 실행될 수 있습니다. 요청은 백그라운드에서 데이터를 처리하는 데 사용되며 일부 요청은 백그라운드 응답 상태를 수락하고 상태에 따라 사용자와 간단한 상호 작용을 수행하는 데 사용됩니다.

하지만 여기서 문제가 발생합니다. PHP 자체가 멀티스레딩을 지원하지 않는다는 것을 우리 모두 알고 있는데, PHP에서 멀티스레딩을 어떻게 구현해야 할까요?

1. PHP 시뮬레이션에서 멀티스레딩을 구현하는 세 가지 방법

1. Linux에서 PHP 멀티스레딩

다음은 PHP의 pcntl_fork 함수에서 파생된 것입니다. 시스템 포크, 따라서 이 기사에서 다루는 내용은 Linux/Unix에만 적용됩니다. 먼저 이 함수의 사용법을 살펴보겠습니다. PHP 매뉴얼에는 다음과 같이 나와 있습니다.

<?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
}
?>

pcntl_fork를 통해 하위 프로세스를 생성합니다. 반환 값이 -1이면 하위 프로세스 생성이 실패한 것입니다. 부모 프로세스에는 ID가 반환되고, 자식 프로세스에는 0이 반환됩니다. 이해하기 어렵기 때문에 다음과 같이 작성해야 합니다.

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

이 변경 사항은 부모 프로세스가 이를 알고 싶어하는 경우 훨씬 이해하기 쉽습니다. 하위 프로세스가 정상적으로 종료되면 이전 pcntl_wait를 추가할 수 있습니다.

2. stream_socket_client 메소드를 통해

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. 멀티 프로세스를 통해 멀티스레딩 대체

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. PHP 멀티스레딩을 구현하는 진정한 방법

php 실제 멀티스레딩 방식 PHP 설치 pthread를 확장하면 이를 수행할 수 있습니다.

다운로드하려면 여기를 클릭하세요 https://github.com/krakjoe/pthreads 하지만 이 다운로드는 버전 3이고 PHP 7에서만 사용할 수 있습니다. 버전 2를 사용해야 합니다

그런 다음 다음과 같이 페이지를 새로고침하세요. , 드래그 맨 아래로 이동:

다음 페이지에서 버전 2를 찾으세요

다운로드하세요. 이 v2는 php5에서만 사용할 수 있습니다.

다운로드 및 설치:

또는 직접 다운로드할 수도 있습니다.

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

참고: PHP에서 –enable-maintainer-zts

./configure --prefix=/usr/local/php --disable-fileinfo --enable-fpm --with-config-를 활성화해야 합니다. 파일 경로=/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

모두들 감사합니다. 이 글을 읽으시면 도움이 되셨으면 좋겠습니다.

추천 튜토리얼: "php 튜토리얼"

위 내용은 간단한 PHP 멀티스레딩 솔루션의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!