阻止PHP HTTP包装器等待持久连接的关闭

Question

我正在使用PHP代码通过PHP HTTP wrapper从HTTP服务器检索资源，如：

file_get_contents("http://...");

当PHP发送HTTP / 1.0请求时，服务器使用Connection: Keep-Alive头响应HTTP / 1.1响应：

HTTP/1.1 200 OK
Connection: Keep-Alive
Content-Length: ...

虽然PHP无法使用持久连接，但似乎毫无意义地等待HTTP连接关闭。服务器仅在60秒不活动后关闭它。

---

有没有办法阻止PHP HTTP包装器等待服务器关闭连接，但在收到Content-Length头部公布的数据后自行关闭它？

或者至少使用fopen和fread循环是否安全，阅读直到我得到Content-Length字节？

---

我发现的唯一解决方法是设置timeout HTTP context option以减少等待时间。但显然我需要将超时设置得足够高，以确保它不会中断响应的读取，所以它仍然远非理想状态。

---

我尝试过的其他方法没有成功：

• 使用HTTP / 1.1（使用protocol_version上下文选项），希望它能让PHP知道持久连接
• 使用Connection: close标头（服务器忽略它）

Answer 1

$context = stream_context_create(array('http' => array('header'=>"Connection: close\r\n")));
file_get_contents("http://...",false,$context);

你说你已经完成了这个，在这种情况下，一个更好的答案可能是使用fsockopen手动写/读响应，直到fgets返回false（不要使用feof它会挂起，直到连接关闭）。

参考：http://php.net/manual/en/function.fsockopen.php和http://php.net/manual/en/function.fgets.php

编辑：如前所述，经过进一步测试后，我已经确认这确实也有问题，所以这里有一个正确修改的解决方案

<?php
$handle = fsockopen("google.com", 80);
if ($handle) {
    $out = "GET / HTTP/1.1\r\n";
    $out .= "Host: google.com\r\n";
    $out .= "Connection: Keep-Alive\r\n\r\n";
    fwrite($handle, $out);

    $bytesread = 0;
    while (($buffer = fgets($handle, 4096)) !== false) {
        if(strpos($buffer, "Content-Length:") !== false) {
                list(, $len) = explode("Content-Length: ", $buffer);
        }

        if($buffer === "\r\n") {
                break;
        }
    }

    $data = '';
    while($bytesread != intval($len)) {
        $buf = fgets($handle, 1024);
        $bytesread += strlen($buf);
        $data .= $buf;
    }
    fclose($handle);
    print $data;
}
?>

这显然非常简单，并且缺少相当多的错误检查，但提供了预期的行为。

Answer 2

由于似乎没有办法让get_file_contents跟随Content-Length标题，我最终使用自己的实现：

// parse $http_response_header auto variable to associative array
function get_http_response_headers($http_response_header)
{
    $response_headers = array();
    if (isset($http_response_header))
    {
        foreach ($http_response_header as $header)
        {
            $i = strpos($header, ":");
            if ($i !== false)
            {
                $name = trim(substr($header, 0, $i));
                $value = trim(substr($header, $i+1));
            }
            else
            {
                $name = trim($header);
                $value = NULL;
            }
            $name = strtolower($name);
            $response_headers[$name] = $value;
        }
    }
    else
    {
        $response_headers = array();
    }

    return $response_headers;
}

// Replacement for file_get_contents that follows Content-Length header
function http_get_contents($url, $context)
{
    $h = fopen($url, "r", false, $context);
    $result = ($h !== false);
    if ($result)
    {
        $response_headers = get_http_response_headers($http_response_header);

        $len = null;
        // If it is not persistent connection, just read to the end,
        // as file_get_contents does
        if (isset($response_headers["connection"]) &&
            (strcasecmp($response_headers["connection"], "close") == 0))
        {
            $len = false;
        }
        // If it is not persistent connection, follow Content-Length
        else if (isset($response_headers["content-length"]))
        {
            $len = intval($response_headers["content-length"]);
        }
        else
        {
            trigger_error("No Content-Length or Connection:close header");
            $result = false;
        }

        if ($result)
        {
            $result = null;
            $total = 0;
            while (true)
            {
                $toread = ($len === false) ? 16384 : ($len - $total);
                $buf = fread($h, $toread);
                if ($buf === false)
                {
                    trigger_error("Reading HTTP failed");
                    $result = false;
                    break;
                }
                else
                {
                    $read = strlen($buf);
                    $total += $read;
                    $result .= $buf;
                    if ($len !== false)
                    {
                        if ($read > $len)
                        {
                            trigger_error("Read too much data $read > $len");
                            break;
                        }
                        else if ($read == $len)
                        {
                            // done
                            break;
                        }
                    }
                    else
                    {
                        if ($read == 0)
                        {
                            // done
                            break;
                        }
                    }
                }
            }
        }

        fclose($h);
    }

    return $result;
}