Предотвратить PHP HTTP-оболочку от ожидания закрытия постоянного соединения

Question

Предотвратить PHP HTTP-оболочку от ожидания закрытия постоянного соединения

Я использую PHP-код для извлечения ресурса с HTTP-сервера через PHP HTTP обертка, лайк:

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

Пока PHP отправляет запрос HTTP / 1.0, сервер отвечает HTTP / 1.1 с ответом Connection: Keep-Alive заголовок:

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

Хотя у PHP нет возможности использовать постоянное соединение, похоже, бессмысленно ждать закрытия HTTP-соединения. Сервер закрывает его только после 60 секунд бездействия.

Есть ли какой-нибудь способ запретить PHP HTTP-оболочке ждать, пока сервер закроет соединение, но закрыть его после получения данных, объявленных Content-Length заголовок?

Или, по крайней мере, безопасно использовать fopen и fread цикл, чтение, пока я не получу Content-Length байт?

Единственный обходной путь, который я нашел, это установить timeout Опция HTTP-контекста сократить время ожидания. Но, очевидно, мне нужно установить тайм-аут достаточно высоким, чтобы убедиться, что он не прерывает чтение ответа, поэтому он все еще далек от идеального.

Другие подходы, которые я пробовал без успеха:

используйте HTTP / 1.1 (используя protocol_version опция контекста), надеясь, что это заставит PHP знать о постоянном соединении
использовать Connection: close заголовок (сервер игнорирует его)

3

http http-headers keep-alive php

Решение

Другие решения

Как кажется, нет никакого способа сделать 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;
}

0

Источник

Accepted Answer

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

Вы говорите, что сделали это, и в этом случае лучшим ответом может быть ручная запись / чтение ответа с помощью fsockopen до тех пор, пока fgets не вернет false (не используйте, потому что он зависнет, пока соединение не будет закрыто).

Ссылка: 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;
}
?>

Это, очевидно, очень просто и не содержит много ошибок, но обеспечивает предполагаемое поведение.

1