青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

Fork me on GitHub
隨筆 - 215  文章 - 13  trackbacks - 0
<2025年9月>
31123456
78910111213
14151617181920
21222324252627
2829301234
567891011


專注即時通訊及網(wǎng)游服務(wù)端編程
------------------------------------
Openresty 官方模塊
Openresty 標準模塊(Opm)
Openresty 三方模塊
------------------------------------
本博收藏大部分文章為轉(zhuǎn)載,并在文章開頭給出了原文出處,如有再轉(zhuǎn),敬請保留相關(guān)信息,這是大家對原創(chuàng)作者勞動成果的自覺尊重!!如為您帶來不便,請于本博下留言,謝謝配合。

常用鏈接

留言簿(1)

隨筆分類

隨筆檔案

相冊

Awesome

Blog

Book

GitHub

Link

搜索

  •  

積分與排名

  • 積分 - 219731
  • 排名 - 117

最新評論

閱讀排行榜

http://www.oschina.net/translate/graceful-server-restart-with-go
使用 Go 語言實現(xiàn)優(yōu)雅的服務(wù)器重啟

英文原文:Graceful server restart with Go

標簽: Go
#TagsSwitcher{color:#A00;} #RecTags,#MyTags{margin:5px 0;} #RecTags a.tag{line-height:24px;} #favor_form p:first-child{margin:5px 0;} #favor_form{width:200px;} #favor_form p {color:#666;} #favor_form form{min-height: 85px;width:200px;} #favor_form form ._favor_input{display:block;margin:2px 0;width:199px;} #favor_form form ._favor_button{float:left;padding:2px 5px;} .favor_ok {text-align:center;font-size:10.5pt;width:199px;height:60px;margin-top:10px;} #TagsSwitcher{cursor:pointer;float:right;margin-top:10px;} #MyTags{display:none;width:199px;} #MyTags a.tag {float:left; background-color: #E0EAF1;border-bottom: 1px solid #3E6D8E;border-right: 1px solid #7F9FB6;color: #3E6D8E;font-size: 8pt;line-height: 16px;margin: 2px 2px 2px 0;padding: 2px 4px;text-decoration: none;white-space: nowrap;} #MyTags a.tag:hover{background-color: #3E6D8E;color: #FFF;} 238人收藏此文章, 我要收藏 oschina 推薦于 11個月前 (共 7 段, 翻譯完成于 12-24) (30評)

Go被設(shè)計為一種后臺語言,它通常也被用于后端程序中。服務(wù)端程序是GO語言最常見的軟件產(chǎn)品。在這我要解決的問題是:如何干凈利落地升級正在運行的服務(wù)端程序。

image

目標:

  • 不關(guān)閉現(xiàn)有連接:例如我們不希望關(guān)掉已部署的運行中的程序。但又想不受限制地隨時升級服務(wù)。

  • socket連接要隨時響應(yīng)用戶請求:任何時刻socket的關(guān)閉可能使用戶返回'連接被拒絕'的消息,而這是不可取的。

  • 新的進程要能夠啟動并替換掉舊的。

pseudo
pseudo
翻譯于 11個月前

2人頂

 翻譯的不錯哦!

原理

在基于Unix的操作系統(tǒng)中,signal(信號)是與長時間運行的進程交互的常用方法.

  • SIGTERM: 優(yōu)雅地停止進程

  • SIGHUP: 重啟/重新加載進程 (例如: nginx, sshd, apache)

如果收到SIGHUP信號,優(yōu)雅地重啟進程需要以下幾個步驟:

  1. 服務(wù)器要拒絕新的連接請求,但要保持已有的連接。

  2. 啟用新版本的進程

  3. 將socket“交給”新進程,新進程開始接受新連接請求

  4. 舊進程處理完畢后立即停止。

pseudo
pseudo
翻譯于 11個月前

2人頂

 翻譯的不錯哦!

停止接受連接請求

服務(wù)器程序的共同點:持有一個死循環(huán)來接受連接請求:

