PHP stream_select 怎么避免空转：读写集合、超时返回值与非阻塞循环

PHP 里把多个非阻塞 socket 放进一个循环时，最容易出现的症状不是报错，而是进程一直占满一个 CPU 核：循环不停检查流，却没有真正等待 I/O。stream_select() 的作用就是把这段“忙等”改成有上限的等待；不过它会原地改写传入的流数组，而且返回 0、返回 false、读到 EOF 代表三种不同情况，不能混着处理。

先复现一次“循环很忙但没有数据”的现场

下面用 stream_socket_pair() 建两个本地流：一个模拟连接端，另一个模拟事件循环。把流设为非阻塞后，如果直接反复调用 fread()，没有数据时会立刻返回，循环就会变成空转。

[$peer, $worker] = stream_socket_pair(STREAM_PF_UNIX, STREAM_SOCK_STREAM, 0);
stream_set_blocking($worker, false);

for ($i = 0; $i 

真实网络服务中，连接数一多，这种写法会把 CPU 花在重复检查上。这里别急着加 usleep()：固定休眠会让响应变慢，还无法准确覆盖多个流的同时就绪情况。

读集合每轮都要重建，不能复用上一次结果

stream_select() 的前三个参数都是引用。调用返回后，$read 里只保留已经可读的流，原来的候选集合不再完整。因此正确做法是保留一份连接池，在每轮循环里从连接池复制出本次的监视数组。

$readPool = [$worker];
$writePool = [];
$exceptPool = [];

$read = $readPool;
$write = $writePool;
$except = $exceptPool;
$ready = stream_select($read, $write, $except, 2, 500000);

if ($ready === false) {
    throw new RuntimeException('stream_select failed');
}
if ($ready === 0) {
    // 2.5 秒内没有变化：处理心跳或超时策略
} else {
    foreach ($read as $stream) {
        $chunk = fread($stream, 8192);
        // 只处理本次真正就绪的流
    }
}

超时时间由秒和微秒两个参数组成。2, 500000 表示最多等待 2.5 秒；如果两个参数都是 0，函数只检查当前状态并立即返回，这种写法适合调试，不适合拿来替代正常等待。

可读不等于一定有业务数据：EOF 要单独收口

文件结束或对端关闭连接时，流也可能出现在读集合里。此时 fread() 返回空字符串，不能把它当成“这次暂时没有数据”然后继续保留连接。否则下一轮仍可能立即返回，空转问题会重新出现。

foreach ($read as $stream) {
    $chunk = fread($stream, 8192);

    if ($chunk === '' && feof($stream)) {
        fclose($stream);
        $connections = array_filter(
            $connections,
            static fn ($candidate) => $candidate !== $stream
        );
        continue;
    }

    if ($chunk === false) {
        // 记录读取错误，按连接策略关闭或重试
        continue;
    }

    $buffer .= $chunk;
}

实际代码里建议给每个连接保存独立缓冲区，别把所有流的数据拼到一个全局字符串。这样才能在读到半条协议消息时保留边界，下一次就绪后继续补齐。

写集合只放“还有数据没发完”的连接

非阻塞流的 fwrite() 返回实际写出的字节数，可能小于缓冲区长度。连接没有待发送数据时不要一直放进 $write，否则它通常会持续处于可写状态，让事件循环不断被唤醒。

$pending = [$worker => "event: ready\n\n"];

while ($pending !== []) {
    $read = array_keys($pending);
    $write = array_keys($pending);
    $except = [];

    $ready = stream_select($read, $write, $except, 1);
    if ($ready === false) {
        throw new RuntimeException('select failed');
    }

    foreach ($write as $stream) {
        $data = $pending[$stream];
        $written = fwrite($stream, $data);
        if ($written === false) {
            unset($pending[$stream]);
            fclose($stream);
            continue;
        }
        $pending[$stream] = substr($data, $written);
        if ($pending[$stream] === '') {
            unset($pending[$stream]);
        }
    }
}

示例为了突出流程，使用了资源作为数组键；生产代码更稳妥的做法是给连接分配整数 ID，再把资源、输入缓冲区和输出缓冲区放在连接对象中管理。重点不变：有待写数据才进入写集合，写完立即移出。

把超时和异常分成两条监控信号

返回 0 说明这段等待窗口没有 I/O，并不等于服务异常。可以用它驱动心跳、空闲连接回收或定时刷新；但如果连续多个窗口都没有事件，应结合连接数、活跃请求和对端状态判断，别单凭一次超时报警。

返回 false 则要停下来检查。传入数组必须包含有效流资源，微秒参数应在合法范围内；系统调用被信号中断时，也要依据业务策略选择重建集合后继续，或记录并关闭连接。不要把 false 转成整数后和 0 一起处理，这会丢掉真正的故障信号。

常见问题

stream_select 可以监视普通文件吗？

它面向可被 select 类机制等待的流。普通文件在不同平台上的就绪语义并不适合拿来做通用事件循环，网络 socket 或支持轮询的管道更符合这个函数的使用场景。

为什么调用后 $read 变少了？

这是函数的正常行为：引用参数会被改写为本次就绪的子集。下一轮要从连接池重新复制读集合，不能把上一次的数组直接继续传入。

返回 0 是不是应该立刻重试？

可以进入下一轮，但下一轮必须重新构造三个集合。更重要的是利用这次超时处理心跳和清理逻辑，不要用固定短休眠制造另一种低效循环。

fwrite 返回 0 该怎么处理？

保留未发送内容并等待下一次可写事件，同时记录连接状态。若连续出现错误或对端已关闭，再按协议和重试策略结束连接，不能直接丢掉剩余缓冲区。

一份可以落地的验收清单

改造事件循环后，先用两个本地流验证“有数据时能读到”，再关闭对端验证 EOF 会移除连接，最后发送一段明显大于单次写入能力的内容，确认部分写入会在后续可写事件中补齐。压测时重点看 CPU 空转、超时次数、活跃连接数和未发送缓冲区长度。

stream_select() 的最小原则很短：候选集合由连接池生成，就绪集合只用于当前轮；0 是等待结束，false 是调用失败，空字符串加 feof() 是连接收尾。把这几个分支拆开，非阻塞循环才真正有可控的等待和退出路径。