Go SSE 接口怎么持续向浏览器推送事件

Go 用 SSE（Server-Sent Events）向浏览器持续推送事件，核心是三件事：响应头设置为 text/event-stream，每个事件以空行结束，并在写入后通过 http.Flusher 尽快刷新。循环本身并不能保证浏览器马上收到内容，还要用 Request.Context() 感知页面关闭，及时停止 ticker 和事件生产。

先把 SSE 响应头和事件格式写对

浏览器端用 EventSource 打开接口后，服务端要返回 Content-Type: text/event-stream。一条最小事件可以只写 data:，末尾必须再补一个空行；如果写了 event:，浏览器就能按事件名分发。SSE 文本使用 UTF-8，多个事件之间靠空行分隔。

用 http.Flusher 让事件及时离开服务端

下面的 handler 是一个最小可用骨架。它先检查 ResponseWriter 是否支持 http.Flusher，再用 ticker 定时产生事件；每次写完事件都调用 Flush()。Go 官方文档提醒，默认 HTTP/1.x 和 HTTP/2 的 writer 支持 Flusher，但包装后的 writer 不一定支持，所以运行时检查不能省略。

func events(w http.ResponseWriter, r *http.Request) {
    flusher, ok := w.(http.Flusher)
    if !ok {
        http.Error(w, "streaming is unsupported", http.StatusInternalServerError) // 明确返回不支持流式刷新的错误
        return
    }

    w.Header().Set("Content-Type", "text/event-stream") // 声明 SSE 媒体类型
    w.Header().Set("Cache-Control", "no-cache")          // 避免缓存旧事件
    ticker := time.NewTicker(time.Second)
    defer ticker.Stop() // 客户端退出后释放定时器

    for {
        select {
        case 

代码里的 Cache-Control 只是基础设置；如果前面还有 Nginx、网关或 CDN，还要按它们的配置关闭响应缓冲，否则服务端虽然写了数据，浏览器仍可能积攒一批后才看到。

用 Request.Context 感知浏览器断开

长连接最容易遗漏的是退出路径。Go 的服务端请求上下文会在客户端连接关闭时取消，所以不要只靠 ticker 永久循环。把耗时查询、订阅或消息转发也绑定到这个 context，页面关闭时才能一起停止。

补上心跳、代理缓冲和浏览器接收逻辑

业务事件不一定每秒都有，但空闲连接可能被中间层误判为失活。可以发送只有冒号的 SSE 注释作为心跳，它不会触发 message 回调，却能维持数据流。浏览器端则用 EventSource 监听普通消息和错误：

const source = new EventSource("/events");

source.onmessage = (event) => {
  console.log("收到事件：", event.data); // data 字段会出现在 event.data
};

source.onerror = () => {
  console.log("连接暂时中断，浏览器会按 SSE 规则尝试重连"); // 生产环境应记录重连次数
};

如果要让服务端主动控制重连等待时间，可在事件块里写 retry: 5000；如果需要恢复游标，再给事件写 id:，服务端据此设计断线后的补发策略。不要把 SSE 当成可靠消息队列：连接断开期间的事件是否补发，仍要由业务层保存和确认。

相关问题

SSE 和 WebSocket 应该怎么选？

只有服务端持续通知、浏览器很少向服务端回写时，SSE 更直接；需要双向低延迟通信、二进制帧或更强的会话控制时，再考虑 WebSocket。

为什么写了 fmt.Fprintf，浏览器却没有立即显示？

常见原因是事件没有以空行结束、没有调用 Flush()，或者反向代理仍在缓冲响应。按响应头、事件格式、刷新调用和代理配置逐层排查。

客户端断开后还要手动关闭 ResponseWriter 吗？

通常不需要关闭它；handler 应退出自己的 ticker、订阅和 goroutine。真正需要释放的是你创建的定时器、消息订阅和其他外部资源。

小结：Go SSE 的稳定骨架是“正确媒体类型 + 空行结束事件 + Flusher 刷新 + Context 退出”。先把这四个边界写完整，再根据代理和业务是否需要心跳、重连与断线补发。