Go サーバーからの継続的なチャンク化された HTTP 応答
データのチャンクを継続的に送信する Go HTTP サーバーを作成するために、次のようにしました。課題に遭遇しました。クライアントは、意図したとおりにチャンクを毎秒受信するのではなく、5 秒後にのみ応答全体を受信します。さらに、送信の最後に Content-Length ヘッダーを 0 として送信しようとしています。
この問題を解決するには、Flusher インターフェイスをサーバー実装に統合することが不可欠です。コードの修正バージョンは次のとおりです。
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) { flusher, ok := w.(http.Flusher) if !ok { panic("expected http.ResponseWriter to be an http.Flusher") } 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) flusher.Flush() } }() time.Sleep(time.Second * 5) ticker.Stop() fmt.Println("Finished: should return Content-Length: 0 here") w.Header().Set("Content-Length", "0") }
各チャンクが書き込まれた後に Flusher.Flush() を呼び出すことで、「チャンク化された」エンコーディングをトリガーし、個々のチャンクを送信します。これにより、クライアントはデータが利用可能になったときに確実に受信できるようになります。
次に示すように、この動作は 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 ...
この変更されたコードにより、連続チャンク HTTP 応答の送信が可能になります。 Go サーバーから。最適なパフォーマンスを得るために、ResponseWriter が複数のゴルーチンにわたる同時アクセスをサポートしていることを必ず確認してください。
以上がGo HTTP サーバーが遅延後にチャンク データのみを送信するのはなぜですか? Content-Length を 0 に設定するにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。