fsockopen 连接直到超时才关闭

Question

背景： 我必须创建一个普通站点，它接受传入的发布的 XML 并通过套接字连接将 XML 发送到服务器，然后显示从服务器发回的 XML。简单易行。

问题： 我使用 fsockopen() 连接到服务器并发送 XML 没有任何问题。从服务器读取 XML 是一个全新的问题。正常的方法

while (!feof($fp)) {    
    echo fgets($fp);
}

并不能解决问题，因为服务器返回一个 XML 字符串，并且仅返回一个 XML 字符串（没有长度信息、eof、eol 等）。因此，它会等到超时，显示收到的 XML 和超时错误。我的问题与这个恐龙类似。

简而言之，我想读取套接字上的 XML，并在不再发送数据时立即关闭它（而不是等待超时）。将超时设置为较低值也不可行，因为服务器响应可能会在 2--30 秒之间变化。

解决方案： 经过一下午的挣扎，我决定分享以下这个问题的解决方案（欢迎批评）。

$fp = fsockopen("123.456.789.1", 80, $errno, $errstr, 30);
if (!$fp) {
    echo "$errstr ($errno)";
} else {
    $wait = true;    
    $out = '<samplexml><item>something</item></samplexml>';

    // [1] disable blocking
    stream_set_blocking($fp, 0);
    fwrite($fp, $out);

    while (!feof($fp)) {
        $r = fgets($fp);
        echo $r;
        if (!strcmp($r, "")){                
            if (!$wait) {
                // [2] has recieved data on this socket before
                break;
            }
        } else {
            $wait = false;
        }
    }
    fclose($fp);
}

事实证明，我的主要问题是阻塞。因此，首先，[1]我必须禁用stream_set_blocking，以便fgets()可以连续检查新数据是否可用。如果不禁用，fgets() 将从服务器获取 XML，然后循环将在第二次尝试时卡住，因为它将等待更多数据可用（这永远不会）。

我知道，一旦我们读取了一些数据，如果返回任何空的 fgets() ，我们就可以立即关闭连接（因此我们仍然可以设置 fgets()< /em> 如果有必要）。

使用这个网站几个月后，我终于在 stackoverflow 上发布了一些东西。

Answer 1

该代码片段有几个问题：

• 首先，比较 strcmp($r, "") 实际上没有意义。它有效，但没有意义。我认为 fgets 不会返回空字符串。如果没有更多可用数据，则返回FALSE。您的比较有效的原因是 FALSE 被转换为空字符串。但这会让你的代码不清晰。
• 其次，由于流处于非阻塞模式，因此数据只能暂时不可用。通过在 fgets 返回 false 时中断循环，您可能只读取操作系统缓存的第一批数据。您尝试通过强制等待尚未收到数据来解决此问题，但这是一个脆弱的解决方案。
• 最后，你忙循环等待数据。这是非常资源密集的。

最后两点可以通过使用 stream_select 来解决。通过这种方式，您可以强制执行较大的超时，直到收到第一个数据包，然后使用较小的超时。

Answer 2

您可以使用 fread() 并一次提取一个字节。效率非常低，但您可以在响应到来时对其进行解析并检测 XML 何时结束，而无需等待连接超时。在 hacky 伪代码中：

while(true) {
    $char = fread($fp, 1);
    $xml .= $char;
    if (is_complete($xml)) {
         break;
    }
}

Answer 3

我用的是插座。我发送一个 xml 字符串，也收到一个 xml 字符串。当服务器向我发送字符串 '' 时，我必须关闭套接字。在下面你可以找到我的代码，如果这可以帮助某人：

            stream_set_blocking($fp, 0);
            fwrite($fp, $in);
            $result = '';

            while (!feof($fp)) {
                $r = fgets($fp);
                $result .= $r;
                //echo $r;
                if (strstr($r, "</response>") != null)
                    break;
            }
            fclose($fp);