PHP中使用socket通信响应速度慢的原因与解决办法

在PHP中作为客户端与服务器端使用socket进行通信时，一般我们使用fsockopen，但在使用这个函数进行通信时，有时候发现数据的反应时间特别长，更有甚者能达到1分钟。以下是代码片段：

<?php

function send($data /* String */) {
    $result = '';
    
    $fp = fsockopen($this->url, $this->port, $errno, $errstr, 10);
    
    if (!$fp) {
        return null;
    } else {
        fputs($fp, $this->method." ".$this->uri." HTTP/1.1\r\n");
        fputs($fp, "Host: ".$this->url.":".$this->port."\r\n");
        fputs($fp, "Content-type: text/html;charset=".$this->charset."\r\n");
        fputs($fp, "Accept-Language: zh-cn\r\n");
        fputs($fp, "User-Agent: Mozilla/4.0(Compatible win32; MSIE)\r\n");
        fputs($fp, "Content-Length: ".strlen($data)."\r\n");
        fputs($fp, "Connection: close\r\n\r\n");
        fputs($fp, $data);
        
        while(!feof($fp)) {
            $result .= fgets($fp, 1024);
        }
        
        fclose($fp);
        
        $arr = split("\r\n", $result);
        $state = split(" ", $arr[0]);
        
        if (substr($state[1], 0, 1) != 2) {
            return null;
        } else {
            return substr($result, strpos($result, "\r\n\r\n") + 4);
        }
    }
}

上面这段代码就会有时候出现数据响应时间特别长。经过调试发现问题出在fgets这个函数的返回上，最后一次数据返回的时间很长，说是数据返回不如说是服务器端因为超时断开了连接。经过查阅手册会发现，关于fgets的返回的条件为：碰到换行符（包括在返回值中）、EOF 或者已经读取了 length - 1 字节后停止（看先碰到那一种情况）。

问题就出在服务器端缓冲会话的时候是不会返回结束标志，也不返回换行符的情况。那么我们可以通过以下方法来解决这个问题。

设置一个返回长度$length = 1024。第一次时使用这个长度，当有数据返回时，取出数据的长度$len，然后根据返回的数据来计算还有多少剩余的数据，这样就可以根据$length与（剩余的长度+1）找出最小值$min。下次fgets时的返回长度修正为$min。这样就可以正常的判断返回数据的大小。部分代码如下：

<?php
function send($data /* String */) {
    $result = '';
    
    $fp = fsockopen($this->url, $this->port, $errno, $errstr, 10);
    
    if (!$fp) {
        return null;
    } else {
        fputs($fp, $this->method." ".$this->uri." HTTP/1.1\r\n");
        fputs($fp, "Host: ".$this->url.":".$this->port."\r\n");
        fputs($fp, "Content-type: text/html;charset=".$this->charset."\r\n");
        fputs($fp, "Accept-Language: zh-cn\r\n");
        fputs($fp, "User-Agent: Mozilla/4.0(Compatible win32; MSIE)\r\n");
        fputs($fp, "Content-Length: ".strlen($data)."\r\n");
        fputs($fp, "Connection: close\r\n\r\n");
        fputs($fp, $data);
        
        $len    = -1;
        $length = 1024;
        while(!feof($fp)) {
            $result .= fgets($fp, $length);
            
            if (stripos($result, "\r\n\r\n") !== false) {
                $start = stripos($result, "Content-Length:") + 15;
                
                if ($start !== false && $len < 0) {
                    $end = stripos($result, "\r\n", $start);
                    $len = trim(substr($result, $start, stripos($result, "\r\n", $start) - $start));
                }
                
                if ($len > 0) {
                    $str = substr($result, strpos($result, "\r\n\r\n") + 4);
                    $length = min($length, $len - strlen($str) + 1);
                }
                
                if ($length < 2) {
                    fclose($fp);
                    return $str;
                }
            }
        }
    }
}