LXVIII. ソケット関数
ソケット拡張により、ソケット通信関数への低レベルなインターフェース
が実装され、クライアントとしてだけでなく、ソケットサーバーとして動作する
ことが可能となります。
より一般的なクライアントサイドのソケットインターフェースについては、
fsockopen() および
pfsockopen()を参照下さい。
ここで説明するソケット関数を使用する場合、多くの関数は、C言語に同
じ名前の関数が存在しますが、定義が異なっていることに注意して下さい。
混乱を避けるには、説明をよく読んで下さい。
このようにソケットソケットプログラミングと異なっている点はあります
が、それでも有用な多くのUNIX man ページを参照することができます。
Web上にC言語のソケットプログラミングのチュートリアル情報が存在し、
その多くは、若干の修正により、PHPにおけるソケットプログラミングに
適当することが可能です。
例 1. ソケットの例: 簡易TCP/IPサーバー
この例は、簡単な応答サーバーです。変数address
とportを設定と実行環境に合うように変更して下
さい。このサーバーに次のようなコマンドで接続することが可能です。
: telnet 192.168.1.53 10000 (ただし、アドレス
とポートは設定に合わせます)入力したものは、サーバー側の出力とな
り、エコーバックされます。接続を閉じるには、'quit'を入力します。
<?php
error_reporting(E_ALL);
/* 接続待ちの間、スクリプトを待機させるようにする。 */
set_time_limit(0);
$address = '192.168.1.53';
$port = 10000;
if (($sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
echo "socket() failed: reason: " . strerror($sock) . "\n";
}
if (($ret = bind($sock, $address, $port)) < 0) {
echo "bind() failed: reason: " . strerror($ret) . "\n";
}
if (($ret = listen($sock, 5)) < 0) {
echo "listen() failed: reason: " . strerror($ret) . "\n";
}
do {
if (($msgsock = accept_connect($sock)) < 0) {
echo "accept_connect() failed: reason: " . strerror($msgsock) . "\n";
break;
}
do {
$buf = '';
$ret = read($msgsock, $buf, 2048);
if ($ret < 0) {
echo "read() failed: reason: " . strerror($ret) . "\n";
break 2;
}
if ($ret == 0) {
break 2;
}
$buf = trim($buf);
if ($buf == 'quit') {
close($msgsock);
break 2;
}
$talkback = "PHP: You said '$buf'.\n";
write($msgsock, $talkback, strlen($talkback));
echo "$buf\n";
} while (true);
close($msgsock);
} while (true);
close($sock);
?>
|
|
例 2. ソケットの例: 簡易 TCP/IP クライアント
この例は、簡単な一回限りのHTTPクライアントです。ここでは、あるペー
ジに接続し、HEADリクエストを送信し、応答を出力た後、終了します。
<?php
error_reporting(E_ALL);
echo "<h2>TCP/IP Connection</h2>\n";
/* WWWサービスのポートを得る。 */
$service_port = getservbyname('www', 'tcp');
/* ターゲットホストのIPアドレスを得る。 */
$address = gethostbyname('www.php.net');
/* TCP/IPソケットを作成する。 */
$socket = socket(AF_INET, SOCK_STREAM, 0);
if ($socket < 0) {
echo "socket() failed: reason: " . strerror($socket) . "\n";
} else {
"socket() successful: " . strerror($socket) . "\n";
}
echo "Attempting to connect to '$address' on port '$service_port'...";
$result = connect($socket, $address, $service_port);
if ($result < 0) {
echo "connect() failed.\nReason: ($result) " . strerror($result) . "\n";
} else {
echo "OK.\n";
}
$in = "HEAD / HTTP/1.0\r\n\r\n";
$out = '';
echo "Sending HTTP HEAD request...";
write($socket, $in, strlen($in));
echo "OK.\n";
echo "Reading response:\n\n";
while (read($socket, $out, 2048)) {
echo $out;
}
echo "Closing socket...";
close($socket);
echo "OK.\n\n";
?>
|
|