Discuz! dfopen 优化 timeout 版

Discuz! 里的函数 dfopen 确实很强大, 不过会遇到一点点小麻烦, 就是并不能完全按照 timeout 设置的时间中断连接.
原函数中只有一次判断, 也就是说当连接成功后, 数据未发送完毕之前连接中断了, 并不能中断该连接, 将造成程序锁死.
所以对原函数做了一些改动, 以避免该情况的发生.

1. 
   
2. 
   
3. /*
   
4. 改进后的 dfopen
   
5. */
   
6. 
   
7. function dfopen($url, $limit = 0, $post = '', $cookie = '', $bysocket = FALSE, $ip = '', $timeout = 15, $block = TRUE) {
   
8.         $return = '';
   
9.         $matches = parse_url($url);
   
10.         $host = $matches['host'];
    
11.         $path = $matches['path'] ? $matches['path'].($matches['query'] ? '?'.$matches['query'] : '') : '/';
    
12.         $port = !empty($matches['port']) ? $matches['port'] : 80;
    
13. 
    
14.         if($post) {
    
15.                 $out = "POST $path HTTP/1.0\r\n";
    
16.                 $out .= "Accept: */*\r\n";
    
17.                 //$out .= "Referer: $boardurl\r\n";
    
18.                 $out .= "Accept-Language: zh-cn\r\n";
    
19.                 $out .= "Content-Type: application/x-www-form-urlencoded\r\n";
    
20.                 $out .= "User-Agent: $_SERVER[HTTP_USER_AGENT]\r\n";
    
21.                 $out .= "Host: $host\r\n";
    
22.                 $out .= 'Content-Length: '.strlen($post)."\r\n";
    
23.                 $out .= "Connection: Close\r\n";
    
24.                 $out .= "Cache-Control: no-cache\r\n";
    
25.                 $out .= "Cookie: $cookie\r\n\r\n";
    
26.                 $out .= $post;
    
27.         } else {
    
28.                 $out = "GET $path HTTP/1.0\r\n";
    
29.                 $out .= "Accept: */*\r\n";
    
30.                 //$out .= "Referer: $boardurl\r\n";
    
31.                 $out .= "Accept-Language: zh-cn\r\n";
    
32.                 $out .= "User-Agent: $_SERVER[HTTP_USER_AGENT]\r\n";
    
33.                 $out .= "Host: $host\r\n";
    
34.                 $out .= "Connection: Close\r\n";
    
35.                 $out .= "Cookie: $cookie\r\n\r\n";
    
36.         }
    
37.         $fp = @fsockopen(($ip ? $ip : $host), $port, $errno, $errstr, $timeout);
    
38.         if(!$fp) {
    
39.                 return '';//note $errstr : $errno \r\n
    
40.         } else {
    
41.                 stream_set_blocking($fp, $block);
    
42.                 stream_set_timeout($fp, $timeout);
    
43.                 @fwrite($fp, $out);
    
44.                 while (!feof($fp)) {
    
45.                         $status = stream_get_meta_data($fp);
    
46.                         if(!empty($status['timed_out'])) {
    
47.                                 return '';
    
48.                         }
    
49.                         if(($header = @fgets($fp)) && ($header == "\r\n" ||  $header == "\n")) {
    
50.                                 break;
    
51.                         }
    
52.                 }
    
53.                 $stop = false;
    
54.                 while(!feof($fp) && !$stop) {
    
55.                         $status = stream_get_meta_data($fp);
    
56.                         if(!empty($status['timed_out'])) {
    
57.                                 return '';
    
58.                         }
    
59.                         $data = fread($fp, ($limit == 0 || $limit > 8192 ? 8192 : $limit));
    
60.                         $return .= $data;
    
61.                         if($limit) {
    
62.                                 $limit -= strlen($data);
    
63.                                 $stop = $limit <= 0;
    
64.                         }
    
65.                 }
    
66.                 @fclose($fp);
    
67.                 return $return;
    
68.         }
    
69. }
    
