Symfony 6.4 怎么创建消息推送?SSE技术

胖墨同学_8051

胖墨同学_8051

2026-08-07

903人浏览

原创

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

symfony 6.4 怎么创建消息推送?sse技术

在 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 中持久化映射关系。

Symfony Linux版
Symfony Linux版

Symfony Linux版整理 Symfony CLI 5.17.1 官方下载入口和 Symfony 框架安装配置说明。

下载

第一步:接收请求时提取 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)。

不配置此项,你看到的“实时”推送实际是卡在代理层的假象,调试时容易误判后端逻辑问题。

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
PHP Symfony框架
PHP Symfony框架

本专题专注于PHP主流框架Symfony的学习与应用,系统讲解路由与控制器、依赖注入、ORM数据操作、模板引擎、表单与验证、安全认证及API开发等核心内容。通过企业管理系统、内容管理平台与电商后台等实战案例,帮助学员全面掌握Symfony在企业级应用开发中的实践技能。

2025.09.11

4577

17

PHP API接口开发与RESTful实践
PHP API接口开发与RESTful实践

本专题聚焦 PHP在API接口开发中的应用,系统讲解 RESTful 架构设计原则、路由处理、请求参数解析、JSON数据返回、身份验证(Token/JWT)、跨域处理以及接口调试与异常处理。通过实战案例(如用户管理系统、商品信息接口服务),帮助开发者掌握 PHP构建高效、可维护的RESTful API服务能力。

2025.11.26

504

16

Buffalo框架数据库开发全教程
Buffalo框架数据库开发全教程

本专题围绕Buffalo框架数据库开发,讲解database.yml多环境配置、soda与fizz迁移生成回滚、模型结构体标签、增删改查与条件查询、一对多与多对多关联、数据校验、回调钩子、事务处理及原生SQL执行能力。

2026.09.23

60

15

Buffalo框架路由与请求处理实操指南
Buffalo框架路由与请求处理实操指南

本专题讲解Buffalo框架路由与请求处理机制,涵盖路由注册与分组、资源路由、Handler编写规范、Context上下文方法、参数绑定、中间件编写挂载、Session与Cookie读写、Flash消息及错误页面定制方法。

2026.09.23

20

15

Buffalo框架零基础入门教程
Buffalo框架零基础入门教程

本专题整理Buffalo框架入门内容,涵盖Go环境准备、buffalo CLI安装、新项目生成、目录结构说明、dev热加载启动、数据库连接配置与常见报错排查,帮助新手按约定优于配置的思路跑通第一个Buffalo框架应用。

2026.09.23

20

15

Conan创建软件包配方指南
Conan创建软件包配方指南

本专题介绍通过conanfile.py创建软件包的方法,讲解包名、版本、依赖和构建设置等基础信息,以及source、build、package、package_info等常用方法的作用及编写思路。

2026.09.22

20

12

Conan二进制包配置指南
Conan二进制包配置指南

本专题介绍Conan根据操作系统、编译器、架构和构建类型生成二进制包的方法,讲解Profile、Settings、Options及Package ID的作用,帮助管理不同平台和编译环境下的包版本。

2026.09.22

20

13

Conan私有仓库搭建教程
Conan私有仓库搭建教程

本专题系统的讲解Conan私有仓库的搭建流程,涵盖仓库服务部署、存储目录配置、用户认证、权限划分和远程地址添加,并介绍内部C++依赖包的上传、下载及版本维护方法。

2026.09.22

20

19

loomy官网入口地址合集
loomy官网入口地址合集

本专题汇总了 Loomy 桌面 AI 助理的官方入口地址合集及使用指南。提供 macOS 与 Windows 客户端下载 。Loomy 是讯飞推出的桌面级 AI 工作搭子,支持文件整理、数据分析、网页操作及通过飞书/钉钉远程操控电脑,助你高效完成本地办公任务 。

2026.09.22

20

19

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Symfony 官方文档
Symfony 官方文档

共0课时 | 0人学习

Composer手册
Composer手册

共0课时 | 0人学习

Symfony5【从0开始开发博客系统】
Symfony5【从0开始开发博客系统】

共120课时 | 15.1万人学习