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

首頁 > 編程 > Golang > 正文

詳解如何熱重啟golang服務器

2020-04-01 18:54:29
字體:
來源:轉載
供稿:網友

服務端代碼經常需要升級,對于線上系統的升級常用的做法是,通過前端的負載均衡(如nginx)來保證升級時至少有一個服務可用,依次(灰度)升級。

而另一種更方便的方法是在應用上做熱重啟,直接升級應用而不停服務。

原理

熱重啟的原理非常簡單,但是涉及到一些系統調用以及父子進程之間文件句柄的傳遞等等細節比較多。
處理過程分為以下幾個步驟:

  • 監聽信號(USR2)
  • 收到信號時fork子進程(使用相同的啟動命令),將服務監聽的socket文件描述符傳遞給子進程
  • 子進程監聽父進程的socket,這個時候父進程和子進程都可以接收請求
  • 子進程啟動成功之后,父進程停止接收新的連接,等待舊連接處理完成(或超時)
  • 父進程退出,升級完成

細節

  • 父進程將socket文件描述符傳遞給子進程可以通過命令行,或者環境變量等
  • 子進程啟動時使用和父進程一樣的命令行,對于golang來說用更新的可執行程序覆蓋舊程序
  • server.Shutdown()優雅關閉方法是go1.8的新特性
  • server.Serve(l)方法在Shutdown時立即返回,Shutdown方法則阻塞至context完成,所以Shutdown的方法要寫在主goroutine中

代碼

package mainimport (  "context"  "errors"  "flag"  "log"  "net"  "net/http"  "os"  "os/exec"  "os/signal"  "syscall"  "time") var (  server  *http.Server  listener net.Listener  graceful = flag.Bool("graceful", false, "listen on fd open 3 (internal use only)")) func handler(w http.ResponseWriter, r *http.Request) {  time.Sleep(20 * time.Second)  w.Write([]byte("hello world233333!!!!"))} func main() {  flag.Parse()   http.HandleFunc("/hello", handler)  server = &http.Server{Addr: ":9999"}   var err error  if *graceful {    log.Print("main: Listening to existing file descriptor 3.")    // cmd.ExtraFiles: If non-nil, entry i becomes file descriptor 3+i.    // when we put socket FD at the first entry, it will always be 3(0+3)    f := os.NewFile(3, "")    listener, err = net.FileListener(f)  } else {    log.Print("main: Listening on a new file descriptor.")    listener, err = net.Listen("tcp", server.Addr)  }   if err != nil {    log.Fatalf("listener error: %v", err)  }   go func() {    // server.Shutdown() stops Serve() immediately, thus server.Serve() should not be in main goroutine    err = server.Serve(listener)    log.Printf("server.Serve err: %v/n", err)  }()  signalHandler()  log.Printf("signal end")} func reload() error {  tl, ok := listener.(*net.TCPListener)  if !ok {    return errors.New("listener is not tcp listener")  }   f, err := tl.File()  if err != nil {    return err  }   args := []string{"-graceful"}  cmd := exec.Command(os.Args[0], args...)  cmd.Stdout = os.Stdout  cmd.Stderr = os.Stderr  // put socket FD at the first entry  cmd.ExtraFiles = []*os.File{f}  return cmd.Start()} func signalHandler() {  ch := make(chan os.Signal, 1)  signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM, syscall.SIGUSR2)  for {    sig := <-ch    log.Printf("signal: %v", sig)     // timeout context for shutdown    ctx, _ := context.WithTimeout(context.Background(), 20*time.Second)    switch sig {    case syscall.SIGINT, syscall.SIGTERM:      // stop      log.Printf("stop")      signal.Stop(ch)      server.Shutdown(ctx)      log.Printf("graceful shutdown")      return    case syscall.SIGUSR2:      // reload      log.Printf("reload")      err := reload()      if err != nil {        log.Fatalf("graceful restart error: %v", err)      }      server.Shutdown(ctx)      log.Printf("graceful reload")      return    }  }}

references

Graceful Restart in Golang 

facebookgo/grace

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持VEVB武林網。


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 砀山县| 柘城县| 岳西县| 安远县| 海宁市| 广南县| 湘潭县| 达孜县| 青龙| 巴彦淖尔市| 宕昌县| 晋城| 乌拉特中旗| 通河县| 平顶山市| 清河县| 托克托县| 辽阳县| 泊头市| 泌阳县| 海口市| 霍州市| 信丰县| 栾川县| 元朗区| 五原县| 东海县| 吴江市| 湖口县| 博白县| 富源县| 石屏县| 姚安县| 上饶市| 株洲县| 洮南市| 浦县| 嘉荫县| 华安县| 宜城市| 赫章县|