PHP 并发获取(stream_select)信息程序代码

2. $url = "www.ite5e.com";
3. if(array_key_exists(url,$_GET)){
4. $url = $_GET[url];
5. }
6. $hosts = array("www.xunlei.com", "www.qq.com", "www.163.com","www.baidu.com","www.kaixin.com","vip.xunlei.com");
7. #$hosts = array($url);
9. $timeout = 5;
10. $status = array();
11. $retdata = array();
12. $sockets = array();
13. $e = array();
14. /* Initiate connections to all the hosts simultaneously */
15. foreach ($hosts as $id => $host) {
16. $errno = 0;
17. $errstr = "";
18. $s = stream_socket_client("$host:80", $errno, $errstr, $timeout,STREAM_CLIENT_ASYNC_CONNECT|STREAM_CLIENT_CONNECT);
19. if ($s) {
20.    $sockets[$id] = $s;
21.    $status[$id] = "in progress";
22. } else {
23.    $status[$id] = "failed, $errno $errstr";
24. }
25. $retdata[$id] = ;
26. }
27. /* Now, wait for the results to come back in */
28. while (count($sockets)) {
29. $read = $write = $sockets;
30.     /* This is the magic function - explained below */
31. $n = stream_select($read, $write, $e, $timeout);
32. if ($n > 0) {
33.      /* readable sockets either have data for us, or are failed connection attempts */
34.    foreach ($read as $r) {
35.     $id = array_search($r, $sockets);
36.     $data = fread($r, 8192);
37.     if (strlen($data) == 0) {
38.      if ($status[$id] == "in progress") {
39.       $status[$id] = "failed to connect";
40.      }
41.      fclose($r);
42.      unset($sockets[$id]);
43.     } else {
44.      $retdata[$id] .= $data;
45.     }
46.    }
47.    /* writeable sockets can accept an HTTP request */
48.    foreach ($write as $w) {
49.     if(!is_resource($w))continue;
50.     $id = array_search($w, $sockets);
51.     fwrite($w, "GET / HTTP/1.0 Host: ".$hosts[$id]." ");
52.     $status[$id] = "waiting for response";
53.    }
54. } else {
55.      /* timed out waiting; assume that all hosts associated
56.      * with $sockets are faulty */
57.    foreach ($sockets as $id => $s) {
58.     $status[$id] = "timed out " . $status[$id];
59.    }
60.    break;
61. }
62. }
63. foreach ($hosts as $id => $host) {
64. #echo "Host: $host ";
66. #echo "Status: " . $status[$id] . " ";
68. #echo "Retdata: " . $retdata[$id] . " ";
70. $strs = explode(" ",$retdata[$id],2);
71. echo isset($strs[1])?$strs[1]:$retdata[$id];
72. }
73. function debug($i){
74. var_dump($i);
75. var_dump(gettype($i));
76. var_dump(is_resource($i));
77. }
78. ?>