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

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. ?>

http://www.bkjia.com/PHPjc/486113.htmlwww.bkjia.comtruehttp://www.bkjia.com/PHPjc/486113.htmlTechArticle?php $url = "www.ite5e.com"; if(array_key_exists(url,$_GET)){ $url = $_GET[url]; } $hosts = array("www.xunlei.com", "www.qq.com", "www.163.com","www.baidu.com","www.kaixin.com","vi...