本文详解如何在 php-fpm 架构下突破缓冲瓶颈，确保 server-sent events（sse）消息毫秒级抵达浏览器——涵盖 php 层缓冲控制、web 服务器配置、协议格式规范及生产级心跳与容错设计。
本文详解如何在 php-fpm 架构下突破缓冲瓶颈，确保 server-sent events（sse）消息毫秒级抵达浏览器——涵盖 php 层缓冲控制、web 服务器配置、协议格式规范及生产级心跳与容错设计。
Server-Sent Events（SSE）作为 W3C 标准的轻量级实时推送方案，其核心价值在于“服务端主动、单向、低开销”。但实践中，尤其在主流 PHP-FPM + Nginx/Apache 生产环境中，开发者常遭遇“连接已建立，数据却延迟数分钟才涌出”的典型问题——正如提问中描述：sleep(1) 循环本应每秒推送一次时间戳，结果浏览器长时间无响应，直到缓冲区溢出或超时才批量接收。这并非代码逻辑错误，而是数据在传输链路中被多层缓冲机制拦截所致。
? 关键症结：PHP-FPM 环境下的三重缓冲墙
根据 phpinfo() 显示，您的环境为 PHP 7.4.30 + FPM/FastCGI。此时，即使 output_buffering=off 且 zlib.output_compression=Off，数据仍需穿越以下三道关卡才能抵达浏览器：
- PHP 输出缓冲层（已关闭，安全）
- FastCGI 协议缓冲层（FPM 默认启用，根本原因）
-
Web 服务器代理缓冲层（Nginx
proxy_buffering或 Apachemod_proxy_fcgi）
✅ 验证：您注释掉
str_repeat(" ", 4096)后失效，正是因为该技巧通过填充空白“撑满”了 FastCGI 缓冲块，强制触发刷新——这是一种 hack，不可用于生产。
✅ 正确解法：逐层穿透，精准击穿
1. PHP 层：精简初始化，严守协议格式
<?php
// 【必须】禁用所有可能的缓冲（即使 php.ini 已关，也显式加固）
ini_set('output_buffering', 'off');
ini_set('zlib.output_compression', false);
while (@ob_end_clean()); // 彻底清空所有激活的输出缓冲区
// 【必须】设置 SSE 标准响应头
header('Content-Type: text/event-stream');
header('Cache-Control: no-cache');
header('Connection: keep-alive');
header('X-Accel-Buffering: no'); // 告知 Nginx 不缓存
// Apache 用户请添加：header('Proxy-Connection: keep-alive');
// 【关键】设置脚本永不超时（SSE 连接可存活数小时）
set_time_limit(0);
// 【核心】事件循环：检测信号 → 推送 → 刷新 → 等待
while (true) {
// 模拟业务事件触发（如：监听 Redis Pub/Sub、检查数据库标志位、接收进程信号）
$event_data = [
'event' => 'server-time',
'data' => ['timestamp' => date('c'), 'uptime' => time()]
];
// 严格遵循 SSE 协议：event: + data: + \n\n（换行符必须为 \n，禁用 \r\n）
echo "event: {$event_data['event']}\n";
echo "data: " . json_encode($event_data['data'], JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES) . "\n\n";
// 【双刷指令】顺序不可颠倒：先刷 PHP 缓冲，再刷 Web 服务器缓冲
if (function_exists('ob_flush')) ob_flush();
flush(); // 此处真正将数据交予 FastCGI/Nginx
// 【生产建议】加入心跳保活（防代理断连），每 30 秒发空事件
// if (time() % 30 === 0) { echo ":heartbeat\n\n"; flush(); }
// 【重要】避免空转耗资源，sleep 前可加事件轮询（如 pcntl_signal_dispatch()）
sleep(1);
}2. Web 服务器层：针对性配置（以 Nginx 为例）
location /sse.php {
# 【必配】禁用 Nginx 代理缓冲（否则首条消息永远卡住）
proxy_buffering off;
proxy_cache off;
# 【必配】延长超时，匹配 SSE 长连接特性
proxy_read_timeout 86400; # 24 小时
proxy_send_timeout 86400;
# 【必配】透传 Connection 头，保持长连接
proxy_http_version 1.1;
proxy_set_header Connection '';
# 【PHP-FPM 专用】关键！启用 FastCGI 流式传输
fastcgi_buffering off; # Nginx 1.13.12+ 必须开启
fastcgi_request_buffering off; # 防止请求体缓冲干扰响应流
# 转发至 PHP-FPM
include fastcgi_params;
fastcgi_pass php-fpm-upstream;
}⚠️ 若使用 Apache + mod_proxy_fcgi：在
<location></location>或虚拟主机中添加ProxySet flushpackets=on（Apache 2.4.31+ 支持）
并确保KeepAlive On和KeepAliveTimeout足够长。
3. 协议与健壮性增强
-
格式铁律：每条事件结尾必须是
\n\n（两个 LF），data:后必须换行，多行内容每行末尾加\n； -
ID 与重连：添加
id:字段支持断点续传，客户端EventSource自动携带Last-Event-ID； -
错误防御：在循环内捕获
connection_aborted()或connection_status() !== CONNECTION_NORMAL，优雅退出； - 连接管理：生产环境务必限制最大并发 SSE 连接数（如通过 Redis 计数器），防 DoS。
? 客户端示例（健壮监听）
const eventSource = new EventSource('/sse.php');
eventSource.addEventListener('server-time', (e) => {
const data = JSON.parse(e.data);
console.log('实时时间:', data.timestamp);
});
eventSource.onerror = (err) => {
console.error('SSE 连接异常:', err);
// 自动重连由 EventSource 内置处理（指数退避）
};
// 可选：自定义重连间隔（毫秒）
eventSource.addEventListener('open', () => {
console.log('SSE 连接已建立');
});✅ 总结：SSE 即时推送的黄金 checklist
| 层级 | 检查项 | 是否完成 |
|---|---|---|
| PHP 初始化 |
ob_end_clean() + set_time_limit(0) + X-Accel-Buffering: no
|
☐ |
| 数据输出 |
echo "data: ...\n\n" + ob_flush() + flush()
|
☐ |
| Web 服务器 |
proxy_buffering off + fastcgi_buffering off + proxy_read_timeout
|
☐ |
| 协议合规 |
\n\n 结尾、无 \r、event:/data: 标签完整 |
☐ |
| 生产防护 | 心跳保活、连接数限制、异常退出处理 | ☐ |
SSE 的本质不是“写一个循环”，而是构建一条从 PHP 内存直达浏览器 EventSource 的无阻塞数据管道。当每一层缓冲都被精准绕过，sleep(1) 就会真正变成“每秒一推”，而非“两分钟一涌”。现在，您的实时通知、日志流、数据库变更同步，都将获得毫秒级响应能力。
立即学习“PHP免费学习笔记（深入）”；
