LXXXIIIソケット関数

警告

このモジュールは、実験的なものです。これは、これらの関数の動作、関数名は、このドキュメントに書かれて事項と同様に告知なく将来的なPHPのリリースで変更される可能性があります。注意を喚起するとともに、このモジュールは使用者のリスクで使用して下さい。

ソケット拡張により、ソケット通信関数への低レベルなインターフェース が実装され、クライアントとしてだけでなく、ソケットサーバーとして動作する ことが可能となります。

より一般的なクライアントサイドのソケットインターフェースについては、 fsockopen() および pfsockopen()を参照下さい。

ここで説明するソケット関数を使用する場合、多くの関数は、C言語に同 じ名前の関数が存在しますが、定義が異なっていることに注意して下さい。 混乱を避けるには、説明をよく読んで下さい。

このようにソケットソケットプログラミングと異なっている点はあります が、それでも有用な多くのUNIX man ページを参照することができます。 Web上にC言語のソケットプログラミングのチュートリアル情報が存在し、 その多くは、若干の修正により、PHPにおけるソケットプログラミングに 適当することが可能です。

例 1ソケットの例: 簡易TCP/IPサーバー

この例は、簡単な応答サーバーです。変数addressportを設定と実行環境に合うように変更して下 さい。このサーバーに次のようなコマンドで接続することが可能です。 : 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";
?>
     

目次
accept_connect -- ソケットへの接続を許可する
bind -- ソケットに名前をバインドする
close -- ファイル記述子を閉じる
connect -- ソケット上の接続を初期化する
listen -- ソケット上で接続待ち(listen)する
read -- ソケットから読みこむ
socket -- ソケットを作成する(通信時の終端)
strerror -- ソケットエラーの内容を文字列として返す
write -- ソケットに書き込む