首頁猿問關(guān)閉 Go http.Client...

關(guān)閉 Go http.Client 的連接池

Go

函數(shù)式編程 2023-07-17 14:53:27

出于測(cè)試目的，我嘗試net/http.Client在 Go 中創(chuàng)建一個(gè)禁用連接池的項(xiàng)目。我想要實(shí)現(xiàn)的是每個(gè) HTTP/1.x 請(qǐng)求上的地址都建立一個(gè)新的 TCP 連接。目前我有： c = &http.Client{ Transport: &http.Transport{ DialContext: (&net.Dialer{ Timeout: 5 * time.Second, KeepAlive: 5 * time.Second, }).DialContext, TLSHandshakeTimeout: 5 * time.Second, ResponseHeaderTimeout: 5 * time.Second, ExpectContinueTimeout: 1 * time.Second, }, }有什么想法我應(yīng)該如何調(diào)整這個(gè)嗎？我發(fā)現(xiàn)如果我設(shè)置c.Transport.MaxIdleConns = 1這個(gè)可以工作，但我不確定這是否仍然允許 1 個(gè)使用中 + 1 個(gè)空閑（總共 2 個(gè)）TCP 連接： // MaxIdleConns controls the maximum number of idle (keep-alive) // connections across all hosts. Zero means no limit. MaxIdleConns int同樣，似乎也c.Dialer.KeepAlive = -1可以這樣做： // KeepAlive specifies the keep-alive period for an active // network connection. // If zero, keep-alives are enabled if supported by the protocol // and operating system. Network protocols or operating systems // that do not support keep-alives ignore this field. // If negative, keep-alives are disabled.但我不確定 TCP 連接 + Keep-Alive + HTTP 的行為。另一種方法是嘗試盡快殺死空閑的 TCP 連接，所以我設(shè)置了c.Transport.IdleConnTimeout = 1*time.Nanosecond.當(dāng)我這樣做時(shí)，我Client.Do()現(xiàn)在偶爾會(huì)返回錯(cuò)誤：tls: use of closed connection我懷疑這是一個(gè) Go stdlib 問題（可能是一場(chǎng)競(jìng)賽），它使用了應(yīng)該從池中取出的連接。

查看完整描述

3 回答

哆啦的時(shí)光機(jī)

TA貢獻(xiàn)1779條經(jīng)驗(yàn) 獲得超6個(gè)贊

連接被添加到函數(shù)Transport.tryPutIdleConn中的池中。如果Transport.DisableKeepAlives為 true 或?Transport.MaxIdleConnsPerHost小于零，則不會(huì)合并連接。

設(shè)置任一值都會(huì)禁用池化。Connection: close當(dāng)DisableKeepAlives 為true 時(shí)，傳輸會(huì)添加請(qǐng)求標(biāo)頭。這可能是理想的，也可能不是理想的，具體取決于您正在測(cè)試的內(nèi)容。

設(shè)置DisableKeepAlives的方法如下：

t?:=?http.DefaultTransport.(*http.Transport).Clone()
t.DisableKeepAlives?=?true
c?:=?&http.Client{Transport:?t}

在操場(chǎng)上運(yùn)行DisableKeepAlives = true 的演示。

設(shè)置 MaxIdleConnsPerHost 的方法如下：

t?:=?http.DefaultTransport.(*http.Transport).Clone()
t.MaxIdleConnsPerHost?=?-1
c?:=?&http.Client{Transport:?t}

在操場(chǎng)上運(yùn)行 MaxIdleConnsPerHost = -1 的演示。

上面的代碼克隆了默認(rèn)傳輸以確保使用默認(rèn)傳輸選項(xiàng)。如果您明確想要問題中的選項(xiàng)，請(qǐng)使用

????c?=?&http.Client{
????????Transport:?&http.Transport{
????????????DialContext:?(&net.Dialer{
????????????????Timeout:???5?*?time.Second,
????????????????KeepAlive:?5?*?time.Second,
????????????}).DialContext,
????????????TLSHandshakeTimeout:???5?*?time.Second,
????????????ResponseHeaderTimeout:?5?*?time.Second,
????????????ExpectContinueTimeout:?1?*?time.Second,
????????????DisableKeepAlives:?true,
????????},
????}

或者

????c?=?&http.Client{
????????Transport:?&http.Transport{
????????????DialContext:?(&net.Dialer{
????????????????Timeout:???5?*?time.Second,
????????????????KeepAlive:?5?*?time.Second,
????????????}).DialContext,
????????????TLSHandshakeTimeout:???5?*?time.Second,
????????????ResponseHeaderTimeout:?5?*?time.Second,
????????????ExpectContinueTimeout:?1?*?time.Second,
????????????MaxIdleConnsPerHost:?-1,
????????},
????}

MaxIdleConnsPerHost 不限制每個(gè)主機(jī)的活動(dòng)連接數(shù)。?

通過將Dialer.KeepAlive設(shè)置為 -1，不會(huì)禁用池。

反對(duì) 回復(fù) 2023-07-17

飲歌長嘯

TA貢獻(xiàn)1951條經(jīng)驗(yàn) 獲得超3個(gè)贊

您需要將DisableKeepAlives、true和MaxIdleConnsPerHost-1 設(shè)置為。

從文檔中：

// DisableKeepAlives, if true, disables HTTP keep-alives and

// will only use the connection to the server for a single

// HTTP request.

https://golang.org/src/net/http/transport.go，第 166 和 187 行

因此，您的客戶端必須按如下方式初始化

c = &http.Client{

Transport: &http.Transport{

DialContext: (&net.Dialer{

Timeout: 5 * time.Second,

}).DialContext,

TLSHandshakeTimeout: 5 * time.Second,

ResponseHeaderTimeout: 5 * time.Second,

ExpectContinueTimeout: 1 * time.Second,

DisableKeepAlives: true,

MaxIdleConnsPerHost: -1

},

}

如果您使用 1.7 之前的 Go 版本，那么您需要消耗主體的所有緩沖區(qū)，并且只有在調(diào)用request.Body.Close(). 相反，如果您使用的版本大于或等于 1.7，則可以推遲關(guān)閉，而無需采取額外的預(yù)防措施。

禁用連接池但仍然能夠執(zhí)行并行請(qǐng)求的示例庫： https: //github.com/alessiosavi/Requests

反對(duì) 回復(fù) 2023-07-17

紅顏莎娜

TA貢獻(xiàn)1842條經(jīng)驗(yàn) 獲得超13個(gè)贊

http.Transport 有一個(gè)名為MaxConnsPerHost

MaxConnsPerHost 可以選擇限制每個(gè)主機(jī)的連接總數(shù)，包括處于撥號(hào)、活動(dòng)和空閑狀態(tài)的連接。

包括撥號(hào)、活動(dòng)和空閑狀態(tài)

反對(duì) 回復(fù) 2023-07-17

3 回答
0 關(guān)注
265 瀏覽

關(guān)注

添加回答

舉報(bào)

0/150

提交

取消

使用 Ctrl+D 可將網(wǎng)站添加到書簽

微信客服

購課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)

第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

熱搜

最近搜索清空

關(guān)閉 Go http.Client 的連接池

關(guān)閉 Go http.Client 的連接池

3 回答

添加回答