欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

golang的httpserver優(yōu)雅重啟方法詳解

 更新時間:2018年03月25日 11:35:40   作者:helight  
這篇文章主要給大家介紹了關(guān)于golang的httpserver優(yōu)雅重啟的相關(guān)資料,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧。

前言

去年在做golangserver的時候,內(nèi)部比較頭疼的就是在線服務(wù)發(fā)布的時候,大量用戶的請求在發(fā)布時候會被重連,在那時候也想了n多的方法,最后還是落在一個github上的項目,facebook的一個golang項目grace,那時候簡單研究測試了一下可以就直接在內(nèi)部使用了起來,這段時間突然想起來,又想仔細研究一下這個項目了。

從原理上來說是這樣一個過程:

    1)發(fā)布新的bin文件去覆蓋老的bin文件

    2)發(fā)送一個信號量,告訴正在運行的進程,進行重啟

    3)正在運行的進程收到信號后,會以子進程的方式啟動新的bin文件

    4)新進程接受新請求,并處理

    5)老進程不再接受請求,但是要等正在處理的請求處理完成,所有在處理的請求處理完之后,便自動退出

    6)新進程在老進程退出之后,由init進程收養(yǎng),但是會繼續(xù)服務(wù)。

所以一步一步來看,關(guān)鍵是從第2步開始之后怎么做,所以我們先來看看第2步的實現(xiàn),這個應(yīng)該說很簡單,發(fā)送信號量到一個進程,使用kill命令即可,在facebook這個項目中發(fā)送的信號量有3個:SIGINT,SIGTERM,SIGUSR2,前面兩個信號收到后程序會直接退出,后面一個信號SIGUSR2才會執(zhí)行所謂的優(yōu)雅重啟。

第3步,正在運行的進程收到SIGUSR2信號后,會以子進程的方式啟動新的bin文件。先直接上代碼看:https://github.com/facebookgo/grace/blob/master/gracehttp/http.go

func (a *app) signalHandler(wg *sync.WaitGroup) {
 ch := make(chan os.Signal, 10)
 signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM, syscall.SIGUSR2)
 for {
  sig := <-ch
  switch sig {
  case syscall.SIGINT, syscall.SIGTERM: 
   // this ensures a subsequent INT/TERM will trigger standard go behaviour of
   // terminating. 執(zhí)行標準的go終止行為,程序就結(jié)束了
   signal.Stop(ch)
   a.term(wg)
   return
  case syscall.SIGUSR2: // 這里開始執(zhí)行優(yōu)雅重啟
   err := a.preStartProcess() 
   // 這個函數(shù)在源代碼中沒有具體實現(xiàn)功能,只是預(yù)留了一個鉤子函數(shù),用戶可以注冊自己的函數(shù),可以在重啟之前做些自定義的事情。一般情況下也沒有什么可以做的,除非有些特殊的服務(wù)環(huán)境或是狀態(tài)保存之類的,至少目前,我們的server還沒有遇到
   if err != nil {
    a.errors <- err
   }
   // we only return here if there's an error, otherwise the new process
   // will send us a TERM when it's ready to trigger the actual shutdown.
   if _, err := a.net.StartProcess(); err != nil { // 這里開始正式所謂的優(yōu)雅重啟   
    a.errors <- err
   }
  }
 }
}

a.net.StartProcess的過程我們來看看基本過程:

func (n *Net) StartProcess() (int, error) {
 listeners, err := n.activeListeners() // 獲取目前在監(jiān)聽的端口,這塊也是重點,下面重點介紹
 if err != nil {
  return 0, err
 }
 
 // Extract the fds from the listeners. 從監(jiān)聽端口中把文件描述符取出來
 files := make([]*os.File, len(listeners))
 for i, l := range listeners {
  files[i], err = l.(filer).File()
  if err != nil {
   return 0, err
  }
  defer files[i].Close()
 }
 
 // Use the original binary location. This works with symlinks such that if
 // the file it points to has been changed we will use the updated symlink.
 // 獲取可執(zhí)行bin文件的路勁,也可以是鏈接路勁,會使用最新的鏈接路徑作為啟動文件路勁的
 argv0, err := exec.LookPath(os.Args[0])
 if err != nil {
  return 0, err
 }
 
 // Pass on the environment and replace the old count key with the new one.
 // 獲取 LISTEN_FDS 換進變量值 
 var env []string
 for _, v := range os.Environ() {
  if !strings.HasPrefix(v, envCountKeyPrefix) {
   env = append(env, v)
  }
 }
 env = append(env, fmt.Sprintf("%s%d", envCountKeyPrefix, len(listeners)))
 
 allFiles := append([]*os.File{os.Stdin, os.Stdout, os.Stderr}, files...)
 // 這里調(diào)用一個golang底層的進程啟動函數(shù),來指定,上面獲取的參數(shù)來啟動進程
 process, err := os.StartProcess(argv0, os.Args, &os.ProcAttr{
  Dir: originalWD,
  Env: env,
  Files: allFiles,
 })
 if err != nil {
  return 0, err
 }
 // 返回新進程id。
 return process.Pid, nil 
}

