SSE在Fiber中不能直接用ctx.SendString或ctx.JSON推送，因为Fiber基于fasthttp默认写完即关连接，而SSE要求长期存活、分块写出、固定响应头且禁用缓存；必须手动设置Content-Type、Cache-Control等头，调用c.Context().SetBodyStreamWriter并持续w.Flush()。
SSE在Fiber中不能直接用ctx.SendString或ctx.JSON推送——必须手动控制响应流、禁用缓冲、保持连接活跃，否则会立即关闭连接或触发浏览器缓存。
为什么ctx.JSON和ctx.SendString不适用于SSE
Fiber默认使用fasthttp引擎，其响应生命周期是“写完即关”。SSE要求连接长期存活、数据分块写出、响应头固定且不可缓存。一旦调用ctx.JSON，Fiber会自动设置Content-Type: application/json、写入完整JSON后调用ctx.Response.End()，导致HTTP连接终止——浏览器收不到后续事件。
- 错误现象：
EventSource反复触发error事件，控制台显示Failed to load resource: net::ERR_INCOMPLETE_CHUNKED_ENCODING - 根本原因：Fiber未暴露底层
fasthttp.ResponseCtx的Write和Flush能力，需绕过封装直接操作ctx.Fasthttp - 关键动作：必须手动设置
Content-Type: text/event-stream、Cache-Control: no-cache、Connection: keep-alive，并持续调用Flush()
正确写法：用ctx.Fasthttp裸写响应流
以下是最小可行示例（Go 1.22+，Fiber v2.50+）：
app.Get("/stream", func(c *fiber.Ctx) error {
// 设置SSE必需响应头
c.Set("Content-Type", "text/event-stream")
c.Set("Cache-Control", "no-cache")
c.Set("Connection", "keep-alive")
c.Set("X-Accel-Buffering", "no") // Nginx兼容
<pre class="brush:php;toolbar:false;">// 禁用Fiber自动结束响应
c.Context().SetBodyStreamWriter(func(w *bufio.Writer) {
counter := 0
ticker := time.NewTicker(1 * time.Second)
defer ticker.Stop()
for range ticker.C {
counter++
// 构造标准SSE消息格式（注意末尾两个\n）
msg := fmt.Sprintf("data: {\"count\":%d}\n\n", counter)
if _, err := w.Write([]byte(msg)); err != nil {
return
}
w.Flush() // 必须显式flush，否则数据滞留在缓冲区
}
})
return nil // 不返回c.Send等，避免二次写入})
-
c.Context().SetBodyStreamWriter是唯一能持续写入的入口，它接管整个响应体流 -
w.Flush()不能省略：fasthttp默认启用缓冲，不flush则客户端永远收不到数据 -
X-Accel-Buffering: no防止Nginx等反向代理缓存SSE流（生产环境必加） - 不要在
SetBodyStreamWriter里调用c.Status()或c.Set()，此时响应头已发送
如何处理客户端断开和资源清理
Fiber不会自动监听客户端断连，需主动检查fasthttp连接状态：
- 在
SetBodyStreamWriter内部循环中，定期调用c.Context().IsClientConnected()，返回false时跳出循环 - 使用
ctx.Locals或闭包变量保存定时器/数据库连接等资源，并在退出前Stop()或Close() - 避免goroutine泄漏：每个SSE连接应绑定独立goroutine，但不要无限制启动；可配合
context.WithTimeout做兜底 - 若用数据库游标或大模型流式API（如通义千问），务必在
defer中释放上下文或取消请求
生产环境必须加的三件事
本地跑通不等于线上可用：
- 反向代理配置：Nginx需添加
proxy_buffering off;、proxy_cache off;、proxy_read_timeout 86400; - 超时控制：Fiber默认
ReadTimeout和WriteTimeout可能中断长连接，建议设为0（禁用）或极大值 - 连接数限制：单机SSE连接数可达数千，但
fasthttp默认MaxConnsPerHost可能成为瓶颈，需在fiber.Config中显式调高
最易被忽略的是Flush()和反向代理缓冲——这两点出问题，SSE就变成“一次性吐完然后断连”，完全失去流式意义。
