转到 HTTP 请求 POST 标头，等待响应，然后发布分块的正文内容

Question

我试图弄清楚是否有办法将分块数据发布到 HTTP 服务器，该服务器在接受我的任何请求正文之前尝试发送标头。我有一个服务器，它通过 POST 请求接收永无止境的数据流。收到新的 POST 请求后，它会构造标头并立即尝试刷新。http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {    requestId := uuid.Must(uuid.NewV4()).String()    w.Header().Set("X-Request-Id", requestId)    w.Header().Set("Content-Type", "application/octet-stream")    client := &Connection{requestId, make(chan []byte, 50), r, w}    defer client.Request.Body.Close()    switch client.Request.Method {        case http.MethodPost:            client.Writer.(http.Flusher).Flush()            // goes on to read data from the connection until it is closed    }}这适用于使用套接字实现的 POST 客户端，它可以决定在实际发送任何正文数据之前读取服务器响应。但是，我无法弄清楚如何让它为 Go http Request 对象工作。在客户端，我有一个正在将数据写入 io.PipeWriter 的 goroutine，并且我已将 PipeReader (pr) 传递给 Request 对象：req := &http.Request{    Method: "POST",       ProtoMajor: 1,        ProtoMinor: 1,        URL: serverUrl,    TransferEncoding: []string{"chunked"},    Body: pr,    Header: make(map[string][]string),}resp, err := http.DefaultClient.Do(req)这在两端永远挂起，因为 PipeReader 永远不会关闭，并且服务器在 Flush 上阻塞。我想做的是发送标题，等待服务器的响应，然后开始发送正文内容。我试过只是不在BodyRequest 对象中包含，这会发送标头，接收响应标头，并且连接似乎保持打开状态。但是从我所有的阅读来看，我似乎无法找到一种方法来通过这个连接发送额外的数据。当然，我可以不在服务器端刷新并处理数据——但我实际上正在实现一个指定此行为的协议，因此现有的客户端软件不会发送正文数据，除非它首先收到响应标头。

Answer 1

所以服务器在 Flush 中阻塞，因为主体仍然是打开的。事实证明，如果您在客户端的 POST 请求中将Connection标头设置为close（编辑：您可以在刷新之前在服务器响应标头中设置它，并且无论客户端在做什么，它都有效），服务器将忽略主体仍然存在的事实无论如何打开并刷新（并保持连接打开以读取数据）。整洁的。

我似乎无法在描述此行为的 HTTP 规范或 Go http 库中找到任何文档。但我们到了。