70. 
    
71. 
    
72. 
    

复制代码

原函数

1. 
   
2. /*
   
3. Discuz! 原 dfopen 函数
   
4. */
   
5. function dfopen($url, $limit = 0, $post = '', $cookie = '', $bysocket = FALSE, $ip = '', $timeout = 15, $block = TRUE) {
   
6.         $return = '';
   
7.         $matches = parse_url($url);
   
8.         $host = $matches['host'];
   
9.         $path = $matches['path'] ? $matches['path'].($matches['query'] ? '?'.$matches['query'] : '') : '/';
   
10.         $port = !empty($matches['port']) ? $matches['port'] : 80;
    
11. 
    
12.         if($post) {
    
13.                 $out = "POST $path HTTP/1.0\r\n";
    
14.                 $out .= "Accept: */*\r\n";
    
15.                 //$out .= "Referer: $boardurl\r\n";
    
16.                 $out .= "Accept-Language: zh-cn\r\n";
    
17.                 $out .= "Content-Type: application/x-www-form-urlencoded\r\n";
    
18.                 $out .= "User-Agent: $_SERVER[HTTP_USER_AGENT]\r\n";
    
19.                 $out .= "Host: $host\r\n";
    
20.                 $out .= 'Content-Length: '.strlen($post)."\r\n";
    
21.                 $out .= "Connection: Close\r\n";
    
22.                 $out .= "Cache-Control: no-cache\r\n";
    
23.                 $out .= "Cookie: $cookie\r\n\r\n";
    
24.                 $out .= $post;
    
25.         } else {
    
26.                 $out = "GET $path HTTP/1.0\r\n";
    
27.                 $out .= "Accept: */*\r\n";
    
28.                 //$out .= "Referer: $boardurl\r\n";
    
29.                 $out .= "Accept-Language: zh-cn\r\n";
    
30.                 $out .= "User-Agent: $_SERVER[HTTP_USER_AGENT]\r\n";
    
31.                 $out .= "Host: $host\r\n";
    
32.                 $out .= "Connection: Close\r\n";
    
33.                 $out .= "Cookie: $cookie\r\n\r\n";
    
34.         }
    
35.         $fp = @fsockopen(($ip ? $ip : $host), $port, $errno, $errstr, $timeout);
    
36.         if(!$fp) {
    
37.                 return '';
    
38.         } else {
    
39.                 stream_set_blocking($fp, $block);
    
40.                 stream_set_timeout($fp, $timeout);
    
41.                 @fwrite($fp, $out);
    
42.                 $status = stream_get_meta_data($fp);
    
43.                 if(!$status['timed_out']) {
    
44.                         while (!feof($fp)) {
    
45.                                 if(($header = @fgets($fp)) && ($header == "\r\n" ||  $header == "\n")) {
    
46.                                         break;
    
47.                                 }
    
48.                         }
    
49. 
    
50.                         $stop = false;
    
51.                         while(!feof($fp) && !$stop) {
    
52.                                 $data = fread($fp, ($limit == 0 || $limit > 8192 ? 8192 : $limit));
    
53.                                 $return .= $data;
    
54.                                 if($limit) {
    
55.                                         $limit -= strlen($data);
    
56.                                         $stop = $limit <= 0;
    
57.                                 }
    
58.                         }
    
59.                 }
    
60.                 @fclose($fp);
    
61.                 return $return;
    
62.         }
    
63. }
    

复制代码

顶楼主 楼主观点不错  

www.ZTSUN.COM  充气娃娃多少钱
www.szyuantaidz.com  脚气
www.yushenjt.com  阴茎短小
www.btdyj.com  脚臭
www.1tidc.com  蹭网器
www.cn-xyz.com  卡皇
www.hfloge.com  白发治疗
www.hnshiqi.com  英国卫裤
www.wzeas.com  治疗白发
www.qdzjzc.com  伟哥官网
www.szjczq.com  日本充气娃娃