Jav*_*per 8 apache http keep-alive haproxy go
var (
httpClient *http.Client
)
const (
MaxIdleConnections int = 20
RequestTimeout int = 5
)
// init HTTPClient
func init() {
client := &http.Client{
Transport: &http.Transport{
MaxIdleConnsPerHost: MaxIdleConnections,
},
Timeout: time.Duration(RequestTimeout) * time.Second,
}
return client
}
func makeRequest() {
var endPoint string = "https://localhost:8080/doSomething"
req, err := http.NewRequest("GET", ....)
response, err := httpClient.Do(req)
if err != nil && response == nil {
log.Fatalf("Error sending request to API endpoint. %+v", err)
} else {
// Close the connection to reuse it
defer response.Body.Close()
body, err := ioutil.ReadAll(response.Body)
if err != nil {
log.Fatalf("Couldn't parse response body. %+v", err)
}
log.Println("Response Body:", string(body))
}
}
Run Code Online (Sandbox Code Playgroud)
我在 Go 中有以下代码。Go 使用 http-keep-alive 连接。因此,根据我的理解,httpClient.Do(req)不会创建新连接,因为 golang 使用默认的持久连接。
根据我的理解,HTTP 持久连接一次发出一个请求,即第二个请求只能在第一个响应之后发出。但是如果多个线程调用makeRequest()会发生什么?会httpClient.Do(req)在前一个得到响应之前发送另一个请求吗?
我假设服务器超时客户端建立的任何保持活动的连接。如果服务器超时,那么下一次httpClient.Do(req)被调用,它会建立一个新的连接吗?
anhttp.Client有一个Transport,它将许多发出请求的低级细节委派给它。通过为客户提供自定义传输,您几乎可以更改任何内容。这个答案的其余部分将在很大程度上假设您正在使用http.DefaultClient或至少是一个带有http.DefaultTransport.
发出新请求时,如果到适当服务器的空闲连接可用,传输将使用它。
如果没有空闲连接可用(因为从来没有,或者因为其他 goroutines 都在使用它们,或者因为服务器关闭了连接,或者有一些其他错误)那么传输将考虑建立一个新的连接,限制为MaxConnsPerHost(默认值:无限制)。如果MaxConnsPerHost超过,则请求将阻塞,直到现有请求完成且连接可用。否则,将为此请求建立新连接。
请求完成后,客户端将缓存连接以供以后使用(受MaxIdleConns和限制MaxIdleConnsPerHost;DefaultTransport全局限制为 100 个空闲连接,每个主机没有限制)。
如果空闲连接IdleConnTimeout不用于发出请求,它们将在之后关闭;因为DefaultTransport限制是 90 秒。
所有这些都意味着默认情况下,Go 将建立足够的连接来满足并行性(达到您可以调整的某些限制),但它也会通过在一段时间内维护空闲连接池来尽可能多地重用保持活动连接时间。
| 归档时间: |
|
| 查看次数: |
412 次 |
| 最近记录: |