学习Server-Sent Events遇http.Flusher缺失方法错误求助

你遇到的报错根源在于直接使用强制类型断言w.(http.Flusher)——并非所有http.ResponseWriter实例都实现了http.Flusher接口：比如测试场景下的模拟响应器、反向代理后的特殊响应封装，或是部分自定义响应写入器，都可能未实现该接口，强制断言会直接触发missing method Flush的 panic。

修复方案 #

1. 安全断言接口：使用带ok标识的类型断言，先判断当前响应器是否支持Flush，不支持则返回明确错误。
2. 提前断言提升效率：无需在循环内重复断言，在循环前完成一次断言即可。

修正后的代码如下：

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

func serverSideEvent(w http.ResponseWriter, r *http.Request) {
    if r.URL.Path != "/stream" {
        http.Error(w, "404 not found.", http.StatusNotFound)
        return
    }

    // 方法不支持应返回405状态码，而非404
    if r.Method != http.MethodGet {
        http.Error(w, "Method is not supported.", http.StatusMethodNotAllowed)
        return
    }

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

    // 安全断言http.Flusher接口
    flusher, ok := w.(http.Flusher)
    if !ok {
        http.Error(w, "Server does not support streaming", http.StatusInternalServerError)
        return
    }

    for i := 0; i < 10; i++ {
        fmt.Fprintf(w, "data: %d\n\n", i)
        // 使用提前断言好的实例调用Flush
        flusher.Flush()
        time.Sleep(1 * time.Second)
    }
}

额外注意事项 #

• 标准Go HTTP服务器（http.ListenAndServe默认启动的服务）原生支持http.Flusher，如果使用第三方框架或自定义服务器，需要确认其响应器是否兼容该接口。
• 原代码中把方法不支持的错误状态码写成了http.StatusNotFound（404），这不符合HTTP规范，修正为http.StatusMethodNotAllowed（405）更合理。

内容的提问来源于stack exchange，提问作者Aman RAJ