在 symfony 6.4 中实现 sse 实时推送需使用 sseemitter 类,正确设置 content-type、注册 oncompletion/ontimeout/onerror 回调,按规范 send() 发送事件,并通过用户 id 管理连接池、禁用 nginx/php-fpm 缓冲以确保实时性。

在 Symfony 6.4 中实现服务端向浏览器实时推送消息,需借助 Server-Sent Events(SSE)协议,利用 HTTP 长连接持续发送 text/event-stream 数据流,避免轮询开销,且无需 WebSocket 的双向复杂度——关键是后端必须维持响应流不关闭、设置正确 Content-Type、并按 SSE 格式逐块输出事件。
配置控制器返回 SseEmitter 响应
在 Symfony 6.4 中,SSE 不再通过原生 PHP 输出流手动控制,而是使用 SseEmitter 类(由 symfony/http-foundation 提供),它封装了流式响应生命周期管理。创建一个控制器方法,返回 SseEmitter 实例即可启动长连接。
第一步:在控制器中声明路由并注入 Request 和 Response 相关依赖;第二步:实例化 SseEmitter,传入超时时间(如 300000 表示 5 分钟);第三步:为 onCompletion、onTimeout、onError 注册回调,确保连接断开或异常时能清理资源;第四步:将 SseEmitter 作为响应体返回,Symfony 自动设置 Content-Type: text/event-stream 和必要头部。
注意:若未显式调用 send() 方法,连接会空转直至超时;【必须在返回前注册所有监听器,否则 onError 等回调可能丢失】。
向客户端发送格式化事件数据
使用 SseEmitter::send() 方法推送事件,每次调用都会写入一块符合 SSE 规范的文本段落。标准格式包括 data:(必填)、可选的 id:(用于断线重连续传)、event:(自定义事件类型)、retry:(重连间隔毫秒数)。
方法一:发送纯文本事件
调用 $emitter->send('Hello from Symfony!');,自动包装为 data: Hello from Symfony!\n\n。
方法二:发送结构化 JSON 事件
先 json_encode(['status' => 'updated', 'count' => 12]),再 $emitter->send($jsonString);前端 EventSource 接收后需自行 JSON.parse(event.data)。
方法三:指定事件名与 ID$emitter->send(SseEvent::create()->data('new message')->event('notification')->id('msg-42'));;此时前端可用 source.addEventListener('notification', handler) 精准监听。
防止内存泄漏:绑定用户标识并管理连接池
真实场景中,每个用户需独立连接,不能让所有推送广播给所有人。必须用唯一键(如 user_id 或 JWT 解析出的 sub)索引 SseEmitter 实例,并在内存或 Redis 中持久化映射关系。
第一步:接收请求时提取 user_id(例如从 query 参数或 bearer token);
第二步:检查全局 ConcurrentHashMap 或 CacheInterface 是否已存在该用户的活跃 emitter;
第三步:若存在,直接返回已有 emitter(避免重复建立连接);
第四步:若不存在,新建 emitter 并存入缓存,同时注册 onCompletion 回调从缓存中移除该键;
第五步:在推送逻辑中,根据 user_id 查找对应 emitter 并调用 send()。
这一步漏做会导致同一用户多次刷新页面后积累多个长连接,最终耗尽服务器内存和文件描述符。
前端建立 EventSource 连接并监听事件
前端只需一行 JS 创建连接:const source = new EventSource('/api/sse?user_id=123');。浏览器自动处理重连(默认 3 秒),无需额外轮询逻辑。
监听默认事件:source.onmessage = e => console.log('收到:', e.data);;
监听自定义事件:source.addEventListener('notification', e => renderNotification(e.data));;
捕获连接错误:source.onerror = () => console.warn('SSE 连接中断');。
当用户离开页面或关闭标签页时,浏览器自动触发 onclose 并终止连接,后端 onCompletion 回调随即执行——【务必在此回调中清除缓存中的 emitter 引用,否则内存永不释放】。
部署时绕过代理缓冲:禁用 Nginx/FPM 缓存
默认 Nginx 或 PHP-FPM 会缓冲响应体,导致事件延迟数秒才到达浏览器。必须显式关闭缓冲行为。
在 Nginx 配置 location 块中添加:proxy_buffering off;、proxy_cache off;、proxy_http_version 1.1;、proxy_set_header Connection '';;
在 PHP-FPM 池配置中设置:php_flag[output_buffering] = Off;
在 Symfony 控制器中,可在 SseEmitter 构造后立即调用 $emitter->flush(); 强制刷出首块数据(含 headers)。
不配置此项,你看到的“实时”推送实际是卡在代理层的假象,调试时容易误判后端逻辑问题。











