必须用 starlette 或 fastapi 实现 sse:flask 因 wsgi 同步模型无法可靠维持长连接,易卡顿丢事件;starlette 轻量可控,fastapi 适合需鉴权与校验的场景;需正确设置响应头、双换行分隔、id 去重、转义换行符,并捕获 clientdisconnect 清理资源。

用 Starlette 或 FastAPI 实现 SSE,别碰 Flask
Python 原生不支持长连接流式响应的优雅生命周期管理,Flask 的 yield + Response 表面能跑,但实际会卡住连接、丢事件、无法处理客户端断连。生产环境必须用异步框架。
原因很简单:Flask 是同步 WSGI 框架,每个请求占一个线程/进程,SSE 要求连接长期挂起,而 WSGI 服务器(如 gunicorn)默认超时 30 秒,且无法感知客户端是否已断开;Starlette 和 FastAPI 基于 ASGI,原生支持协程级连接维持和断连检测。
-
Starlette更轻量,StreamingResponse接口直接、可控性强,适合纯 SSE 服务 -
FastAPI自带 OpenAPI 和依赖注入,适合需要鉴权、参数校验、与其他 API 共存的场景 - 避免用
aiohttp.web:它没有内置的 SSE 响应包装,要手动写Content-Type、Cache-Control、text/event-stream分隔符,容易漏掉retry:或换行格式,导致浏览器重连失败
StreamingResponse 返回前必须设对响应头
浏览器只认 Content-Type: text/event-stream,且要求响应头在流开始前全部发出。少一个头,或者晚发,都会让 EventSource 卡在 connecting 状态,不报错也不触发 message。
常见错误现象:EventSource 打开后一直 pending,Network 面板里状态是 (pending),控制台无报错。
立即学习“Python免费学习笔记(深入)”;
- 必须显式设置
headers={"Content-Type": "text/event-stream", "Cache-Control": "no-cache", "Connection": "keep-alive"} -
Cache-Control不设或设错(比如写成no-store),某些浏览器(尤其是 Safari)会拒绝解析流 - 不要依赖框架自动加
Transfer-Encoding: chunked—— ASGI 服务器(如uvicorn)通常会加,但如果你套了 Nginx,得确认它没缓冲响应;加proxy_buffering off;到 location 块里
发送事件时每条消息结尾必须是
,不是
SSE 协议规定:每条事件以空行(
)分隔。少一个
,后续所有事件都会被浏览器拼成一条,data: 字段解析错乱,id: 和 event: 失效。
典型错误写法:yield "data: hello
" → 浏览器收不到 message 事件;正确是 yield "data: hello
"。
- 完整单条事件示例:
"id: 123 event: update data: {"status":"ok"} " -
id:字段用于断线重连后的事件去重,生产环境建议生成单调递增或时间戳 ID - 如果数据含换行符(比如 JSON 字符串),必须对
data:行做转义:把替换成\n,否则会提前触发分隔
客户端断连后,服务端协程得真正退出,别留僵尸任务
ASGI 应用里,StreamingResponse 的生成器函数一旦被客户端关闭,uvicorn 会抛 ClientDisconnect 异常。但如果你在生成器里开了后台任务(比如 asyncio.create_task())、用了未取消的定时器、或忘了 try/except 捕获,协程就卡在 await 上,连接释放了,任务还在跑。
后果:内存缓慢增长,fd 耗尽,uvicorn 日志出现 Task was destroyed but it is pending!。
- 务必在生成器最外层包
try...except starlette.exceptions.ClientDisconnect:,并在finally里清理资源 - 如果用了
asyncio.sleep()循环推送,改用asyncio.wait_for(..., timeout=...)并捕获asyncio.TimeoutError和ClientDisconnect - 避免在 SSE 路由里调用阻塞 IO(如
time.sleep、requests.get),它们会阻塞整个 event loop
真正难的不是推数据,是推完还能干净收手。很多线上问题都出在“以为连接断了,其实任务还挂着”。