以上是啟動新進程,并且接管監(jiān)聽端口的過程, 一般情況下端口是不可以重復(fù)監(jiān)聽的,所以這里就要需要使用比較特別的辦法,從上面的代碼來看就是讀取監(jiān)聽端口的文件描述符,并且把監(jiān)聽端口的文件描述符傳遞給子進程,子進程里從這個文件描述符實現(xiàn)對端口的監(jiān)聽

另外還有一個比較特別的地方就是老的接口怎么關(guān)閉的問題,關(guān)閉必須要把已經(jīng)收到的請求處理完成之后再關(guān)閉。為此facebook的同學另外開了一個項目httpdown,繼承了原始的httpserver,但是多了對各種鏈接狀態(tài)的維護和處理,這部分后面在分析。

總結(jié)

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

相關(guān)文章

  • gin框架Context如何獲取Get?Query?Param函數(shù)數(shù)據(jù)

    gin框架Context如何獲取Get?Query?Param函數(shù)數(shù)據(jù)

    這篇文章主要為大家介紹了gin框架Context?Get?Query?Param函數(shù)獲取數(shù)據(jù),有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-03-03
  • Go語言字符串及strings和strconv包使用實例

    Go語言字符串及strings和strconv包使用實例

    字符串是工作中最常用的,值得我們專門的練習一下,下面這篇文章主要給大家介紹了關(guān)于Go語言字符串及strings和strconv包使用的相關(guān)資料,文中通過代碼介紹的非常詳細,需要的朋友可以參考下
    2024-06-06
  • 一文帶你了解Golang中的WaitGroups

    一文帶你了解Golang中的WaitGroups

    WaitGroups是同步你的goroutines的一種有效方式。這篇文章主要來和大家聊聊Golang中WaitGroups的使用,感興趣的小伙伴可以跟隨小編一起了解一下
    2023-03-03
  • Go中的 panic / recover 簡介與實踐記錄

    Go中的 panic / recover 簡介與實踐記錄

    這篇文章主要介紹了Go中的 panic / recover 簡介與實踐,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2023-04-04
  • Golang獲取當前時間代碼

    Golang獲取當前時間代碼

    本文給大家匯總介紹了golang中的相關(guān)的時間的操作,有需要的小伙伴可以拿走參考下
    2018-10-10
  • 一文搞懂Go語言中條件語句的使用

    一文搞懂Go語言中條件語句的使用

    這篇文章主要介紹了Go語言中五個常用條件語句的使用,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2022-04-04
  • Go實現(xiàn)后臺任務(wù)調(diào)度系統(tǒng)的實例代碼

    Go實現(xiàn)后臺任務(wù)調(diào)度系統(tǒng)的實例代碼

    平常我們在開發(fā)API的時候,前端傳遞過來的大批數(shù)據(jù)需要經(jīng)過后端處理,如果后端處理的速度快,前端響應(yīng)就快,反之則很慢,影響用戶體驗,為了解決這一問題,需要我們自己實現(xiàn)后臺任務(wù)調(diào)度系統(tǒng),本文將介紹如何用Go語言實現(xiàn)后臺任務(wù)調(diào)度系統(tǒng),需要的朋友可以參考下
    2023-06-06
  • golang協(xié)程池模擬實現(xiàn)群發(fā)郵件功能

    golang協(xié)程池模擬實現(xiàn)群發(fā)郵件功能

    這篇文章主要介紹了golang協(xié)程池模擬實現(xiàn)群發(fā)郵件功能,本文給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2021-05-05
  • GoLang函數(shù)與面向接口編程全面分析講解

    GoLang函數(shù)與面向接口編程全面分析講解

    這篇文章主要介紹了GoLang函數(shù)與面向接口編程,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習吧
    2023-01-01
  • golang讀取yaml配置文件的示例代碼

    golang讀取yaml配置文件的示例代碼

    在項目開發(fā)中,經(jīng)常需要把一些配置文件常量提取到統(tǒng)一配置文件進行維護,go項目在開發(fā)中常常把需要維護的常量或者配置提取到y(tǒng)aml文件,所以本文主要來為大家介紹一下golang如何讀取yaml配置文件吧
    2023-11-11

最新評論