php5函数stream_select()知识 – php多任务应用开发

<?php
$id = 0;
$delay = 15;
$timeout = 30;
$write = NULL;
$except = NULL;
$sockets = array();
$result = array();
$convenient_read_block = 8192;
$data = '';
echo "Program starts at " . date('h:i:s') . ".\n";
while ($delay > 0) {
    $fp = stream_socket_client("phaseit.net:80", $errno, $errstr, $timeout);
    if ($fp) {
        $sockets[$id++] = $fp;
        $http_message = "GET /demonstration/delay?delay=" . $delay . " HTTP/1.0\r\nHost: phaseit.net\r\n\r\n";
        fwrite($fp, $http_message);
    } else {
        echo "Stream " . $id . " failed to open correctly.";
    }
    $delay -= 3;
}
while (count($sockets)) {
    $read = $sockets;
    stream_select($read, $write, $except, $timeout);
    if (count($read)) {
        foreach ($read as $r) {
            $id = array_search($r, $sockets);
            $data = fread($r, $convenient_read_block);
            if (strlen($data) == 0) {
                echo "Stream " . $id . " closes at " . date('h:i:s') . ".\n";
                fclose($r);
                unset($sockets[$id]);
            } else {
                $result[] = $data;
            }
        }
    } else {
        /* A time-out means that *all* streams have failed
          to receive a response. */
        echo "Time-out!\n";
        break;
    }
}
//print_r($result);
?>