成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

實(shí)戰(zhàn):用取消參數(shù)使 Go net/http 服務(wù)更靈活

開發(fā) 前端
超時(shí)既難以捉摸,卻又真實(shí)地存在于我們生活的由網(wǎng)絡(luò)連接的世界中。在我寫這篇文章的同時(shí),隔壁兩個(gè)同事正在用他們的智能手機(jī)打字,也許是在跟與他們相距萬里的人聊天。網(wǎng)絡(luò)使這一切變?yōu)榭赡堋?/div>

關(guān)于超時(shí),可以把開發(fā)者分為兩類:一類是了解超時(shí)多么難以捉摸的人,另一類是正在感受超時(shí)如何難以捉摸的人。

超時(shí)既難以捉摸,卻又真實(shí)地存在于我們生活的由網(wǎng)絡(luò)連接的世界中。在我寫這篇文章的同時(shí),隔壁兩個(gè)同事正在用他們的智能手機(jī)打字,也許是在跟與他們相距萬里的人聊天。網(wǎng)絡(luò)使這一切變?yōu)榭赡堋?/p>

[[349023]]

這里要說的是網(wǎng)絡(luò)及其復(fù)雜性,作為寫網(wǎng)絡(luò)服務(wù)的我們,必須掌握如何高效地駕馭它們,并規(guī)避它們的缺陷。

閑話少說,來看看超時(shí)和它們是如何影響我們的 net/http 服務(wù)的。

服務(wù)超時(shí) — 基本原理

web 編程中,超時(shí)通常分為客戶端和服務(wù)端超時(shí)兩種。我之所以要研究這個(gè)主題,是因?yàn)槲易约河龅搅艘粋€(gè)有意思的服務(wù)端超時(shí)的問題。這也是本文我們將要重點(diǎn)討論服務(wù)側(cè)超時(shí)的原因。

先解釋下基本術(shù)語:超時(shí)是一個(gè)時(shí)間間隔(或邊界),用來標(biāo)識(shí)在這個(gè)時(shí)間段內(nèi)要完成特定的行為。如果在給定的時(shí)間范圍內(nèi)沒有完成操作,就產(chǎn)生了超時(shí),這個(gè)操作會(huì)被取消。