1
2
3
for {
  conn, err := listener.Accept()
  // Handle connection}

跳出這個循環(huán)的最簡單方式是在socket監(jiān)聽器上設(shè)置一個超時,當調(diào)用listener.SetTimeout(time.Now())后,listener.Accept()會立即返回一個timeout err,你可以捕獲并處理:

1
2
3
4
5
6
7
8
for {
  conn, err := listener.Accept()
  if err != nil {
    if nerr, ok := err.(net.Err); ok && nerr.Timeout() {
       fmt.Println(“Stop accepting connections”)
       return
    }
  }}

注意這個操作與關(guān)閉listener有所不同。這樣進程仍在監(jiān)聽服務(wù)器端口,但連接請求會被操作系統(tǒng)的網(wǎng)絡(luò)棧排隊,等待一個進程接受它們。

pseudo
pseudo
翻譯于 11個月前

3人頂

 翻譯的不錯哦!

啟動新進程

Go提供了一個原始類型ForkExec來產(chǎn)生新進程.你可以與這個新進程共享某些消息,例如文件描述符或環(huán)境參數(shù)。

1
2
3
4
5
6
execSpec := &syscall.ProcAttr{
  Env:   os.Environ(),
  Files: []uintptr{os.Stdin.Fd(), os.Stdout.Fd(), os.Stderr.Fd()},
}fork,
 
err := syscall.ForkExec(os.Args[0], os.Args, execSpec)[…]

你會發(fā)現(xiàn)這個進程使用完全相同的參數(shù)os.Args啟動了一個新進程。

pseudo
pseudo
翻譯于 11個月前

1人頂

 翻譯的不錯哦!

發(fā)送socket到子進程并恢復(fù)它

正如你先前看到的,你可以將文件描述符傳遞到新進程,這需要一些UNIX魔法(一切都是文件),我們可以把socket發(fā)送到新進程中,這樣新進程就能夠使用它并接收及等待新的連接。

但fork-execed進程需要知道它必須從文件中得到socket而不是新建一個(有些興許已經(jīng)在使用了,因為我們還沒斷開已有的監(jiān)聽)。你可以按任何你希望的方法來,最常見的是通過環(huán)境變量或命令行標志。

1
2
3
4
listenerFile, err := listener.File()if err != nil {
  log.Fatalln("Fail to get socket file descriptor:", err)}listenerFd := listenerFile.Fd()// Set a flag for the new process start processos.Setenv("_GRACEFUL_RESTART", "true")execSpec := &syscall.ProcAttr{
  Env:   os.Environ(),
  Files: []uintptr{os.Stdin.Fd(), os.Stdout.Fd(), os.Stderr.Fd(), listenerFd},}// Fork exec the new version of your serverfork, err := syscall.ForkExec(os.Args[0], os.Args, execSpec)

 

然后在程序的開始處:

1
2
3
4
5
6
7
8
9
10
11
12
var listener *net.TCPListenerif os.Getenv("_GRACEFUL_RESTART") == "true" {
  file := os.NewFile(3"/tmp/sock-go-graceful-restart")
  listener, err := net.FileListener(file)
  if err != nil {
    // handle
  }
  var bool ok
  listener, ok = listener.(*net.TCPListener)
  if !ok {
    // handle
  }} else {
  listener, err = newListenerWithPort(12345)}

 

文件描述沒有被隨機的選擇為3,這是因為uintptr的切片已經(jīng)發(fā)送了fork,監(jiān)聽獲取了索引3。留意隱式聲明問題

Garfielt
Garfielt
翻譯于 11個月前

1人頂

 翻譯的不錯哦!

最后一步,等待舊服務(wù)連接停止

到此為止,就這樣,我們已經(jīng)將其傳到另一個正在正確運行的進程,對于舊服務(wù)器的最后操作是等其連接關(guān)閉。由于標準庫里提供了sync.WaitGroup結(jié)構(gòu)體,用go實現(xiàn)這個功能很簡單。

每次接收一個連接,在WaitGroup上加1,然后,我們在它完成時將計數(shù)器減一:

1
2
3
for {  conn, err := listener.Accept()
 
  wg.Add(1)  go func() {    handle(conn)    wg.Done()  }()}

 

