在Go 中使用未緩衝的HTTP 回應傳送即時資料
在Go 中，HTTP 回應通常在傳送到客戶端之前進行緩衝。然而，對於串流或即時應用程序，在不緩衝的情況下增量發送資料至關重要。
要實現無緩衝響應，您可以利用某些 ResponseWriter 實作的 Flusher 介面。透過在每次寫入作業後刷新回應，您可以在資料可用時將資料直接傳送到用戶端。這是一個範例：
func handle(res http.ResponseWriter, req *http.Request) {
fmt.Fprintf(res, "sending first line of data")
if f, ok := res.(http.Flusher); ok {
f.Flush()
}
sleep(10) // Not real code
fmt.Fprintf(res, "sending second line of data")
}雖然此方法適用於手動寫入，但它可能不足以滿足管道命令輸出或資料非同步傳入的其他場景。在這種情況下，您可以利用 Go 例程連續讀取和刷新資料。
pipeReader, pipeWriter := io.Pipe()
cmd.Stdout = pipeWriter
cmd.Stderr = pipeWriter
go writeCmdOutput(res, pipeReader)
err := cmd.Run()
pipeWriter.Close()
func writeCmdOutput(res http.ResponseWriter, pipeReader *io.PipeReader) {
buffer := make([]byte, BUF_LEN)
for {
n, err := pipeReader.Read(buffer)
if err != nil {
pipeReader.Close()
break
}
data := buffer[0:n]
res.Write(data)
if f, ok := res.(http.Flusher); ok {
f.Flush()
}
// Reset buffer
for i := 0; i < n; i++ {
buffer[i] = 0
}
}
}這種方法可確保命令輸出直接寫入並刷新到客戶端，而無需緩衝。為了進一步方便，請考慮使用像 [fasthttp](https://github.com/valyala/fasthttp) 這樣的函式庫，它為即時串流提供內建支援。
以上是如何在 Go 中發送帶有無緩衝 HTTP 回應的即時資料？的詳細內容。更多資訊請關注PHP中文網其他相關文章！
