12 
$f = fsockopen("www....",80,$x,$y);

fwrite("GET request HTTP/1.1\r\nConnection: keep-alive\r\n\r\n");

while($s = fread($f,1024)){
    ...
}

上記は のため停止しConnection: keep-alive、 で動作しConnection: closeます。

どうすれば停滞せずに済みますか?

4

2 に答える 2

18

応答によって異なります。応答のtransfer-encodingが の場合chunkedは、「最後のチャンク」( \r\n0\r\n) に遭遇するまで読みます。

が の場合content-encodingはgzip、応答ヘッダーを見て、それだけのcontent-length量のデータを読み取り、それを膨らませます。もチャンクに設定されている場合はtransfer-encoding、デコードされた応答をデチャンクする必要があります。

最も簡単な方法は、応答用のデータがまだ残っている間にソケットから応答を読み取る単純なステート マシンを構築することです。

チャンク化されたデータを読み取るときは、最初のチャンク長 (およびチャンク化された拡張子) を読み取ってから、チャンク サイズと同じ量のデータを読み取り、最後のチャンクまでそれを行う必要があります。

別の言い方をすれば:

  • HTTP 応答ヘッダーを読み取ります (遭遇するまでデータの小さなチャンクを読み取ります\r\n\r\n)
  • 応答ヘッダーを配列に解析します
  • チャンクされている場合はtransfer-encoding、データを 1 つずつ読み取り、デチャンクします。
  • ヘッダーが設定されている場合content-length、ソケットからそれだけのデータを読み取ることができます
  • gzipの場合content-encodingは読み込んだデータを解凍

上記の手順を実行すると、応答全体が読み取られ、同じソケットで別の HTTP 要求を送信してプロセスを繰り返すことができます。

一方、キープアライブ接続が絶対に必要でない限りConnection: close、リクエストに設定するだけで安全に読み取ることができますwhile (!feof($f))。

現時点では、HTTP 応答を読み取って解析するための PHP コードはありません (cURL を使用しているだけです) が、実際のコードを確認したい場合はお知らせください。上記のすべてを実行する、私が作成した C# コードを紹介することもできます。

編集: これはfsockopen、HTTP 要求を発行し、チャンク エンコーディングと gzip 圧縮の可能性があるキープアライブ接続の読み取りを示すために使用する作業コードです。テスト済みですが、拷問を受けていません - ご自身の責任で使用してください!!!

<?php

/**
 * PHP HTTP request demo
 * Makes HTTP requests using PHP and fsockopen
 * Supports chunked transfer encoding, gzip compression, and keep-alive
 *
 * @author drew010 <http://stackoverflow.com/questions/11125463/if-connection-is-keep-alive-how-to-read-until-end-of-stream-php/11812536#11812536>
 * @date 2012-08-05
 * Public domain
 *
 */

error_reporting(E_ALL);
ini_set('display_errors', 1);

$host = 'www.kernel.org';

$sock = fsockopen($host, 80, $errno, $errstr, 30);

if (!$sock) {
    die("Connection failed.  $errno: $errstr\n");
}

request($sock, $host, 'GET', '/');

$headers = readResponseHeaders($sock, $resp, $msg);
$body    = readResponseBody($sock, $headers);

echo "Response status: $resp - $msg\n\n";

echo '<pre>' . var_export($headers, true) . '</pre>';
echo "\n\n";
echo $body;

// if the connection is keep-alive, you can make another request here
// as demonstrated below

request($sock, $host, 'GET', '/kernel.css');
$headers = readResponseHeaders($sock, $resp, $msg);
$body    = readResponseBody($sock, $headers);

echo "Response status: $resp - $msg\n\n";

echo '<pre>' . var_export($headers, true) . '</pre>';
echo "\n\n";
echo $body;


exit;