至于等待連接的結(jié)束,你僅需要wg.Wait(),因為沒有新的連接,我們等待wg.Done()已經(jīng)被所有正在運行的handler調(diào)用。

Ley
Ley
翻譯于 11個月前

1人頂

 翻譯的不錯哦!

Bonus: 不要無限制等待,給定限量的時間

有time.Timer,實現(xiàn)很簡單:

1
2
3
4
5
timeout := time.NewTimer(time.Minute)wait := make(chan struct{})go func() {
  wg.Wait()
  wait <- struct{}{}}()select {case <-timeout.C:
  return WaitTimeoutErrorcase <-wait:
  return nil}

完整的示例

這篇文章中的代碼片段都是從這個完整的示例中提取的:https://github.com/Scalingo/go-graceful-restart-example

結(jié)論

socket傳遞配合ForkExec使用確實是一種無干擾更新進程的有效方式,在最大時間上,新的連接會等待幾毫秒——用于服務(wù)的啟動和恢復(fù)socket,但這個時間很短。

這篇文章是我#周五技術(shù)系列的一部分,下這個周不會有新的更新了,大家圣誕節(jié)快樂。

鏈接:

— Léo Unbekandt CTO @ Appsdeck

Garfielt
Garfielt
翻譯于 11個月前

1人頂

 翻譯的不錯哦!

