a亚洲精品_精品国产91乱码一区二区三区_亚洲精品在线免费观看视频_欧美日韩亚洲国产综合_久久久久久久久久久成人_在线区

首頁 > 編程 > Golang > 正文

詳解如何熱重啟golang服務(wù)器

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

服務(wù)端代碼經(jīng)常需要升級(jí),對(duì)于線上系統(tǒng)的升級(jí)常用的做法是,通過前端的負(fù)載均衡(如nginx)來保證升級(jí)時(shí)至少有一個(gè)服務(wù)可用,依次(灰度)升級(jí)。

而另一種更方便的方法是在應(yīng)用上做熱重啟,直接升級(jí)應(yīng)用而不停服務(wù)。

原理

熱重啟的原理非常簡(jiǎn)單,但是涉及到一些系統(tǒng)調(diào)用以及父子進(jìn)程之間文件句柄的傳遞等等細(xì)節(jié)比較多。
處理過程分為以下幾個(gè)步驟:

  • 監(jiān)聽信號(hào)(USR2)
  • 收到信號(hào)時(shí)fork子進(jìn)程(使用相同的啟動(dòng)命令),將服務(wù)監(jiān)聽的socket文件描述符傳遞給子進(jìn)程
  • 子進(jìn)程監(jiān)聽父進(jìn)程的socket,這個(gè)時(shí)候父進(jìn)程和子進(jìn)程都可以接收請(qǐng)求
  • 子進(jìn)程啟動(dòng)成功之后,父進(jìn)程停止接收新的連接,等待舊連接處理完成(或超時(shí))
  • 父進(jìn)程退出,升級(jí)完成

細(xì)節(jié)

  • 父進(jìn)程將socket文件描述符傳遞給子進(jìn)程可以通過命令行,或者環(huán)境變量等
  • 子進(jìn)程啟動(dòng)時(shí)使用和父進(jìn)程一樣的命令行,對(duì)于golang來說用更新的可執(zhí)行程序覆蓋舊程序
  • server.Shutdown()優(yōu)雅關(guān)閉方法是go1.8的新特性
  • server.Serve(l)方法在Shutdown時(shí)立即返回,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

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持VEVB武林網(wǎng)。


發(fā)表評(píng)論 共有條評(píng)論
用戶名: 密碼:
驗(yàn)證碼: 匿名發(fā)表
主站蜘蛛池模板: 国产无套精品久久久久久 | 日日夜夜天天 | 国产精品不卡视频 | 91久久国产精品 | 国产一级片在线播放 | 国产一区二区三区 | 欧美一区二区视频免费观看 | 欧美日韩免费看 | 欧美日韩精品一区二区三区 | 国产色婷婷| 女人久久久 | 99精品欧美一区二区三区 | 爱爱免费视频网站 | 99热精品在线 | 亚洲人成中文字幕在线观看 | 成人免费毛片嘿嘿连载视频 | 欧美精品一区二区三区一线天视频 | 狠操av| 麻豆一区 | 欧美亚洲国产一区二区三区 | 伊人干综合 | 亚洲一区二区高清视频 | 嫩草懂你 | 欧日韩免费 | 国产91在线免费观看 | 日韩中文字幕国产 | 欧美精品一区二区三区在线播放 | 亚洲精美视频 | 日韩免费高清视频 | 成人一区二区三区在线 | 麻豆色呦呦 | 成人天堂噜噜噜 | 国产精品二区三区 | 美日韩在线观看 | 国产一区二区三区av在线 | 日本欧美在线观看 | www.天天草| 久久精品成人免费视频 | 国产美女精品视频免费观看 | 午夜小视频在线观看 | 久久精品久久久久久久久久久久久 |