快速上手：利用Go语言构建SSE服务器推送

package main

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

func sseHandler(w http.ResponseWriter, r *http.Request) {
    // 设置响应头，关键在于Content-Type
    w.Header().Set("Content-Type", "text/event-stream")
    w.Header().Set("Cache-Control", "no-cache")
    w.Header().Set("Connection", "keep-alive")

    // 创建一个通道，用于发送数据
    messageChan := make(chan string)

    // 启动一个goroutine，模拟数据源
    go func() {
        defer close(messageChan)
        ticker := time.NewTicker(2 * time.Second)
        defer ticker.Stop()

        for range ticker.C {
            messageChan <- fmt.Sprintf("当前时间：%s", time.Now().Format(time.RFC3339))
        }
    }()

    // 监听客户端断开连接
    notify := r.Context().Done()
    go func() {
        <-notify
        log.Println("客户端已断开连接")
        return
    }()

    // 循环发送数据
    for msg := range messageChan {
        fmt.Fprintf(w, "data: %s\n\n", msg)
        // 强制刷新缓冲区，确保数据立即发送
        flusher, ok := w.(http.Flusher)
        if ok {
            flusher.Flush()
        }
    }

    log.Println("SSE 完成")
}

func main() {
    http.HandleFunc("/events", sseHandler)
    log.Println("SSE服务器已启动，监听端口：8080")
    log.Fatal(http.ListenAndServe(":8080", nil))
}