posted on 2015-12-03 11:57 思月行云 閱讀(283) 評論(0)  編輯 收藏 引用 所屬分類: Golang
青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            欧美成人精品在线观看| 亚洲精品永久免费| 亚洲欧美卡通另类91av| 国产精品hd| 亚洲一区二区三区乱码aⅴ| 亚洲精品国久久99热| 免费成人高清视频| 亚洲美女中文字幕| 日韩一级黄色大片| 国产麻豆日韩| 六月婷婷久久| 欧美极品在线观看| 亚洲制服少妇| 欧美一级在线视频| 激情五月***国产精品| 亚洲国产导航| 日韩一级二级三级| 中文一区在线| 国产在线精品一区二区中文| 欧美成人精品h版在线观看| 欧美韩日一区二区三区| 亚洲女同在线| 久久九九精品| 亚洲一区二区三区色| 欧美在线二区| 99在线精品观看| 欧美一区二区三区免费大片| 亚洲精品在线看| 欧美一区成人| 一区二区精品国产| 久久久另类综合| 亚洲欧美资源在线| 美女脱光内衣内裤视频久久影院 | 亚洲欧美精品一区| 狠狠做深爱婷婷久久综合一区| 亚洲黄色在线| 韩国在线一区| 亚洲小说春色综合另类电影| 亚洲黄色小视频| 亚洲欧美三级在线| 亚洲无毛电影| 麻豆成人av| 久久久久久穴| 国产精品久久久久久久久搜平片| 欧美不卡激情三级在线观看| 国产精品igao视频网网址不卡日韩| 女同一区二区| 国产亚洲欧美一区二区| 亚洲视频欧美在线| 99国产一区二区三精品乱码| 久久久综合精品| 久久成人国产精品| 国产精品久久福利| 亚洲伦理在线观看| 亚洲人成人77777线观看| 久久精品国产综合精品| 午夜宅男久久久| 国产精品成人观看视频免费| 亚洲人成人77777线观看| 亚洲高清不卡| 久久青草久久| 免费视频亚洲| 亚洲大片在线观看| 久久久夜精品| 欧美成人亚洲| 亚洲区免费影片| 裸体歌舞表演一区二区| 欧美bbbxxxxx| 亚洲国产一区在线观看| 老鸭窝91久久精品色噜噜导演| 久久天天躁夜夜躁狠狠躁2022| 国产深夜精品福利| 欧美亚洲在线视频| 久久天天躁狠狠躁夜夜av| 黄色欧美成人| 麻豆亚洲精品| 亚洲精品在线看| 这里只有精品在线播放| 欧美少妇一区| 亚洲欧美日韩国产综合精品二区| 亚洲精品中文字幕在线| 欧美日韩一区二区国产| 亚洲久久成人| 欧美一区二区三区视频在线观看| 国产精品久久久久久久久免费桃花| 亚洲午夜一区二区| 欧美在线综合视频| 在线免费观看欧美| 欧美精品二区| 亚洲欧美国产不卡| 久久色中文字幕| 亚洲精品久久久久中文字幕欢迎你| 欧美日韩1区| 亚洲永久免费精品| 蜜臀av性久久久久蜜臀aⅴ四虎| 最新日韩在线| 国产精品人人做人人爽| 久久国产精彩视频| 91久久夜色精品国产九色| 亚洲一区二区三区四区五区午夜| 国产欧美日韩视频| 久久午夜精品一区二区| 一本色道久久综合狠狠躁篇的优点| 欧美影片第一页| 亚洲免费观看在线视频| 国产精品推荐精品| 欧美成人有码| 欧美在线一二三四区| 亚洲人成网站777色婷婷| 久久国产精品免费一区| 99综合视频| 国产一区二区三区直播精品电影| 欧美精品一区二区精品网| 性欧美videos另类喷潮| 亚洲精品乱码久久久久久黑人| 久久国产精品99久久久久久老狼| 亚洲精品黄网在线观看| 国产一区高清视频| 欧美日韩亚洲高清一区二区| 久久在线播放| 午夜欧美大尺度福利影院在线看 | 91久久精品美女高潮| 国产精品一区二区你懂的| 欧美激情国产日韩| 久久精品一区中文字幕| 亚洲欧美国产日韩中文字幕| 亚洲激情视频在线观看| 麻豆精品视频在线观看视频| 亚洲欧美色婷婷| 一区二区三区高清| 最新日韩av| 91久久久一线二线三线品牌| 韩国av一区二区三区四区| 国产麻豆9l精品三级站| 国产精品久久久久久久浪潮网站| 欧美激情久久久| 欧美成人中文字幕在线| 六月天综合网| 欧美成人中文字幕| 欧美成人午夜激情在线| 美女在线一区二区| 久热精品视频在线观看| 久久成人在线| 久久久精品网| 久久亚洲精品视频| 久久亚洲春色中文字幕| 久久国产福利| 另类欧美日韩国产在线| 久久综合图片| 欧美成人精精品一区二区频| 免播放器亚洲| 欧美精选午夜久久久乱码6080| 欧美大片免费看| 欧美精品色综合| 欧美人与性动交a欧美精品| 亚洲国产精品久久人人爱蜜臀| 一区二区日韩精品| 在线一区二区三区四区五区| 亚洲综合色丁香婷婷六月图片| 亚洲欧美日韩精品综合在线观看 | 国产一区日韩二区欧美三区| 黑人操亚洲美女惩罚| 亚洲大片一区二区三区| 日韩网站免费观看| 亚洲自啪免费| 久久久中精品2020中文| 男同欧美伦乱| 亚洲免费av观看| 午夜一区二区三视频在线观看 | 亚洲精品久久久久久久久久久久久 | 久久偷看各类wc女厕嘘嘘偷窃| 六月天综合网| 99re6热在线精品视频播放速度| 亚洲免费一级电影| 久久精品综合一区| 欧美精品在线观看播放| 国产精品一区视频| 亚洲成人自拍视频| 亚洲午夜精品一区二区| 久久久久久久久久久久久女国产乱| 免费中文字幕日韩欧美| 夜夜嗨av一区二区三区免费区| 午夜精品久久久久久久男人的天堂 | 久久精品人人做人人爽| 欧美顶级艳妇交换群宴| 一区二区欧美视频| 久久另类ts人妖一区二区| 欧美日本国产在线| 国产在线视频欧美| 在线视频免费在线观看一区二区| 久久久久成人精品| 亚洲美女啪啪| 久久久久久久综合| 国产精品美女午夜av| 亚洲黄色在线| 久久米奇亚洲| 亚洲一区二区三区久久| 欧美精品国产一区二区| 伊人成年综合电影网| 午夜在线不卡|