通道未在第一個 API 請求上發送數據

問題內容

我有一個SSE 端點，它將資料傳送到前端，並且該資料是從另一個API 端點檢索的。我對 go 中的 channels 仍然很陌生，似乎我必須觸發 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, so
                // dead connections must be closed here.
                fmt.Printf("Error while flushing: %v. Closing http connection.\n", err)

                break
            }

        }
    }))

    fmt.Println("SSE Closed")
    return nil

}

傳送資料給sse的API

func GetApiData(appCtx *fiber.Ctx, dataChannel chan string) error {
    log.Println("Sending DataChannel data")
    dataChannel <- "Data is passed from api to sse"
    return appCtx.Status(http.StatusOK).SendString("Not Implemented")
}

正確答案

您看到此情況的原因是您在此部分中使用了 2 個訊息

fmt.Fprintf(w, "data: Message: %s\n\n", <-dataChannel)
log.Println(<-dataChannel)

每個奇數訊息都會傳送到 SSE，每個偶數訊息都會記錄到控制台。應改為

message := <-dataChannel
fmt.Fprintf(w, "data: Message: %s\n\n", message)
log.Println(message)

以上是通道未在第一個 API 請求上發送數據的詳細內容。更多資訊請關注PHP中文網其他相關文章！