根据OP的进一步说明。默认客户端 不会 重用连接。
确保关闭响应。
读取完后,呼叫者应关闭res.Body。如果未关闭resp.Body,则客户端的基础RoundTripper(通常是Transport)可能无法将与服务器的持久TCP连接重新用于后续的“保持活动”请求。
另外,我发现在调用Close()之前,我还 需要阅读直到响应完成 。
例如
res, _ := client.Do(req)io.Copy(ioutil.Discard, res.Body)res.Body.Close()
为确保重用http.Client连接,请确保执行以下两项 *** 作:
- 读取直到响应完成(即
ioutil.ReadAll(resp.Body)
) - 呼叫
Body.Close()
旧答案,对速率限制很有用,但对OP的作用却不大:
我认为无法通过golang 1.1 http
API设置最大连接数。这意味着如果您不小心的话,可以通过大量的TCP连接(直到用完文件描述符或其他内容)使自己陷入困境。
也就是说, 您可以 通过time.Tick 限制 为特定主机 调用go例程的速率 (并因此限制出站请求和连接)。
例如:
import "time"requests_per_second := 5throttle := time.Tick(1000000000 / requests_per_second)for i := 0; i < 16; i += 1 { <-throttle go serveQueue()}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)