function request($sock, $host, $method = 'GET', $uri = '/', $params = null)
{
    $method = strtoupper($method);
    if ($method != 'GET' && $method != 'POST') $method = 'GET';

    $request = "$method $uri HTTP/1.1\r\n"
              ."Host: $host\r\n"
              ."Connection: keep-alive\r\n"
              ."Accept-encoding: gzip, deflate\r\n"
              ."\r\n";

    fwrite($sock, $request);
}

function readResponseHeaders($sock, &$response_code, &$response_status)
{
    $headers = '';
    $read    = 0;

    while (true) {
        $headers .= fread($sock, 1);
        $read    += 1;

        if ($read >= 4 && $headers[$read - 1] == "\n" && substr($headers, -4) == "\r\n\r\n") {
            break;
        }
    }

    $headers = parseHeaders($headers, $resp, $msg);

    $response_code   = $resp;
    $response_status = $msg;

    return $headers;
}

function readResponseBody($sock, array $headers)
{
    $responseIsChunked = (isset($headers['transfer-encoding']) && stripos($headers['transfer-encoding'], 'chunked') !== false);
    $contentLength     = (isset($headers['content-length'])) ? $headers['content-length'] : -1;
    $isGzip            = (isset($headers['content-encoding']) && $headers['content-encoding'] == 'gzip') ? true : false;
    $close             = (isset($headers['connection']) && stripos($headers['connection'], 'close') !== false) ? true : false;

    $body = '';

    if ($contentLength >= 0) {
        $read = 0;
        do {
            $buf = fread($sock, $contentLength - $read);
            $read += strlen($buf);
            $body .= $buf;
        } while ($read < $contentLength);

    } else if ($responseIsChunked) {
        $body = readChunked($sock);
    } else if ($close) {
        while (!feof($sock)) {
            $body .= fgets($sock, 1024);
        }
    }

    if ($isGzip) {
        $body = gzinflate(substr($body, 10));
    }

    return $body;
}

function readChunked($sock)
{   
    $body = '';

    while (true) {
        $data = '';

        do {
            $data .= fread($sock, 1);
        } while (strpos($data, "\r\n") === false);

        if (strpos($data, ' ') !== false) {
            list($chunksize, $chunkext) = explode(' ', $data, 2);
        } else {
            $chunksize = $data;
            $chunkext  = '';
        }

        $chunksize = (int)base_convert($chunksize, 16, 10);

        if ($chunksize === 0) {
            fread($sock, 2); // read trailing "\r\n"
            return $body;
        } else {
            $data    = '';
            $datalen = 0;
            while ($datalen < $chunksize + 2) {
                $data .= fread($sock, $chunksize - $datalen + 2);
                $datalen = strlen($data);
            }

            $body .= substr($data, 0, -2); // -2 to remove the "\r\n" before the next chunk
        }
    } // while (true)
}

function parseHeaders($headers, &$response_code = null, &$response_message = null)
{
    $lines  = explode("\r\n", $headers);
    $return = array();

    $response = array_shift($lines);

    if (func_num_args() > 1) {
        list($proto, $code, $message) = explode(' ', $response, 3);

        $response_code    = $code;

        if (func_num_args() > 2) {
            $response_message = $message;
        }
    }

    foreach($lines as $header) {
        if (trim($header) == '') continue;
        list($name, $value) = explode(':', $header, 2);

        $return[strtolower(trim($name))] = trim($value);
    }

    return $return;
}
于 2012-08-04T22:46:42.867 に答える
0

次のコードは私にとって問題なく動作します：

<?php
$f = fsockopen("www.google.de",80);
fwrite($f,"GET / HTTP/1.1\r\n Connection: keep-alive\r\n\r\n");

while($s = fread($f,1024)){
    echo "got: $s";
}
echo "finished;";
?>

面白いのは、キープアライブなしでこの例が私のために失速することです。コピーして貼り付けるだけでエラーが表示される例を追加できますか？

于 2012-08-05T08:59:22.180 に答える