PHP가 multi-threading_php를 구현할 수 없는 문제를 해결하는 방법 팁

PHP에서 멀티스레딩을 구현할 수 있는 방법이 있나요? 여러 서버를 기반으로 하는 PHP 애플리케이션을 작성한다고 가정해 보겠습니다. 차례로 여러 서버에 요청을 보내는 것이 아니라 동시에 여러 서버에 요청을 보내는 것입니다. 가능합니까? 동시성 기능을 구현하려는 사람은 일반적으로 포크 또는 스폰 스레드를 사용하려고 생각하지만, PHP가 멀티스레딩을 지원하지 않는다는 사실을 알게 되면 마음이 바뀌고 Perl과 같이 충분하지 않은 언어를 사용할 수도 있습니다.
n개의 실행 중인 서버를 검사하여 해당 서버가 여전히 제대로 작동하는지 확인하는 서비스를 구축한다고 가정해 보겠습니다. 다음과 같은 코드를 작성할 수 있습니다.

$hosts = array("host1.sample.com", "host2.sample.com", "host3.sample.com"); 
$timeout = 15; 
$status = array(); 
foreach ($hosts as $host) {  
    $errno = 0;  
    $errstr = "";  
    $s = fsockopen($host, 80, $errno, $errstr, $timeout);  
    if ($s) {  
       $status[$host] = "Connectedn";  
       fwrite($s, "HEAD / HTTP/1.0rnHost: $hostrnrn");  
      do {   
        $data = fread($s, 8192);   
        if (strlen($data) == 0) {   
        break;   
        }   
       $status[$host] .= $data;  
     }  
     while (true);  
      fclose($s);  
     }  
     else {  
       $status[$host] = "Connection failed: $errno $errstrn";  
     } 
} 
print_r($status); 
?>

잘 작동하지만, 많은 수의 서버를 관리하기 위해 이 코드를 확장하면 fsockopen()이 호스트 이름을 구문 분석하고 성공적인 연결을 설정할 때까지(또는 $timeout초 지연) 오랜 시간이 걸립니다.

따라서 이 코드를 포기해야 합니다. 비동기 연결을 설정할 수 있습니다. fsockopen이 연결 상태를 반환할 때까지 기다릴 필요가 없습니다. PHP는 여전히 호스트 이름을 확인해야 하지만(IP를 직접 사용하는 것이 더 합리적임) 연결을 연 후 즉시 반환되어 다음 서버에 연결할 수 있습니다.

이를 달성하는 방법에는 두 가지가 있습니다. PHP5에서는 새로운 stream_socket_client() 함수를 사용하여 fsocketopen()을 직접 대체할 수 있습니다. PHP5 이전 버전의 경우 문제를 해결하려면 직접 수행하고 소켓 확장을 사용해야 합니다. PHP5의 솔루션은 다음과 같습니다.

$hosts = array("host1.sample.com", "host2.sample.com", "host3.sample.com"); 
$timeout = 15; 
$status = array(); 
$sockets = array(); 
/* Initiate connections to all the hosts simultaneously */ 
foreach ($hosts as $id => $host) {  
    $s = stream_socket_client("$host:80", $errno, $errstr, $timeout,  
       STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT);  
    if ($s) {  
      $sockets[$id] = $s;  
      $status[$id] = "in progress";  
    }  
    else { $status[$id] = "failed, $errno $errstr";  
    } 
} 
/* Now, wait for the results to come back in */ 
 
while (count($sockets)) {  
   $read = $write = $sockets;  
/* This is the magic function - explained below */  
   $n = stream_select($read, $write, $e = null, $timeout);  
   if ($n > 0) {  
   /* readable sockets either have data for us, or are failed  * connection attempts */  
     foreach ($read as $r) {    
          $id = array_search($r, $sockets);    
          $data = fread($r, 8192);    
     if (strlen($data) == 0) {   
          if ($status[$id] == "in progress") {   
            $status[$id] = "failed to connect";   
          }   
     fclose($r);   
     unset($sockets[$id]);    
      }  
      else {   
         $status[$id] .= $data;    
      }  
    }  
/* writeable sockets can accept an HTTP request */  
foreach ($write as $w) {   
     $id = array_search($w, $sockets);   
     fwrite($w, "HEAD / HTTP/1.0rnHost: "   
     . $hosts[$id] . "rnrn");   
     $status[$id] = "waiting for response";  
     }  
}  
else {  
/* timed out waiting; assume that all hosts associated  * with $sockets are faulty */  
foreach ($sockets as $id => $s) {   
     $status[$id] = "timed out "  
     . $status[$id];  
     }  
break;  
 } 
} 
foreach ($hosts as $id => $host) {  
   echo "Host: $hostn"; echo "Status: "  
   . $status[$id] . "nn"; 
}  
?> 

우리는 stream_select()를 사용하여 소켓 열기의 연결 이벤트를 기다립니다. stream_select()는 시스템의 select(2) 함수를 호출하여 작동합니다. 처음 세 개의 매개변수는 사용하려는 스트림의 배열입니다. (각각 세 개의 매개변수에 대해) 읽고 쓰고 예외를 가져올 수 있습니다. stream_select()는 $timeout(초) 매개변수를 설정하여 이벤트가 발생할 때까지 기다릴 수 있습니다. 이벤트가 발생하면 해당 소켓 데이터가 전달한 매개변수에 기록됩니다.

다음은 PHP 4.1.0 이상의 구현입니다. PHP를 컴파일할 때 소켓(ext/sockets) 지원을 포함했다면 위와 비슷한 코드를 사용할 수 있지만, streams/ 위의 파일 시스템 함수는 ext/sockets 함수를 사용하여 구현되었습니다. 주요 차이점은 stream_socket_client() 대신 다음 함수를 사용하여 연결을 설정한다는 것입니다.

// This value is correct for Linux, other systems have other values 
define('EINPROGRESS', 115); 
function non_blocking_connect($host, $port, &$errno, &$errstr, $timeout) {  
    $ip = gethostbyname($host);  
    $s = socket_create(AF_INET, SOCK_STREAM, 0);  
    if (socket_set_nonblock($s)) {  
      $r = @socket_connect($s, $ip, $port);  
      if ($r || socket_last_error() == EINPROGRESS) {   
         $errno = EINPROGRESS;   
         return $s;  
        }  
     }  
    $errno = socket_last_error($s);  
    $errstr = socket_strerror($errno);  
    socket_close($s);  
    return false; 
} 
?> 

이제 stream_select()를 소켓_select()로, fread()를 소켓_read()로, fwrite()를 소켓_write()로, fclose()를 소켓_close()로 교체하여 스크립트를 실행하세요!
PHP5의 발전은 stream_select()를 사용하여 거의 모든 스트림을 처리할 수 있다는 것입니다. 예를 들어, 키보드 입력을 수신하고 STDIN을 포함하여 배열에 저장할 수 있습니다. 또한 proc_open()으로 열린 파이프에서 데이터를 수신할 수도 있습니다.

이 글을 통해 PHP가 멀티스레딩을 구현할 수 없는 문제를 모두가 현명하게 해결할 수 있기를 바랍니다.