国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Golang > 正文

golang中為什么Response.Body需要被關(guān)閉詳解

2020-04-01 18:53:47
字體:
供稿:網(wǎng)友

前言

本文主要介紹了關(guān)于golang中Response.Body需要被關(guān)閉的相關(guān)內(nèi)容,文中通過示例代碼介紹的非常詳細,對各位學習或者使用golang具有一定參考學習價值,下面話不多說了,來一起看看詳細的介紹吧

Body io.ReadCloser

The http Client and Transport guarantee that Body is always non-nil, even on 
responses without a body or responses with a zero-length body. It is the caller's 
responsibility to close Body. The default HTTP client's Transport does not attempt to 
reuse HTTP/1.0 or HTTP/1.1 TCP connections ("keep-alive") unless the Body is read to 
completion and is closed.

http客戶端(Client)和傳輸(Transport)保證響應(yīng)體總是非空的,即使響應(yīng)沒有響應(yīng)體或0長響應(yīng)
體。關(guān)閉響應(yīng)體是調(diào)用者的責任。默認http客戶端傳輸(Transport)不會嘗試復用keep-alive的
http/1.0、http/1.1連接,除非請求體已被完全讀出而且被關(guān)閉了。

以上是http包文檔說明。但是為什么body需要被關(guān)閉呢,不關(guān)閉會如何?那就讀源碼唄。

要了解body,首先要了解http事務(wù)是如何處理的。http事務(wù)是交由底層的Transport處理的。

第一步是從連接池獲取一個連接,這個連接的功能由3個goroutine協(xié)同實現(xiàn),一個主goroutine,一個readLoop,一個writeLoop,后兩個goroutine生命周期和連接一致。雖說readLoop和writeLoop名字叫循環(huán)(也確實是for循環(huán)),但實際上一次循環(huán)就完整處理一個http事務(wù),循環(huán)本身僅僅是為了連接復用,所以為了便于理解其邏輯可以忽略它的循環(huán)結(jié)構(gòu)。

接下來三個goroutine協(xié)同完成http事務(wù):

  • 主goroutine將request同時發(fā)給readLoop和writeLoop。
  • writeLoop發(fā)送request,然后將狀態(tài)(error)發(fā)送給主goroutine和readLoop。
  • readLoop解析頭部response,然后將狀態(tài)(error)和response發(fā)送給主goroutine。
  • 主goroutine返回用戶代碼,readLoop等待body讀取完成。
  • readLoop回收連接。

了解http事務(wù)的處理流程,然后我們回過頭來看看神秘的body到底是什么

//源碼版本1.8.3// src/net/http/transfer.go:405 body解析方法func readTransfer(msg interface{}, r *bufio.Reader) (err error)// src/net/http/transfer.go:485 解析chunkedt.Body = &body{src: internal.NewChunkedReader(r), hdr: msg, r: r, closing: t.Close}// src/net/http/transfer.go:490 產(chǎn)生eoft.Body = &body{src: io.LimitReader(r, realLength), closing: t.Close}// src/net/http/transport.go:1560 發(fā)送eof信號body := &bodyEOFSignal{// src/net/http/transport.go:1583 gzip解碼resp.Body = &gzipReader{body: body}

body實際上是一個嵌套了多層的net.TCPConn:

  • bufio.Reader,這層嘗試將多次小的讀操作替換為一次大的讀操作,減少系統(tǒng)調(diào)用的次數(shù),提高性能;
  • io.LimitedReader,tcp連接在讀取完body后不會關(guān)閉,繼續(xù)讀會導致阻塞,所以需要LimitedReader在body讀完后發(fā)出eof終止讀取;
  • chunkedReader,解析chunked格式編碼(如果不是chunked略過);
  • bodyEOFSignal,在讀到eof,或者是提前關(guān)閉body時會對readLoop發(fā)出回收連接的通知;
  • gzipReader,解析gzip壓縮(如果不是gizp壓縮略過);

從上面可以看出如果body既沒有被完全讀取,也沒有被關(guān)閉,那么這次http事務(wù)就沒有完成,除非連接因超時終止了,否則相關(guān)資源無法被回收。

如果請求頭或響應(yīng)頭指明Connection: close呢?還是無法回收,因為close表示在http事務(wù)完成后斷開連接,而事務(wù)尚未完成自然不會斷開,更不會回收。

從實現(xiàn)上看只要body被讀完,連接就能被回收,只有需要拋棄body時才需要close,似乎不關(guān)閉也可以。但那些正常情況能讀完的body,即第一種情況,在出現(xiàn)錯誤時就不會被讀完,即轉(zhuǎn)為第二種情況。而分情況處理則增加了維護者的心智負擔,所以始終close body是最佳選擇。

總結(jié)

以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對大家的學習或者工作具有一定的參考學習價值,如果有疑問大家可以留言交流,謝謝大家對VEVB武林網(wǎng)的支持。

 

發(fā)表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發(fā)表
主站蜘蛛池模板: 石城县| 西城区| 桐庐县| 永德县| 汤原县| 高安市| 通渭县| 八宿县| 咸阳市| 伊宁市| 南靖县| 满城县| 桦甸市| 安顺市| 定远县| 临汾市| 庐江县| 徐州市| 汾阳市| 华宁县| 遂昌县| 湘乡市| 搜索| 云和县| 沅陵县| 广州市| 武隆县| 晋宁县| 宁德市| 南木林县| 安康市| 鲁山县| 江城| 盖州市| 西峡县| 邓州市| 时尚| 互助| 正定县| 保山市| 旬阳县|