從一個(gè) net/http 的服務(wù)的初始化中,能看出一些超時(shí)的基礎(chǔ)配置:

 

  1. srv := &http.Server{ 
  2.     ReadTimeout:       1 * time.Second
  3.     WriteTimeout:      1 * time.Second
  4.     IdleTimeout:       30 * time.Second
  5.     ReadHeaderTimeout: 2 * time.Second
  6.     TLSConfig:         tlsConfig, 
  7.     Handler:           srvMux, 

http.Server 類型的服務(wù)可以用四個(gè)不同的 timeout 來初始化:

  • ReadTimeout:讀取包括請(qǐng)求體的整個(gè)請(qǐng)求的最大時(shí)長(zhǎng)
  • WriteTimeout:寫響應(yīng)允許的最大時(shí)長(zhǎng)
  • IdleTimetout:當(dāng)開啟了保持活動(dòng)狀態(tài)(keep-alive)時(shí)允許的最大空閑時(shí)間
  • ReadHeaderTimeout:允許讀請(qǐng)求頭的最大時(shí)長(zhǎng)

對(duì)上述超時(shí)的圖表展示:

 

實(shí)戰(zhàn):用取消參數(shù)使 Go net/http 服務(wù)更靈活

服務(wù)生命周期和超時(shí)

當(dāng)心!不要以為這些就是你所需要的所有的超時(shí)了。除此之外還有很多超時(shí),這些超時(shí)提供了更小的粒度控制,對(duì)于我們的持續(xù)運(yùn)行的 HTTP 處理器不會(huì)生效。

請(qǐng)聽我解釋。

timeout 和 deadline

如果我們查看 net/http 的源碼,尤其是看到 `conn` 類型[1] 時(shí),我們會(huì)發(fā)現(xiàn)conn 實(shí)際上使用了 net.Conn 連接,net.Conn 表示底層的網(wǎng)絡(luò)連接:

  1. // Taken from: https://github.com/golang/go/blob/bbbc658/src/net/http/server.go#L247 
  2. // A conn represents the server-side of an HTTP connection
  3. type conn struct { 
  4.     // server is the server on which the connection arrived. 
  5.     // Immutable; never nil. 
  6.     server *Server 
  7.  
  8.     // * Snipped * 
  9.  
  10.     // rwc is the underlying network connection
  11.     // This is never wrapped by other types and is the value given out 
  12.     // to CloseNotifier callers. It is usually of type *net.TCPConn or 
  13.     // *tls.Conn. 
  14.     rwc net.Conn 
  15.  
  16.     // * Snipped * 

換句話說,我們的 HTTP 請(qǐng)求實(shí)際上是基于 TCP 連接的。從類型上看,TLS 連接是 *net.TCPConn 或 *tls.Conn 。

serve 函數(shù)[2]處理每一個(gè)請(qǐng)求[3]時(shí)調(diào)用 readRequest 函數(shù)。readRequest使用我們?cè)O(shè)置的 timeout 值[4]來設(shè)置 TCP 連接的 deadline:

 

  1. // Taken from: https://github.com/golang/go/blob/bbbc658/src/net/http/server.go#L936 
  2. // Read next request from connection
  3. func (c *conn) readRequest(ctx context.Context) (w *response, err error) { 
  4.         // *Snipped* 
  5.  
  6.         t0 := time.Now() 
  7.         if d := c.server.readHeaderTimeout(); d != 0 { 
  8.                 hdrDeadline = t0.Add(d) 
  9.         } 
  10.         if d := c.server.ReadTimeout; d != 0 { 
  11.                 wholeReqDeadline = t0.Add(d) 
  12.         } 
  13.         c.rwc.SetReadDeadline(hdrDeadline) 
  14.         if d := c.server.WriteTimeout; d != 0 { 
  15.                 defer func() { 
  16.                         c.rwc.SetWriteDeadline(time.Now().Add(d)) 
  17.                 }() 
  18.         } 
  19.  
  20.         // *Snipped* 

從上面的摘要中,我們可以知道:我們對(duì)服務(wù)設(shè)置的 timeout 值最終表現(xiàn)為 TCP 連接的 deadline 而不是 HTTP 超時(shí)。

所以,deadline 是什么?工作機(jī)制是什么?如果我們的請(qǐng)求耗時(shí)過長(zhǎng),它們會(huì)取消我們的連接嗎?

一種簡(jiǎn)單地理解 deadline 的思路是,把它理解為對(duì)作用于連接上的特定的行為的發(fā)生限制的一個(gè)時(shí)間點(diǎn)。例如,如果我們?cè)O(shè)置了一個(gè)寫的 deadline,當(dāng)過了這個(gè) deadline 后,所有對(duì)這個(gè)連接的寫操作都會(huì)被拒絕。

盡管我們可以使用 deadline 來模擬超時(shí)操作,但我們還是不能控制處理器完成操作所需的耗時(shí)。deadline 作用于連接,因此我們的服務(wù)僅在處理器嘗試訪問連接的屬性(如對(duì) http.ResponseWriter 進(jìn)行寫操作)之后才會(huì)返回(錯(cuò)誤)結(jié)果。

為了實(shí)際驗(yàn)證上面的論述,我們來創(chuàng)建一個(gè)小的 handler,這個(gè) handler 完成操作所需的耗時(shí)相對(duì)于我們?yōu)榉?wù)設(shè)置的超時(shí)更長(zhǎng):

 

  1. package main 
  2.  
  3. import ( 
  4.  "fmt" 
  5.  "io" 
  6.  "net/http" 
  7.  "time" 
  8.  
  9. func slowHandler(w http.ResponseWriter, req *http.Request) { 
  10.  time.Sleep(2 * time.Second
  11.  io.WriteString(w, "I am slow!\n"
  12.  
  13. func main() { 
  14.  srv := http.Server{ 
  15.   Addr:         ":8888"
  16.   WriteTimeout: 1 * time.Second
  17.   Handler:      http.HandlerFunc(slowHandler), 
  18.  } 
  19.  
  20.  if err := srv.ListenAndServe(); err != nil { 
  21.   fmt.Printf("Server failed: %s\n", err) 
  22.  } 

上面的服務(wù)有一個(gè) handler,這個(gè) handler 完成操作需要兩秒。另一方面,http.Server 的 WriteTimeout 屬性設(shè)為 1 秒。基于服務(wù)的這些配置,我們猜測(cè) handler 不能把響應(yīng)寫到連接。

我們可以用 go run server.go 來啟動(dòng)服務(wù)。使用 curl localhost:8888 來發(fā)送一個(gè)請(qǐng)求:

 

  1. time curl localhost:8888 
  2. curl: (52) Empty reply from server 
  3. curl localhost:8888  0.01s user 0.01s system 0% CPU 2.021 total 

這個(gè)請(qǐng)求需要兩秒來完成處理,服務(wù)返回的響應(yīng)是空的。雖然我們的服務(wù)知道在 1 秒之后我們寫不了響應(yīng)了,但 handler 還是多耗了 100% 的時(shí)間(2 秒)來完成處理。

雖然這是個(gè)類似超時(shí)的處理,但它更大的作用是在到達(dá)超時(shí)時(shí)間時(shí),阻止服務(wù)進(jìn)行更多的操作,結(jié)束請(qǐng)求。在我們上面的例子中,handler 在完成之前一直在處理請(qǐng)求,即使已經(jīng)超出響應(yīng)寫超時(shí)時(shí)間(1 秒)100%(耗時(shí) 2 秒)。

最根本的問題是,對(duì)于處理器來說,我們應(yīng)該怎么設(shè)置超時(shí)時(shí)間才更有效?

處理超時(shí)

我們的目標(biāo)是確保我們的 slowHandler 在 1s 內(nèi)完成處理。如果超過了 1s,我們的服務(wù)會(huì)停止運(yùn)行并返回對(duì)應(yīng)的超時(shí)錯(cuò)誤。

在 Go 和一些其它編程語言中,組合往往是設(shè)計(jì)和開發(fā)中最好的方式。標(biāo)準(zhǔn)庫的 `net/http` 包[5]有很多相互兼容的元素,開發(fā)者可以不需經(jīng)過復(fù)雜的設(shè)計(jì)考慮就可以輕易將它們組合在一起。

基于此,net/http 包提供了`TimeoutHandler`[6] — 返回了一個(gè)在給定的時(shí)間限制內(nèi)運(yùn)行的 handler。

函數(shù)簽名:

  1. func TimeoutHandler(h Handler, dt time.Duration, msg string) Handler 

第一個(gè)參數(shù)是 Handler,第二個(gè)參數(shù)是 time.Duration (超時(shí)時(shí)間),第三個(gè)參數(shù)是 string 類型,當(dāng)?shù)竭_(dá)超時(shí)時(shí)間后返回的信息。

用 TimeoutHandler 來封裝我們的 slowHandler,我們只需要:

 

  1. package main 
  2.  
  3. import ( 
  4.  "fmt" 
  5.  "io" 
  6.  "net/http" 
  7.  "time" 
  8.  
  9. func slowHandler(w http.ResponseWriter, req *http.Request) { 
  10.  time.Sleep(2 * time.Second
  11.  io.WriteString(w, "I am slow!\n"
  12.  
  13. func main() { 
  14.  srv := http.Server{ 
  15.   Addr:         ":8888"
  16.   WriteTimeout: 5 * time.Second
  17.   Handler:      http.TimeoutHandler(http.HandlerFunc(slowHandler), 1*time.Second"Timeout!\n"), 
  18.  } 
  19.  
  20.  if err := srv.ListenAndServe(); err != nil { 
  21.   fmt.Printf("Server failed: %s\n", err) 
  22.  } 

兩個(gè)需要留意的地方是:

  • 我們?cè)?http.TimetoutHandler 里封裝 slowHanlder,超時(shí)時(shí)間設(shè)為 1s,超時(shí)信息為 “Timeout!”。
  • 我們把 WriteTimeout 增加到 5s,以給予 http.TimeoutHandler 足夠的時(shí)間執(zhí)行。如果我們不這么做,當(dāng) TimeoutHandler 開始執(zhí)行時(shí),已經(jīng)過了 deadline,不能再寫到響應(yīng)。

如果我們?cè)賳?dòng)服務(wù),當(dāng)程序運(yùn)行到 slow handler 時(shí),會(huì)有如下輸出:

 

  1. time curl localhost:8888 
  2. Timeout! 
  3. curl localhost:8888  0.01s user 0.01s system 1% CPU 1.023 total 

1s 后,我們的 TimeoutHandler 開始執(zhí)行,阻止運(yùn)行 slowHandler,返回文本信息 ”Timeout!“。如果我們?cè)O(shè)置信息為空,handler 會(huì)返回默認(rèn)的超時(shí)響應(yīng)信息,如下:

  1. <html> 
  2.   <head> 
  3.     <title>Timeout</title> 
  4.   </head> 
  5.   <body> 
  6.    <h1>Timeout</h1> 
  7.   </body> 
  8. </html> 

如果忽略掉輸出,這還算是整潔,不是嗎?現(xiàn)在我們的程序不會(huì)有過長(zhǎng)耗時(shí)的處理;也避免了有人惡意發(fā)送導(dǎo)致長(zhǎng)耗時(shí)處理的請(qǐng)求時(shí),導(dǎo)致的潛在的 DoS 攻擊。

盡管我們?cè)O(shè)置超時(shí)時(shí)間是一個(gè)偉大的開始,但它仍然只是初級(jí)的保護(hù)。如果你可能會(huì)面臨 DoS 攻擊,你應(yīng)該采用更高級(jí)的保護(hù)工具和技術(shù)。(可以試試Cloudflare[7] )

我們的 slowHandler 僅僅是個(gè)簡(jiǎn)單的 demo。但是,如果我們的程序復(fù)雜些,能向其他服務(wù)和資源發(fā)出請(qǐng)求會(huì)發(fā)生什么呢?如果我們的程序在超時(shí)時(shí)向諸如 S3 的服務(wù)發(fā)出了請(qǐng)求會(huì)怎么樣?

會(huì)發(fā)生什么?

未處理的超時(shí)和請(qǐng)求取消

我們稍微展開下我們的例子:

 

  1. func slowAPICall() string { 
  2.  d := rand.Intn(5) 
  3.  select { 
  4.  case <-time.After(time.Duration(d) * time.Second): 
  5.   log.Printf("Slow API call done after %s seconds.\n", d) 
  6.   return "foobar" 
  7.  } 
  8.  
  9. func slowHandler(w http.ResponseWriter, r *http.Request) { 
  10.  result := slowAPICall() 
  11.  io.WriteString(w, result+"\n"

我們假設(shè)最初我們不知道 slowHandler 由于通過 slowAPICall 函數(shù)向 API 發(fā)請(qǐng)求導(dǎo)致需要耗費(fèi)這么長(zhǎng)時(shí)間才能處理完成,

slowAPICall 函數(shù)很簡(jiǎn)單:使用 select 和一個(gè)能阻塞 0 到 5 秒的 time.After 。當(dāng)經(jīng)過了阻塞的時(shí)間后,time.After 方法通過它的 channel 發(fā)送一個(gè)值,返回 "foobar" 。

(另一種方法是,使用 sleep(time.Duration(rand.Intn(5)) * time.Second),但我們?nèi)匀皇褂? select,因?yàn)樗鼤?huì)使我們下面的例子更簡(jiǎn)單。)

如果我們運(yùn)行起服務(wù),我們預(yù)期超時(shí) handler 會(huì)在 1 秒之后中斷請(qǐng)求處理。來發(fā)送一個(gè)請(qǐng)求驗(yàn)證一下:

 

  1. time curl localhost:8888 
  2. Timeout! 
  3. curl localhost:8888  0.01s user 0.01s system 1% CPU 1.021 total 

通過觀察服務(wù)的輸出,我們會(huì)發(fā)現(xiàn),它是在幾秒之后打出日志的,而不是在超時(shí) handler 生效時(shí)打出:

 

  1. $ Go run server.go 
  2. 2019/12/29 17:20:03 Slow API call done after 4 seconds. 

這個(gè)現(xiàn)象表明:雖然 1 秒之后請(qǐng)求超時(shí)了,但是服務(wù)仍然完整地處理了請(qǐng)求。這就是在 4 秒之后才打出日志的原因。

雖然在這個(gè)例子里問題很簡(jiǎn)單,但是類似的現(xiàn)象在生產(chǎn)中可能變成一個(gè)嚴(yán)重的問題。例如,當(dāng) slowAPICall 函數(shù)開啟了幾個(gè)百個(gè)協(xié)程,每個(gè)協(xié)程都處理一些數(shù)據(jù)時(shí)。或者當(dāng)它向不同系統(tǒng)發(fā)出多個(gè)不同的 API 發(fā)出請(qǐng)求時(shí)。這種耗時(shí)長(zhǎng)的的進(jìn)程,它們的請(qǐng)求方/客戶端并不會(huì)使用服務(wù)端的返回結(jié)果,會(huì)耗盡你系統(tǒng)的資源。

所以,我們?cè)趺幢Wo(hù)系統(tǒng),使之不會(huì)出現(xiàn)類似的未優(yōu)化的超時(shí)或取消請(qǐng)求呢?

上下文超時(shí)和取消

Go 有一個(gè)包名為 `context`[8] 專門處理類似的場(chǎng)景。

context 包在 Go 1.7 版本中提升為標(biāo)準(zhǔn)庫,在之前的版本中,以`golang.org/x/net/context`[9] 的路徑作為 Go Sub-repository Packages[10]出現(xiàn)。

這個(gè)包定義了 Context 類型。它最初的目的是保存不同 API 和不同處理的截止時(shí)間、取消信號(hào)和其他請(qǐng)求相關(guān)的值。如果你想了解關(guān)于 context 包的其他信息,可以閱讀 Golang's blog[11] 中的 “Go 并發(fā)模式:Context”(譯注:Go Concurrency Patterns: Context) .

net/http 包中的的 Request 類型已經(jīng)有 context 與之綁定。從 Go 1.7 開始,Request 新增了一個(gè)返回請(qǐng)求的上下文的 `Context` 方法[12]。對(duì)于進(jìn)來的請(qǐng)求,在客戶端關(guān)閉連接、請(qǐng)求被取消(HTTP/2 中)或 ServeHTTP 方法返回后,服務(wù)端會(huì)取消上下文。

我們期望的現(xiàn)象是,當(dāng)客戶端取消請(qǐng)求(輸入了 CTRL + C)或一段時(shí)間后TimeoutHandler 繼續(xù)執(zhí)行然后終止請(qǐng)求時(shí),服務(wù)端會(huì)停止后續(xù)的處理。進(jìn)而關(guān)閉所有的連接,釋放所有被運(yùn)行中的處理進(jìn)程(及它的所有子協(xié)程)占用的資源。

我們把 Context 作為參數(shù)傳給 slowAPICall 函數(shù):

 

  1. func slowAPICall(ctx context.Context) string { 
  2.  d := rand.Intn(5) 
  3.  select { 
  4.  case <-time.After(time.Duration(d) * time.Second): 
  5.   log.Printf("Slow API call done after %d seconds.\n", d) 
  6.   return "foobar" 
  7.  } 
  8.  
  9. func slowHandler(w http.ResponseWriter, r *http.Request) { 
  10.  result := slowAPICall(r.Context()) 
  11.  io.WriteString(w, result+"\n"

在例子中我們利用了請(qǐng)求上下文,實(shí)際中怎么用呢?`Context` 類型[13]有個(gè) Done 屬性,類型為 <-chan struct{}。當(dāng)進(jìn)程處理完成時(shí),Done 關(guān)閉,此時(shí)表示上下文應(yīng)該被取消,而這正是例子中我們需要的。

我們?cè)?slowAPICall 函數(shù)中用 select 處理 ctx.Done 通道。當(dāng)我們通過 Done 通道接收一個(gè)空的 struct 時(shí),意味著上下文取消,我們需要讓 slowAPICall 函數(shù)返回一個(gè)空字符串。

 

  1. func slowAPICall(ctx context.Context) string { 
  2.  d := rand.Intn(5) 
  3.  select { 
  4.  case <-ctx.Done(): 
  5.   log.Printf("slowAPICall was supposed to take %s seconds, but was canceled.", d) 
  6.   return "" 
  7.         //time.After() 可能會(huì)導(dǎo)致內(nèi)存泄漏 
  8.  case <-time.After(time.Duration(d) * time.Second): 
  9.   log.Printf("Slow API call done after %d seconds.\n", d) 
  10.   return "foobar" 
  11.  } 

(這就是使用 select 而不是 time.Sleep -- 這里我們只能用 select 處理 Done 通道。)

在這個(gè)簡(jiǎn)單的例子中,我們成功得到了結(jié)果 -- 當(dāng)我們從 Done 通道接收值時(shí),我們打印了一行日志到 STDOUT 并返回了一個(gè)空字符串。在更復(fù)雜的情況下,如發(fā)送真實(shí)的 API 請(qǐng)求,你可能需要關(guān)閉連接或清理文件描述符。

我們?cè)賳?dòng)服務(wù),發(fā)送一個(gè) cRUL 請(qǐng)求:

 

  1. # The cURL command: 
  2. $ curl localhost:8888 
  3. Timeout! 
  4.  
  5. # The server output
  6. $ Go run server.go 
  7. 2019/12/30 00:07:15 slowAPICall was supposed to take 2 seconds, but was canceled. 

檢查輸出:我們發(fā)送了 cRUL 請(qǐng)求到服務(wù),它耗時(shí)超過 1 秒,服務(wù)取消了 slowAPICall 函數(shù)。我們幾乎不需要寫任何代碼。TimeoutHandler 為我們代勞了 -- 當(dāng)處理耗時(shí)超過預(yù)期時(shí),TimeoutHandler 終止了處理進(jìn)程并取消請(qǐng)求上下文。

TimeoutHandler 是在 `timeoutHandler.ServeHTTP` 方法[14] 中取消上下文的:

 

  1. // Taken from: https://github.com/golang/go/blob/bbbc658/src/net/http/server.go#L3217-L3263 
  2. func (h *timeoutHandler) ServeHTTP(w ResponseWriter, r *Request) { 
  3.         ctx := h.testContext 
  4.         if ctx == nil { 
  5.          var cancelCtx context.CancelFunc 
  6.          ctx, cancelCtx = context.WithTimeout(r.Context(), h.dt) 
  7.          defer cancelCtx() 
  8.         } 
  9.         r = r.WithContext(ctx) 
  10.  
  11.         // *Snipped* 

上面例子中,我們通過調(diào)用 context.WithTimeout 來使用請(qǐng)求上下文。超時(shí)值 h.dt (TimeoutHandler 的第二個(gè)參數(shù))設(shè)置給了上下文。返回的上下文是請(qǐng)求上下文設(shè)置了超時(shí)值后的一份拷貝。隨后,它作為請(qǐng)求上下文傳給r.WithContext(ctx)。

context.WithTimeout 方法執(zhí)行了上下文取消。它返回了 Context 設(shè)置了一個(gè)超時(shí)值之后的副本。當(dāng)?shù)竭_(dá)超時(shí)時(shí)間后,就取消上下文。

這里是執(zhí)行的代碼:

 

  1. // Taken from: https://github.com/golang/go/blob/bbbc6589/src/context/context.go#L486-L498 
  2. func WithTimeout(parent Context, timeout time.Duration) (Context, CancelFunc) { 
  3.  return WithDeadline(parent, time.Now().Add(timeout)) 
  4.  
  5. // Taken from: https://github.com/golang/go/blob/bbbc6589/src/context/context.go#L418-L450 
  6. func WithDeadline(parent Context, d time.Time) (Context, CancelFunc) { 
  7.         // *Snipped* 
  8.  
  9.         c := &timerCtx{ 
  10.          cancelCtx: newCancelCtx(parent), 
  11.          deadline:  d, 
  12.         } 
  13.  
  14.         // *Snipped* 
  15.  
  16.         if c.err == nil { 
  17.          c.timer = time.AfterFunc(dur, func() { 
  18.           c.cancel(true, DeadlineExceeded) 
  19.          }) 
  20.         } 
  21.         return c, func() { c.cancel(true, Canceled) } 

這里我們又看到了截止時(shí)間。WithDeadline 函數(shù)設(shè)置了一個(gè) d 到達(dá)之后執(zhí)行的函數(shù)。當(dāng)?shù)竭_(dá)截止時(shí)間后,它調(diào)用 cancel 方法處理上下文,此方法會(huì)關(guān)閉上下文的 done 通道并設(shè)置上下文的 timer 屬性為 nil。

Done 通道的關(guān)閉有效地取消了上下文,使我們的 slowAPICall 函數(shù)終止了它的執(zhí)行。這就是 TimeoutHandler 終止耗時(shí)長(zhǎng)的處理進(jìn)程的原理。

(如果你想閱讀上面提到的源碼,你可以去看 `cancelCtx` 類型[15] 和`timerCtx` 類型[16])

有彈性的 net/http 服務(wù)

連接截止時(shí)間提供了低級(jí)的細(xì)粒度控制。雖然它們的名字中含有“超時(shí)”,但它們并沒有表現(xiàn)出人們通常期望的“超時(shí)”。實(shí)際上它們非常強(qiáng)大,但是使用它們有一定的門檻。

另一個(gè)角度講,當(dāng)處理 HTTP 時(shí),我們?nèi)匀粦?yīng)該考慮使用 TimeoutHandler。Go 的作者們也選擇使用它,它有多種處理,提供了如此有彈性的處理以至于我們甚至可以對(duì)每一個(gè)處理使用不同的超時(shí)。TimeoutHandler 可以根據(jù)我們期望的表現(xiàn)來控制執(zhí)行進(jìn)程。

除此之外,TimeoutHandler 完美兼容 context 包。context 包很簡(jiǎn)單,包含了取消信號(hào)和請(qǐng)求相關(guān)的數(shù)據(jù),我們可以使用這些數(shù)據(jù)來使我們的應(yīng)用更好地處理錯(cuò)綜復(fù)雜的網(wǎng)絡(luò)問題。

結(jié)束之前,有三個(gè)建議。寫 HTTP 服務(wù)時(shí),怎么設(shè)計(jì)超時(shí):

  • 最常用的,到達(dá) TimeoutHandler 時(shí),怎么處理。它進(jìn)行我們通常期望的超時(shí)處理。
  • 不要忘記上下文取消。context 包使用起來很簡(jiǎn)單,并且可以節(jié)省你服務(wù)器上的很多處理資源。尤其是在處理異常或網(wǎng)絡(luò)狀況不好時(shí)。
  • 一定要用截止時(shí)間。確保做了完整的測(cè)試,驗(yàn)證了能提供你期望的所有功能。

 

責(zé)任編輯:未麗燕 來源: 今日頭條
相關(guān)推薦

2009-05-18 09:12:00

ASON自動(dòng)交換光網(wǎng)絡(luò)

2015-05-04 14:12:43

2023-06-06 19:24:06

KubernetesSpark

2024-11-21 15:48:40

2011-02-22 10:00:38

.NETc#IronPython

2011-02-23 09:48:00

Python.NET

2009-06-03 09:08:20

ScalaJava類型

2017-07-18 06:08:41

2023-11-27 08:21:49

Camera2API,

2012-01-13 10:31:25

ibmdw

2020-09-14 09:33:02

網(wǎng)絡(luò)

2025-02-18 00:10:00

2017-02-14 15:37:32

KappaLambda

2024-01-08 08:36:29

HTTPGo代理服務(wù)器

2015-10-10 10:01:39

VMware數(shù)據(jù)中心

2023-12-05 10:25:24

Python類型注解

2012-03-13 10:40:58

Google Go

2013-11-11 16:20:01

戴爾

2013-12-12 10:55:21

2009-08-04 15:55:56

OracleEPMBI
點(diǎn)贊
收藏

51CTO技術(shù)棧公眾號(hào)

主站蜘蛛池模板: 成人1区 | 久久久久久av | 免费激情网站 | 在线观看亚洲欧美 | 国产成人a亚洲精品 | 日韩色在线 | 波多野结衣一区二区三区在线观看 | 91欧美激情一区二区三区成人 | 亚洲网址 | 91最新在线视频 | 日韩成人在线观看 | 精品久久久久久久久久 | 久久不卡视频 | 3p视频在线观看 | av资源网站 | 成人在线观看亚洲 | 粉嫩av | 久久久精品视 | 亚洲国产一区二区三区在线观看 | 亚洲永久字幕 | 一级黄a视频 | 天堂av免费观看 | 自拍偷拍av| a国产视频| 国产91丝袜在线播放 | 国产成人在线免费 | 精国产品一区二区三区四季综 | 日韩欧美一区二区三区在线播放 | 精品欧美一区二区三区免费观看 | 欧美精品啪啪 | 日韩在线视频一区 | 成人免费av在线 | 国产精品久久久久久238 | 不卡一二区 | 久久aⅴ乱码一区二区三区 亚洲国产成人精品久久久国产成人一区 | av天天爽 | 亚洲福利网 | 精品国产欧美 | 性色av一区二区三区 | 三级黄视频在线观看 | 欧美精品日韩 |