小编dan*_*ufi的帖子

我有一个SSE端点将数据发送到前端，并且该数据是从另一个API端点检索的。channels我对in还很陌生go，似乎我必须触发 API 端点两次，以便 SSE 端点将数据发送到前端一次。就目前而言，我还没有编写前端代码来建立 SSE 连接，因为我仍在使用通道。有人可以解释为什么这需要调用 API 两次才能让 SSE 发送数据吗？

上交所路线

func SendSSE(appCtx *fiber.Ctx, dataChannel chan string) error {
    appCtx.Set("Content-Type", "text/event-stream")
    appCtx.Set("Cache-Control", "no-cache")
    appCtx.Set("Connection", "keep-alive")
    appCtx.Set("Transfer-Encoding", "chunked")

    appCtx.Context().SetBodyStreamWriter(fasthttp.StreamWriter(func(w *bufio.Writer) {
        log.Println("SSE Opened")
        for {
            log.Println("Retrieving data channel..")
            fmt.Fprintf(w, "data: Message: %s\n\n", <-dataChannel)
            log.Println(<-dataChannel)

            err := w.Flush()
            if err != nil {
                // Refreshing page in web browser will establish a new
                // SSE connection, but only (the last) one is alive, …