如何从 Go HTTP 服务器按块顺序发送数据？

使用块从 Go 服务器顺序发送数据

在 Go 中创建 HTTP 服务器时，发送响应可能很有用以块的形式，允许在检索数据时逐渐发送数据。这使客户端能够以顺序方式接收数据。

但是，如果客户端仅在预定持续时间结束时接收数据块，或者如果 Go 自动设置 Content-Length 标头，则可能会令人沮丧。为了纠正这个问题，我们需要深入研究 Go 中分块 HTTP 响应的细微差别。

首先，重要的是要记住 Transfer-Encoding 标头是由 Go 的 HTTP 响应编写器隐式处理的。因此，不需要显式设置。

实现顺序 chunk 传递的关键在于使用 Flusher.Flush()。通过在写入每个块后调用此方法，我们触发“分块”编码并将数据发送到客户端。这确保客户端在准备好时接收每个块。

以下是如何实现此技术的示例：

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

func main() {
    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        flusher, ok := w.(http.Flusher)
        if !ok {
            panic("expected http.ResponseWriter to be an http.Flusher")
        }
        w.Header().Set("X-Content-Type-Options", "nosniff")
        for i := 1; i <= 10; i++ {
            fmt.Fprintf(w, "Chunk #%d\n", i)
            flusher.Flush() // Trigger "chunked" encoding and send a chunk...
            time.Sleep(500 * time.Millisecond)
        }
    })

    log.Print("Listening on localhost:8080")
    log.Fatal(http.ListenAndServe(":8080", nil))
}

通过使用此方法，您可以确保您的 Go HTTP 服务器按顺序发送块，使客户端能够及时接收数据。此外，重要的是要记住 http.ResponseWriters 支持多个 goroutine 使用的并发访问。这允许您在必要时从不同的线程或 goroutine 发送块。

以上是如何从 Go HTTP 服务器按块顺序发送数据？的详细内容。更多信息请关注PHP中文网其他相关文章！