PHP 멀티스레드 PHP fsockopen 솔루션-PHP 튜토리얼-php.cn

PHP 멀티스레드 PHP fsockopen 솔루션

不言

풀어 주다： 2023-03-23 21:12:02

원래의

2759명이 탐색했습니다.

이 문서의 내용은 PHP 멀티 스레드 PHP fsockopen 솔루션에 관한 것입니다. 특정 참조 값이 있습니다. 필요한 친구가 참조할 수 있습니다.

질문:
PHP에서 다중 스레드를 구현할 수 있는 방법이 있나요? ? 스레드는 어떻습니까?

여러 서버를 기반으로 하는 PHP 애플리케이션을 작성한다고 가정해 보겠습니다. 이상적인 상황은 차례로 여러 서버에 요청을 보내는 것이 아니라 동시에 여러 서버에 요청을 보내는 것입니다.
가능한가요?
답변:

누군가 동시성 기능을 구현하려는 경우 일반적으로 포크 또는 스폰
스레드 사용을 생각하지만 PHP가 멀티 스레딩을 지원하지 않는다는 사실을 알게 되면 마음이 바뀌고 충분하지 않은 일부를 사용할 수 있습니다. 펄과 같은 언어.

사실 대부분의 경우 포크나 실을 사용할 필요가 없고, 포크나 실을 사용하는 것보다 더 나은 성능을 얻을 수 있습니다.

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();
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";
}
}
while (count($sockets)) {
$read = $write = $sockets;
$n = stream_select($read, $write, $e = null, $timeout);
if ($n > 0) {
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;
}
}
foreach ($write as $w) {
$id = array_search($w, $sockets);
fwrite($w, "HEAD / HTTP/1.0rnHost: " . $hosts[$id] . "rnrn");
$status[$id] = "waiting for response";
}
} else {
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) 지원을 포함했다면 위와 비슷한 코드를 사용할 수 있지만 스트림/파일 시스템의 기능을 사용해야 합니다. 위의 함수.ext/sockets 함수 구현. 주요 차이점은 연결을 설정하기 위해
stream_socket_client() 대신 다음 함수를 사용한다는 것입니다.

// This value is correct for Linux, other systems have other values
define(&#39;EINPROGRESS&#39;, 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()로,
socket_write로 바꿉니다. () fwrite()를 교체하고, 소켓_close()를 사용하여 fclose()를 교체하면 스크립트를 실행할 수 있습니다!
PHP5의 발전은 stream_select()를 사용하여 거의 모든 스트림을 처리할 수 있다는 것입니다. 예를 들어 이를 사용하여 include
STDIN을 통해 키보드 입력을 수신하고 이를 배열에 저장할 수 있습니다. 열린 파이프에서 데이터를 수신할 수도 있습니다. proc_open() 데이터를 통해.
PHP4.3.x에 스트림 처리 기능을 추가하려면 fsockopen이 비동기식으로 작동하도록 패치를 준비했습니다. 이 패치는 더 이상 사용되지 않으며 공식적으로 출시된 PHP 버전에는 나타나지 않습니다. 패치에 stream_socket_client() 함수 구현을 포함시켰습니다. 이를 통해 스크립트를
PHP5와 호환되게 만들 수 있습니다.