1

ポートをリッスンして無限に実行されるPHPスクリプト（オンラインで見つけました）があり、このポートへの接続が確立されるとTCP connection. しかし、このスクリプトを実行して接続数が多い (500 前後) と、CLOSE_WAIT接続数が増加します。この状態で接続されているリモート デバイスは、CLOSE_WAITが終了していないため、再接続できません。

// port info
$host = "0.0.0.0";
$port = 10260;
$pos = 1;

// don't timeout!
set_time_limit(0);
record("START");

$sock = socket_create(AF_INET, SOCK_STREAM, 0);
$timeout = array('sec'=>3000,'usec'=>0);
$try = socket_set_option($sock,SOL_SOCKET,SO_RCVTIMEO,$timeout);

// Bind the socket to the address/port
if(!socket_bind($sock, $host, $port))
{
    echo socket_last_error() ;
    die('Could not bind to address');
}
record("SOCKET BIND OK");

// start listening for connections
$result = socket_listen($sock, 1024) or die("Could not set up socket listener\n");
record("SOCKET LISTEN OK");
$clients = array($sock);


// infinite while loop
while(1)
{

    // Setup clients listen socket for reading
    $read = $clients;

    $e = NULL;

    if (socket_select($read, $write = NULL, $except = NULL, 0,0) < 1) 
    {
       continue;
    }

    /* if a new read ready is being made add it to the client array */

    if (in_array($sock, $read)) {
        record("NEW CONNECTION");
        $clients[$pos] = $newsock = socket_accept($sock);
        $curpos = $pos;
        $pos++;
        socket_getpeername($newsock, $ip,$port);
        record("Incoming IP: {$ip} PORT: {$port}");
        // remove the listening socket from the clients-with-data array
        $key = array_search($sock, $read);
        unset($read[$key]);

    } // end if in_array

    // loop through all the clients that have data to read from
    foreach ($read as $read_key => $read_sock) {
        // read until newline or 1024 bytes
        // socket_read while show errors when the client is disconnected, so silence the error messages
        $key = $read_key;
        $fulldata = $data = @socket_read($read_sock, 1024);

        // check if the client is disconnected
        if ($data === false) {
            // remove client for $clients array
            $key = array_search($read_sock, $clients);
            socket_close($read_sock);
            unset($clients[$key]);

            record("NO DATA");

            // continue to the next client to read from, if any
            continue;
        }


        // .. do something with $data ...

    }


}

socket_close($sock);    
record("END");
die("DONE");

socket_close()コードで使用しようとしましたが、役に立ちませんでした。CLOSE_WAIT次の状態に移行するのに時間がかかるようです。

4

1 に答える 1

3

コードに 2 つの問題が見つかりました。

まず、socket_select の 4 番目のパラメーター (tv_sec) は 0 ではなく NULL にする必要があります。マニュアルで説明されているように、0 を指定すると無駄な無限ループで CPU 負荷が高くなり、NULL を指定すると何かが起こるまでブロックされます。

tv_sec が 0 の場合、socket_select() はすぐに戻ります。これは、ポーリングに役立ちます。tv_sec が NULL (タイムアウトなし) の場合、socket_select() は無期限にブロックできます。

2 つ目は、CLOSE_WAIT の理由は $data が false の場合のテストだと思います。これはグレースフル クローズド接続でのみ機能しますが、ここのコメントの 1 つにあるように、空の文字列でもテストする必要があります。したがって、1 行を次のように変更します。

if (socket_select($read, $write = NULL, $except = NULL, NULL, 0) < 1)

もう一方は:

// check if the client is disconnected
if ($data === false || $data === '') {

そして、あなたは大丈夫なはずです

于 2013-09-30T11:22:47.927 に答える