Flask实现SSE实时推送，事件流生成教程

本文深入剖析了在Flask中正确实现Server-Sent Events（SSE）实时推送的核心要点与常见陷阱，强调SSE成功的关键并非语法本身，而是对HTTP长连接生命周期的精细掌控：从必须严格设置的响应头（如`Content-Type: text/event-stream`、`Cache-Control: no-cache`）、规范的数据格式（`data:`前缀+双换行符`\n\n`），到规避同步阻塞（禁用`time.sleep`、推荐异步或消息队列解耦），再到应对前端EventSource敏感的错误处理、超时配置与多用户隔离方案——每一步细微偏差都可能导致连接失败、事件丢失或服务阻塞，堪称一场围绕响应流、头部、换行符和连接韧性的实战排错指南。

Flask里用Response配合生成器实现SSE，关键在流式响应头和数据格式

Flask本身不内置SSE支持，但靠Response对象返回生成器函数，并手动设置Content-Type: text/event-stream和禁用缓冲，就能跑通。核心不是“怎么注册SSE”，而是“怎么让浏览器持续接收、解析事件”。很多初学者卡在响应被缓存、连接断开或格式不被识别——问题通常出在响应头或换行符上。

实操要点：

• Response必须接收一个生成器函数（不是调用结果），例如Response(event_stream(), mimetype='text/event-stream')
• 每个事件块必须以data:开头，后跟内容，且**末尾要有两个换行符（\n\n）**，单个\n会被浏览器忽略
• 需设置headers={'Cache-Control': 'no-cache', 'Connection': 'keep-alive'}，否则Nginx/浏览器可能缓存或关闭长连接
• Flask开发服务器默认启用Werkzeug的响应缓冲，必须加app.config['SEND_FILE_MAX_AGE_DEFAULT'] = 0并确保WSGI中间件不拦截流

生成器函数里不能用time.sleep()阻塞主线程？得用yield配合非阻塞等待

常见错误是直接在生成器里写while True: yield 'data: ...'; time.sleep(1)——这在单线程开发服务器（如Werkzeug默认模式）下会阻塞整个应用，所有其他请求排队。SSE本应轻量，但写法不当就变成性能瓶颈。

更稳妥的做法：

• 用yield立即返回数据，把等待逻辑交给客户端（比如前端用setTimeout控制重连频率）
• 若服务端真需定时推送，改用asyncio.sleep() + async def生成器（需搭配Quart或Flask 2.3+异步视图），纯Flask同步视图里别硬塞sleep
• 实际生产中建议用消息队列（如Redis Pub/Sub）解耦推送逻辑，生成器只做监听和转发，避免轮询或忙等待

前端EventSource连接失败或自动重连失败，大概率是Flask没处理好HTTP状态码或超时

浏览器的EventSource对响应异常很敏感：如果Flask视图抛出异常、返回非200状态码、或连接在3秒内断开，它会立刻触发error事件并按指数退避重试。很多人以为是前端代码问题，其实是后端没维持住连接。

排查重点：

• 确保视图函数始终返回Response对象，不要中途return 'error'或触发404
• 检查WSGI服务器配置：Gunicorn需加--timeout 120 --keep-alive 5，避免worker杀掉长连接；uWSGI要设harakiri 300和http-keepalive
• 服务端可主动发送retry: 3000\n\n告诉浏览器重连间隔（单位毫秒），比依赖默认3秒更可控
• 首次连接时，若Flask返回了Transfer-Encoding: chunked但没发任何data:，EventSource会卡在connecting状态，务必保证第一个yield尽快发出

多用户并发SSE连接时，生成器状态混乱？别在全局变量里存用户上下文

一个典型反模式是：用全局字典user_streams = {}存每个用户的生成器，然后在视图里yield from user_streams.get(user_id)——这会导致不同用户的事件混发，因为生成器不是线程安全的，且Flask每次请求都是新上下文，无法复用旧生成器。

正确做法是让每个请求独占一个生成器实例：

• 把用户标识（如request.args.get('uid')）传进生成器函数，在里面做权限校验和数据过滤
• 避免跨请求共享生成器对象；需要广播时，用Redis或内存队列做中转，每个连接监听自己专属的通道
• 注意生成器退出时机：用户关闭页面后，浏览器发FIN包，Flask可能不会立刻感知。可在生成器里定期检查request.environ.get('wsgi.input').closed（不通用）或加心跳检测

SSE的难点不在语法，而在HTTP长连接生命周期管理。生成器只是载体，真正要抠的是头信息、换行符、超时策略和错误传播路径——这些地方错一点，前端就收不到任何东西。

今天关于《Flask实现SSE实时推送，事件流生成教程》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！