当前位置：首页 > 文章列表 > Golang > Go教程 > Go net/http 如何实现可取消的 SSE 心跳：断线检测与资源回收

Go net/http 如何实现可取消的 SSE 心跳：断线检测与资源回收

来源：17golang原创 2026-08-26 23:18:10 0浏览收藏

做 SSE（Server-Sent Events）时，最容易漏掉的不是把事件写到响应体，而是浏览器断开后服务端还在继续做无用工作。一个可靠的 Go 心跳端点应当同时满足三件事：拿到 http.Flusher 及时把事件推出去，用 r.Context().Done() 感知连接结束，并在退出分支关闭 ticker 和后台资源。

心跳只是连接保活信号，不是断线检测本身；真正的停止条件应来自请求上下文取消，写入失败则作为额外的退出信号处理。

要点速览

每条 SSE 事件以空行结束，调用 Flusher 后客户端才更快收到心跳。
请求上下文是服务端回收连接级工作的主通道，不要依赖固定次数循环。
写响应失败后立即停止当前连接，ticker 和后台 goroutine 都要有明确收尾路径。
用 curl -N 观察事件间隔，再用客户端中断验证取消链是否生效。

先把 SSE 心跳服务跑起来

这里做一个最小服务：访问 /events 后，每 15 秒发送一次注释心跳。SSE 允许用以冒号开头的注释保持连接活跃，浏览器不会把它当成业务消息，但代理和客户端仍能看到数据流在前进。

package main

import (
    "fmt"
    "log"
    "net/http"
    "time"
)

func events(w http.ResponseWriter, r *http.Request) {
    flusher, ok := w.(http.Flusher)
    if !ok {
        http.Error(w, "streaming unsupported", http.StatusInternalServerError)
        return
    }

    w.Header().Set("Content-Type", "text/event-stream")
    w.Header().Set("Cache-Control", "no-cache")
    w.Header().Set("Connection", "keep-alive")

    ticker := time.NewTicker(15 * time.Second)
    defer ticker.Stop()

    fmt.Fprint(w, ": connected\n\n")
    flusher.Flush()

    for {
        select {
        case

Go net/http SSE 心跳写出后经过 http.Flusher 刷新到客户端的事件流证据图

这段代码的关键不在 ticker，而在两个退出分支。fmt.Fprint 报错说明响应写入已经失去意义；上下文取消则覆盖了客户端主动关闭、服务器结束请求等连接生命周期变化。defer ticker.Stop() 让函数从任意分支返回时都能释放计时器。

把连接生命周期和后台工作绑在一起

真实业务通常不是每 15 秒写一行注释这么简单，心跳旁边还会有订阅、聚合或缓存刷新。此时不要再起一个永不结束的 goroutine。让后台工作只接收一个上下文，并把它的退出结果汇总回当前请求。

func watchTopic(ctx context.Context, out chan

Go SSE 客户端断线后 Request.Context 取消并停止后台 ticker 的资源回收证据图

这里有一个容易忽视的细节：发送到 updates 也必须可取消。否则请求已经返回，后台 goroutine 仍可能卡在无缓冲 channel 的发送处。把发送动作放进带 ctx.Done() 的 select，取消信号就能穿透到最深的等待点。

用 curl 验证刷新和断线

先启动服务，再用下面的命令保持终端连接。-N 会关闭 curl 的输出缓冲，看到 : heartbeat 按间隔出现，才说明服务端确实在持续刷新。

go run .
curl -N http://127.0.0.1:8080/events

运行十几秒后按 Ctrl+C 关闭 curl，回到服务端日志检查是否出现 sse client left。如果没有日志，先确认请求是否经过反向代理；如果有日志但后台仍持续输出，说明后台工作没有使用同一个请求上下文。

几个边界别混在一起

现象	应检查的点	处理判断
客户端迟迟收不到心跳	事件是否以两个换行结束，是否调用 Flush	先看响应格式和缓冲，再看代理超时
断开后 CPU 仍上升	后台循环是否监听 Context	给每个等待点增加取消分支
服务端写入出现错误	当前响应是否仍可写	记录一次并退出当前连接，不做盲目重写

另外，SSE 的心跳间隔要小于链路中最短的空闲超时，但不要把 15 秒当成通用答案。生产环境应根据网关、负载均衡和客户端网络策略压测；心跳越密，连接数多时产生的写放大也越明显。