• <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>
            Fork me on GitHub
            隨筆 - 215  文章 - 13  trackbacks - 0
            <2017年5月>
            30123456
            78910111213
            14151617181920
            21222324252627
            28293031123
            45678910


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

            常用鏈接

            留言簿(1)

            隨筆分類

            隨筆檔案

            相冊(cè)

            Awesome

            Blog

            Book

            GitHub

            Link

            搜索

            •  

            積分與排名

            • 積分 - 216795
            • 排名 - 118

            最新評(píng)論

            閱讀排行榜

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

            英文原文:Graceful server restart with Go

            標(biāo)簽: 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個(gè)月前 (共 7 段, 翻譯完成于 12-24) (30評(píng))

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

            image

            目標(biāo):

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

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

            • 新的進(jìn)程要能夠啟動(dòng)并替換掉舊的。

            pseudo
            pseudo
            翻譯于 11個(gè)月前

            2人頂

             翻譯的不錯(cuò)哦!

            原理

            在基于Unix的操作系統(tǒng)中,signal(信號(hào))是與長(zhǎng)時(shí)間運(yùn)行的進(jìn)程交互的常用方法.

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

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

            如果收到SIGHUP信號(hào),優(yōu)雅地重啟進(jìn)程需要以下幾個(gè)步驟:

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

            2. 啟用新版本的進(jìn)程

            3. 將socket“交給”新進(jìn)程,新進(jìn)程開始接受新連接請(qǐng)求

            4. 舊進(jìn)程處理完畢后立即停止。

            pseudo
            pseudo
            翻譯于 11個(gè)月前

            2人頂

             翻譯的不錯(cuò)哦!

            停止接受連接請(qǐng)求

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

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

            跳出這個(gè)循環(huán)的最簡(jiǎn)單方式是在socket監(jiān)聽器上設(shè)置一個(gè)超時(shí),當(dāng)調(diào)用listener.SetTimeout(time.Now())后,listener.Accept()會(huì)立即返回一個(gè)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
                }
              }}

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

            pseudo
            pseudo
            翻譯于 11個(gè)月前

            3人頂

             翻譯的不錯(cuò)哦!

            啟動(dòng)新進(jìn)程

            Go提供了一個(gè)原始類型ForkExec來產(chǎn)生新進(jìn)程.你可以與這個(gè)新進(jì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)[…]

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

            pseudo
            pseudo
            翻譯于 11個(gè)月前

            1人頂

             翻譯的不錯(cuò)哦!

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

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

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

            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)}

             

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

            Garfielt
            Garfielt
            翻譯于 11個(gè)月前

            1人頂

             翻譯的不錯(cuò)哦!

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

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

            每次接收一個(gè)連接,在WaitGroup上加1,然后,我們?cè)谒瓿蓵r(shí)將計(jì)數(shù)器減一:

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

             

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

            Ley
            Ley
            翻譯于 11個(gè)月前

            1人頂

             翻譯的不錯(cuò)哦!

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

            有time.Timer,實(shí)現(xiàn)很簡(jiǎ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}

            完整的示例

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

            結(jié)論

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

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

            鏈接:

            — Léo Unbekandt CTO @ Appsdeck

            Garfielt
            Garfielt
            翻譯于 11個(gè)月前

            1人頂

             翻譯的不錯(cuò)哦!

            posted on 2015-12-03 11:57 思月行云 閱讀(278) 評(píng)論(0)  編輯 收藏 引用 所屬分類: Golang
            欧美精品国产综合久久| 亚洲狠狠婷婷综合久久蜜芽 | 性高朝久久久久久久久久| 午夜视频久久久久一区| 性高湖久久久久久久久| 国产精品成人99久久久久 | 久久久久久久综合综合狠狠| 日本久久中文字幕| a高清免费毛片久久| 青青草原综合久久大伊人导航| 一本色道久久88精品综合| 国产成人久久激情91| 99久久这里只精品国产免费 | 久久99精品久久久久久秒播 | 少妇人妻88久久中文字幕| 香港aa三级久久三级| 亚洲色欲久久久综合网| 久久精品无码专区免费| 久久er国产精品免费观看2| 99久久做夜夜爱天天做精品| 国产精品成人99久久久久 | 色偷偷888欧美精品久久久| 中文国产成人精品久久不卡| 久久99精品国产麻豆婷婷| a高清免费毛片久久| 人妻精品久久久久中文字幕69| 久久国产视频网| 四虎亚洲国产成人久久精品| 国产AⅤ精品一区二区三区久久| 久久99精品久久久久久动态图| 大香伊人久久精品一区二区| 亚洲国产精品无码久久久久久曰 | 久久综合狠狠综合久久| 久久天天躁狠狠躁夜夜av浪潮| 99re久久精品国产首页2020| 精品无码久久久久久尤物| 久久ww精品w免费人成| 色综合久久综合中文综合网| 一本色道久久88精品综合| 久久夜色精品国产噜噜亚洲AV| 色狠狠久久AV五月综合|