json - HTTP 请求、JSON、重用连接

Question

我正在使用 Go 通过 HTTPS 发出许多请求，但我遇到了无法重用连接和端口用尽的问题。我发出的请求是针对以 JSON 格式返回数据的 API，然后我将其json.Decode 转换为 Go 值。

根据我在这个网站上遇到的问题(#1，#2)，为了让 Go 为另一个请求重用连接，我必须在关闭之前阅读整个响应的主体(注意这个并不总是这种行为，如 here 所述)。

Previously the HTTP client's (*Response).Body.Close would try to keep
reading until EOF, hoping to reuse the keep-alive HTTP connection...

在典型情况下，我会使用前面链接中显示的示例，如下所示:

ioutil.ReadAll(resp.Body)

但是因为我通过这样的代码从 JSON 中提取数据:

...

req, _ := http.NewRequest("GET", urlString, nil)
req.Header.Add("Connection", "keep-alive")
resp, err = client.Do(req)
defer resp.Body.Close()

...

decoder := json.NewDecoder(resp.Body)
decoder.Decode(data)

我不确定这两种方法如何相互作用。

所以问题是，我如何确保已读取整个响应，以便稍后可以将连接重用于另一个请求？

Answer 1

如果您只想使用 Decoder 解码单个对象，则可以使用 More() 方法查看流中是否还有更多需要读取的对象。

decoder := json.NewDecoder(resp.Body)
err := decoder.Decode(data)
if err != nil {
    // handle err
}
if decoder.More() {
    // there's more data in the stream, so discard whatever is left
    io.Copy(ioutil.Discard, resp.Body)
}

您也可以在每次调用时延迟复制，但如果出现意外数据或错误，这样您可以更轻松地处理或记录。