Senden Sie eine Chunked HTTP-Antwort von einem Go-Server

Question

Ich erstelle einen Test Go HTTP-Server, und ich sende eine Antwort-Header von Transfer-Encoding: Chunked, damit ich kontinuierlich neue Daten senden kann, wie ich es abrufen. Dieser Server sollte jede Sekunde einen Chunk auf diesen Server schreiben. Der Kunde sollte sie auf Anfrage erhalten können.

Leider empfängt der Client (curl in diesem Fall) alle Chunks am Ende der Dauer, 5 Sekunden, anstatt einen Chunk alle eine Sekunde zu empfangen. Außerdem scheint Go die Inhaltslänge für mich zu senden. Ich mag die Content-Length am Ende senden, und ich mag der Wert ist der Header 0.

Hier zu sein, ist der Server-Code:

package main 

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

func main() { 
    http.HandleFunc("/test", HandlePost); 
    log.Fatal(http.ListenAndServe(":8080", nil)) 
} 

func HandlePost(w http.ResponseWriter, r *http.Request) { 
    w.Header().Set("Connection", "Keep-Alive") 
    w.Header().Set("Transfer-Encoding", "chunked") 
    w.Header().Set("X-Content-Type-Options", "nosniff") 

    ticker := time.NewTicker(time.Second) 
    go func() { 
     for t := range ticker.C { 
      io.WriteString(w, "Chunk") 
      fmt.Println("Tick at", t) 
     } 
    }() 
    time.Sleep(time.Second * 5) 
    ticker.Stop() 
    fmt.Println("Finished: should return Content-Length: 0 here") 
    w.Header().Set("Content-Length", "0") 
} 

Answer 1

Der Trick scheint zu sein, dass Sie einfach müssen Rufen Sie Flusher.Flush() nach jedem Stück wird geschrieben. Beachten Sie auch, dass der Header "Transfer-Encoding" vom Writer implizit gehandhabt wird, also muss er nicht gesetzt werden.

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

können Sie überprüfen, indem Sie telnet:

$ telnet localhost 8080 
Trying ::1... 
Connected to localhost. 
Escape character is '^]'. 
GET/HTTP/1.1 

HTTP/1.1 200 OK 
Date: Tue, 02 Jun 2015 18:16:38 GMT 
Content-Type: text/plain; charset=utf-8 
Transfer-Encoding: chunked 

9 
Chunk #1 

9 
Chunk #2 

... 

Sie könnten einige der Forschung tun müssen, um sicherzustellen, dass http.ResponseWriters den gleichzeitigen Zugriff für die Verwendung durch mehrere goroutines unterstützen. Weitere Informationen zum "X-Content-Type-Options" header finden Sie auch unter dieser Frage.

Answer 2

Es sieht aus wie HTTPUTIL bietet ein NewChunkedReader Funktion