golang 熱更新技巧 - Golang教程网

序言

Golang標準庫的http部分提供了強大的web應用支持，再加上negroni等中間件框架的支持，能夠開發高性能的web應用（如提供Restful的api服務等）。一般這些web應用部署在多臺Linux操做系統的應用服務器上，並用Nginx等作爲反向代理，實現高可用的集羣服務。當應用版本升級時，如何實現比較優雅的多態服務器的版本更新呢？git

問題分析

Web應用的更新，我以爲可能須要考慮幾個方面的問題：github

編譯好的應用二進制文件、配置文件上傳到服務器上；
應用服務器能感知到有新的版本上傳；
在沒有中止服務的狀況下，熱更新版本；
最好全部的更新過程，能夠腳本化，減小手動操做的錯誤。

方案

其實，go社區有一些開源項目，能夠自動檢測web應用的改變，並實現自動的更新，但這些應用都是檢測源碼、資源文件的更新，啓動build過程，實現自動的編譯和重啓，例如 gin和 fresh，這些應用適合應用於開發和測試階段，可能並不適合應用的部署和更新，但提供了良好的思路。web

部署環境的目錄及版本的上傳我將發佈的應用二進制文件和配置文件，存放在某個目錄下，如 ~/app/release，每一個版本都保留在這個目錄中，例如 app.1.0、app.1.一、app.2.0，一旦發現有問題，能夠及時的回滾。同時，在~/app目錄下，利用軟連接文件，指向到最新版本，如json

ln -s ~/app/release/app.2.0 ~/app/app.bin

此外，利用一個保存在 ~/app/release 下的文本文件，來指明當前應用的版本，如current.conf：api

{
    "bin.file": "~/app/release/app.2.0",
    "cfg.file": "~/app/release/cfg.2.0"
}

當須要更新服務器的版本時，能夠經過腳本調用scp，將新版本上傳到release目錄下，而後更新current.conf文件。監控current.conf文件，獲知版本更新 current.conf文件中是當前的版本，一旦這個文件發生變化，即表示有版本須要更新（或者回滾），咱們只須要監控這個文件的變化，一旦發生變化，則作相應的處理。文件的監控，能夠經過 fsnotify來實現。服務器

func watch() {
    watcher, err := fsnotify.NewWatcher()
    if err != nil {
        logger.Fatal(err)
    }
    defer watcher.Close()

    go func() {
        for {
                select {
                case event := <-watcher.Events:
                    logger.Println("event:", event)
                    if event.Op&fsnotify.Write == fsnotify.Write {
                        logger.Println("notify runner to do the ln -s and restart server.")
                        restartChan <- true
                    }
                case err := <-watcher.Errors:
                    logger.Println("error:", err)
            }
        }
    }()

    err = watcher.Add("/path/to/current.conf")
    if err != nil {
        logger.Fatal(err)
    }

    <- make(chan bool)
}

重啓服務監控到current.conf文件的變化後，接下來就是重啓服務。爲了讓服務不中斷，優雅的進行重啓，能夠利用 endless 來替換標準庫net/http的ListenAndServe：app

n := negroni.New()
    n.Use(middleware.NewRecovery())
    n.Use(middleware.NewMaintainMiddleware())
    n.Use(middleware.NewLogMiddleware())
    n.Use(middleware.NewStatic(http.Dir("static")))
    n.UseHandler(router.NewRouter())

    log.Fatal(endless.ListenAndServe(":3000", n))

在current.conf變動後，首先將~/app下的軟連接文件指向最新版本，而後利用框架

kill -HUP

通知應用重啓。less

func run() {
    for {
        <- restartChan

        c, err := ioutil.ReadFile("/path/to/current.conf")
        if err != nil {
            logger.Println("current.conf read error:", err)
            return
        }

        var j interface{}
        err = json.Unmarshal(c, &j)
        if err != nil {
            logger.Println("current.conf parse error:", err)
            return
        }

        parsed, ok := j.(map[string]interface{})
        if !ok {
            logger.Println("current.conf parse error: mapping errors")
            return
        }

        exec.Command("rm", "app.bin").Run()
        exec.Command("ln", "-s", parsed["bin.file"].(string), "app.bin").Run()

        exec.Command("rm", "app.conf").Run()
        exec.Command("ln", "-s", parsed["cfg.file"].(string), "app.cfg").Run()

        if !started {
            cmd := exec.Command("./app.bin", "-c", "app.cfg")
            started = true
        } else {
            processes, _ := ps.Processes()
            for _, v := range processes {
                if strings.Contains(v.Executable(), parsed["bin.file"]) {
                    process, _ := os.FindProcess(v.Pid())
                    process.Signal(syscall.SIGHUP)
                }
            }
        }
    }
}