Flask Server-Sent Events怎么写_SSE向浏览器主动推送实时数据-Python教程-PHP中文网

flask实现sse需用yield返回生成器，设content-type: text/event-stream和cache-control: no-cache，每条消息末尾双换行；前端用eventsource监听onmessage/onerror并手动重连；生产环境必须用异步服务器如uvicorn或gunicorn+gevent。

flask server-sent events怎么写_sse向浏览器主动推送实时数据

Flask 怎么写 SSE 路由

Flask 本身不内置 SSE 支持，但靠 yield + 正确的响应头就能实现。核心是返回一个生成器（generator），每条数据以 data: ...\n\n 格式输出，并设好 Content-Type: text/event-stream 和禁用缓存。

常见错误是直接 return 字符串、忘了加双换行、或没设 Cache-Control: no-cache —— 浏览器会等缓冲填满才吐数据，导致“一直没反应”。

路由必须用 @app.route，不能用 @app.get（老版本 Flask 不识别）
函数返回值必须是生成器函数（含 yield），不能是普通字符串或列表
每条消息末尾必须有两个换行：yield "data: hello\n\n"，少一个就解析失败
推荐加 response.headers["Cache-Control"] = "no-cache"，避免 Nginx 或浏览器缓存住流

from flask import Flask, Response
import time

app = Flask(__name__)

@app.route('/sse')
def sse():
    def event_stream():
        for i in range(5):
            yield f"data: message {i}\n\n"
            time.sleep(1)
    return Response(event_stream(), content_type='text/event-stream')

前端怎么连上 Flask SSE 并处理断线重连

EventSource 是浏览器原生 API，简单可靠，但默认不自动重连 —— 断网、服务重启后它就停了，用户得刷新页面。这不是 bug，是规范行为。

容易踩的坑：没监听 error 事件、把 onmessage 写成 addEventListener('message', ...)（漏掉 on 前缀）、或在 onerror 里直接 new EventSource(...) 导致无限新建连接。

必须监听 onerror，并在其中检查 event.target.readyState 是否为 0（关闭状态）再重建
重连前建议加延迟（如 setTimeout），避免雪崩请求
如果后端返回自定义事件类型（如 event: update\n），前端要用 addEventListener('update', ...) 接，不是 onmessage
记得调用 eventSource.close() 清理，比如组件卸载时

let es = null;
function connect() {
  es = new EventSource('/sse');
  es.onmessage = e => console.log('data:', e.data);
  es.onerror = () => {
    if (es && es.readyState === 0) {
      setTimeout(connect, 2000);
    }
  };
}
connect();