PHP CLI中stream_select()、信号处理与标准输入读取的最佳实践

问题背景 #

我正在编写一个原生PHP CLI应用，用于从标准输入（stdin）读取日志数据并进行后续处理。

最初的可用实现是简单的while循环：

while ($line = fgets(STDIN)) {
    // 处理逻辑
}

添加信号处理代码后：

function signal_handler(int $signo, mixed $siginfo) {
    // 信号处理逻辑
}

pcntl_async_signals(TRUE);
pcntl_signal(SIGHUP, 'signal_handler');

出现的问题：信号仅在每次fgets()执行完成后才会被处理——因为fgets()会阻塞直到有输入，期间无法响应信号。尝试用stream_select()并设置超时为NULL时，系统负载又会大幅升高。

需求：找到最佳实践，使用stream_select()与fgets()读取标准输入，有数据就绪时读取，无数据时无限等待，同时保证信号能被及时处理。

解决方案：带短超时的stream_select循环 #

核心思路是给stream_select()设置较短的固定超时（如1秒），让循环定期唤醒，既给PHP留出处理信号的窗口，又不会因为轮询过于频繁导致高负载。

实现代码 #

function signal_handler(int $signo, mixed $siginfo) {
    echo "Received signal: $signo\n";
    // 此处添加你的信号处理逻辑，比如清理资源、标记退出等
}

// 启用异步信号处理
pcntl_async_signals(true);
pcntl_signal(SIGHUP, 'signal_handler');

$stdin = fopen('php://stdin', 'r');
if (!$stdin) {
    die("Failed to open stdin\n");
}

// 标记是否需要退出循环
$shouldExit = false;

// 注册SIGINT信号处理（比如Ctrl+C触发优雅退出）
pcntl_signal(SIGINT, function() use (&$shouldExit) {
    $shouldExit = true;
    echo "\nExiting...\n";
});

while (!$shouldExit) {
    $read = [$stdin];
    $write = [];
    $except = [];

    // 用1秒超时的stream_select，定期唤醒以响应信号
    $result = stream_select($read, $write, $except, 1);

    if ($result === false) {
        // 处理stream_select被信号中断的情况，直接进入下一轮循环
        continue;
    }

    if ($result > 0) {
        // 有数据可读，读取一行
        $line = fgets($stdin);
        if ($line === false) {
            // 标准输入被关闭，退出循环
            break;
        }
        // 处理读取到的日志行
        echo "Processed line: " . trim($line) . "\n";
    }
}

fclose($stdin);

关键说明 #

1. 短超时的平衡作用：1秒的超时既保证信号最多延迟1秒被处理，又避免了轮询过于频繁导致的CPU占用飙升，是及时性与系统负载的最优平衡点。
2. 异步信号处理：pcntl_async_signals(true)会自动在PHP的事件间隙处理信号，无需手动调用pcntl_signal_dispatch()。
3. 优雅退出机制：通过$shouldExit变量在信号处理函数中标记退出，让循环能完成当前逻辑后平稳结束。
4. 错误兼容：stream_select()可能因信号中断返回false，此时直接进入下一轮循环即可，不影响整体逻辑。

为什么不使用NULL超时？ #

如果设置stream_select($read, $write, $except, null)，函数会无限阻塞直到有数据可读，此时信号同样只能在函数返回后才会被处理，和直接用fgets()的问题完全一致；而如果设置0秒超时，循环会无休无止运行，导致CPU占用率拉满。

内容的提问来源于stack exchange，提问作者Schubi Duah