Go - HTTP请求,JSON,重用连接

baw*_*sen 4 connection json http request go

我正在使用Go通过HTTPS发出许多请求,而且我遇到了不重用连接和用完端口的问题.我正在做的请求是一个返回JSON格式数据的API,然后我将其json.Decode转换为Go值.

根据我在这个网站上遇到的问题(#1,#2),为了让Go重新使用连接进行另一个请求,我必须在关闭之前读取整个响应的主体(注意这并不总是行为,说这里).

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

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

ioutil.ReadAll(resp.Body)
Run Code Online (Sandbox Code Playgroud)

但是因为我通过这样的代码将数据从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)
Run Code Online (Sandbox Code Playgroud)

我不确定这两种方法是如何相互作用的.

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

Jim*_*imB 6

如果您只想使用解码器解码单个对象,则可以使用该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)
}
Run Code Online (Sandbox Code Playgroud)

您也可以在每次调用时推迟复制,但这样您可以更轻松地处理或记录是否存在意外数据或错误.