讲师中心 微信公众号
AI工具推荐 视频效率加速

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

胖墨同学_8051

胖墨同学_8051

发布时间:2026-08-07 19:50:00

|

903人浏览过

|

来源于php中文网

原创

在 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)。

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

热门AI工具

更多
Lovart
Lovart Hot

一款面向视觉设计创作的AI设计平台,可通过智能体和画布工作流辅助制作海报、Logo、网页、PPT及其他视觉内容。

咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

AionClaw
AionClaw Hot

AionClaw是一款面向办公、创作和编程任务的AI桌面智能体。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

超级简历WonderCV

一款AI办公效率工具,主要用于免费求职简历模版下载制作,应届生职场人必备简历制作神器,适合需要提升相关任务效率的用户。

Seko
Seko Hot

一款AI视频创作工具,主要用于商汤科技推出的创编一体的AI短视频创作Agent,适合需要提升相关任务效率的用户。

LibLibAI
LibLibAI Hot

一款AI视频创作工具,主要用于国内领先的AI创意平台,以海量模型、低门槛操作与“创作-分享-商业化”生态,让小白与专业创作者都能高效实现图文乃至视频创意表达,适合需要提升相关任务效率的用户。

相关专题

更多
PHP Symfony框架
PHP Symfony框架

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

4597

2025.09.11

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

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

504

2025.11.26

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

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

80

2026.09.23

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

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

20

2026.09.23

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

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

20

2026.09.23

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

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

20

2026.09.22

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

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

40

2026.09.22

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

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

20

2026.09.22

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

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

20

2026.09.22

热门下载

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

精品课程

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

共0课时 | 0人学习

Composer手册
Composer手册

共0课时 | 0人学习

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

共120课时 | 15.1万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn