php fsockopenソリューション

php fsockopen ソリューション

最近 PHP マルチスレッドの問題を調査したところ、中国語のリソースが非常に少ないことがわかりました。いくつかの記事は何度も再投稿されていますが、記事の内容の価値は限られています。検索中に、多くの海外サイトで引用されている、よく書かれた記事を見つけたので翻訳してみました。

著作権表示: 転載は自由です。転載する場合は、必ず記事とこの記述の出典と著者情報をハイパーリンクの形式で明記してください。
http://blog. iyi.cn/start/

質問:
PHP でマルチスレッドを実装する方法はありますか?

複数のサーバーに基づいて PHP アプリケーションを作成しているとします。理想的な状況は、リクエストを次々に送信するのではなく、同時に複数のサーバーに送信することです。
それは可能ですか？
答え:

同時実行機能を実装したいとき、通常、フォークまたは生成スレッドを使用することを考えますが、PHP がマルチスレッドをサポートしていないことがわかると、考えを変え、perl などの十分ではない言語を使用する可能性があります。 。

実際、ほとんどの場合、フォークやスレッドを使用する必要はなく、フォークやスレッドを使用するよりもパフォーマンスが向上します。

n 台の実行中のサーバーが正常に機能していることを確認するサービスを構築するとします。次のようなコードを書くとよいでしょう:

?

<?php 
$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 を直接使用する方が賢明です) が、接続を開いた後すぐにホスト名が返されるため、次のサーバーに接続できます。
これを実現するには 2 つの方法があります。PHP5 では、新しい stream_socket_client() 関数を使用して fsocketopen() を直接置き換えることができます。 PHP5 より前のバージョンの場合、問題を解決するには自分で実行し、ソケット拡張機能を使用する必要があります。

PHP5 での解決策は次のとおりです:

<?php 
$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) 関数を呼び出して機能します。最初の 3 つのパラメータは、使用するストリームの配列であり、(3 つのパラメータごとに) 読み取り、書き込み、例外の取得が可能です。 stream_select() は、$timeout (秒) パラメータを設定することでイベントが発生するのを待つことができます。イベントが発生すると、渡したパラメータに対応するソケット データが書き込まれます。

以下は PHP 4.1.0 以降の実装です。PHP のコンパイル時にソケット (ext/sockets) サポートを組み込んでいる場合は、上記と同様のコードを使用できますが、streams/ の関数を追加する必要があります。上記のファイルシステム関数は ext/sockets 関数を使用して実装されています。主な違いは、stream_socket_client() の代わりに次の関数を使用して接続を確立することです:

<?php 
// 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() をsocket_select()、fread() をsocket_read()、fwrite() をsocket_write()、fclose() をsocket_close()に置き換えて、スクリプトを実行します。
PHP5 の進歩は、stream_select() を使用してほぼすべてのストリームを処理できることです。たとえば、これを使用して、STDIN を含めてキーボード入力を受信し、配列に保存したり、 proc_open() データを通じてパイプが開かれました。
PHP4.3.xにストリーム処理機能を持たせたい場合は、fsockopenを非同期で動作させるパッチを用意しました。このパッチは非推奨であり、正式にリリースされた PHP バージョンには含まれません。このパッチには stream_socket_client() 関数の実装が含まれており、これを使用してスクリプトを PHP5 と互換性を持たせることができます。