Le canal n'envoie pas de données lors de la première requête API

Contenu de la question

J'ai un SSE 端点，它将数据发送到前端，并且该数据是从另一个 API 端点检索的。我对 go 中的 channels encore nouveau et il semble que je doive déclencher le point de terminaison de l'API deux fois pour que le point de terminaison SSE envoie des données au frontend. Pour l'instant, je n'ai pas écrit le code front-end pour établir une connexion SSE car j'utilise toujours des canaux. Quelqu'un peut-il expliquer pourquoi cela nécessite d'appeler l'API deux fois pour que SSE envoie les données ?

Route de la Bourse de Shanghai

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

}

API pour l'envoi de données à sse

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")
}

Bonne réponse

La raison pour laquelle vous voyez ceci est parce que vous avez utilisé 2 messages dans cette section

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

Chaque message impair est envoyé à SSE et chaque message pair est enregistré sur la console. Devrait être remplacé par

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

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!