Go Web服務(wù)優(yōu)雅平滑重啟
在生產(chǎn)環(huán)境中,當(dāng)我們需要對(duì)正在運(yùn)行的服務(wù)進(jìn)行升級(jí)時(shí),如何確保不影響當(dāng)前未處理完的請(qǐng)求,同時(shí)又能應(yīng)用新的代碼,是個(gè)極具挑戰(zhàn)性的問(wèn)題。
傳統(tǒng)的做法通常是停止當(dāng)前服務(wù),部署新代碼后再重啟服務(wù),但這種方式會(huì)導(dǎo)致正在處理的請(qǐng)求被強(qiáng)制中斷,用戶體驗(yàn)會(huì)受到很大的影響。
在這篇文章中,我將帶大家一起探索如何在 Go 語(yǔ)言中通過(guò)使用 endless 包來(lái)實(shí)現(xiàn)服務(wù)的優(yōu)雅重啟,即在不影響當(dāng)前正在處理的請(qǐng)求的情況下,完成服務(wù)的無(wú)縫升級(jí)。
什么是優(yōu)雅重啟?
優(yōu)雅重啟的核心思想是:在服務(wù)啟動(dòng)新的進(jìn)程處理新請(qǐng)求的同時(shí),允許舊的進(jìn)程繼續(xù)完成其手頭未完成的工作,然后再優(yōu)雅地退出。這種方式可以確保服務(wù)在升級(jí)的過(guò)程中不會(huì)出現(xiàn)中斷,提升用戶體驗(yàn)的同時(shí),也降低了在服務(wù)切換過(guò)程中的風(fēng)險(xiǎn)。
實(shí)現(xiàn)優(yōu)雅重啟的代碼示例
下面的代碼演示了如何使用 endless 包來(lái)實(shí)現(xiàn) Gin 服務(wù)的優(yōu)雅重啟。
package main
import (
"log"
"net/http"
"time"
"github.com/fvbock/endless"
"github.com/gin-gonic/gin"
)
func main() {
router := gin.Default()
router.GET("/ping", func(c *gin.Context) {
// 模擬程序處理請(qǐng)求需要 5 秒
time.Sleep(5 * time.Second)
c.JSON(http.StatusOK, gin.H{
"message": "pong",
})
})
// 默認(rèn) endless 服務(wù)器會(huì)監(jiān)聽(tīng)下列信號(hào):
// syscall.SIGHUP,syscall.SIGUSR1,syscall.SIGUSR2,syscall.SIGINT,syscall.SIGTERM 和 syscall.SIGTSTP
// 接收到 SIGHUP 信號(hào)將觸發(fā) `fork/restart` 實(shí)現(xiàn)優(yōu)雅重啟(kill -1 pid 會(huì)發(fā)送 SIGHUP 信號(hào))
// 接收到 syscall.SIGINT 或 syscall.SIGTERM 信號(hào)將觸發(fā)優(yōu)雅關(guān)機(jī)
// 接收到 SIGUSR2 信號(hào)將觸發(fā) HammerTime
// SIGUSR1 和 SIGTSTP 被用來(lái)觸發(fā)一些用戶自定義的 hook 函數(shù)
if err := endless.ListenAndServe(":8080", router); err != nil {
log.Printf("Server err: %v\n", err)
}
log.Println("Server exiting")
}
如何驗(yàn)證優(yōu)雅重啟?
為了驗(yàn)證這個(gè)實(shí)現(xiàn),我們可以通過(guò)以下步驟進(jìn)行測(cè)試:
- 打開(kāi)終端,執(zhí)行
go build -o gin_graceful_restart gin_graceful_restart.go編譯程序,然后執(zhí)行./gin_graceful_restart啟動(dòng)服務(wù)。終端會(huì)輸出當(dāng)前服務(wù)的 PID(例如:[pid] 12345)。 - 修改代碼中的
/ping接口的響應(yīng)內(nèi)容,比如將pong修改為pong1。 - 再次執(zhí)行
go build -o gin_graceful_restart gin_graceful_restart.go編譯程序。 - 在瀏覽器中訪問(wèn)
http://127.0.0.1:8080/ping,此時(shí)瀏覽器會(huì)等待服務(wù)返回響應(yīng)(由于接口模擬了 5 秒的延遲)。 - 在另一個(gè)終端中執(zhí)行
kill -1 12345命令,向服務(wù)發(fā)送syscall.SIGHUP信號(hào),12345 為第一步中的 PID。 - 依舊在第 4 步的瀏覽器中等待,等響應(yīng)到
pong信息之后,再次刷新頁(yè)面,你會(huì)發(fā)現(xiàn)響應(yīng)內(nèi)容變成了pong1,這意味著服務(wù)已經(jīng)應(yīng)用了新的代碼,同時(shí)之前的請(qǐng)求也得到了正確的處理。
Endless 的工作原理
endless 包實(shí)現(xiàn)優(yōu)雅重啟的原理非常簡(jiǎn)單:它會(huì) fork 一個(gè)新的子進(jìn)程來(lái)處理新的請(qǐng)求,而舊的進(jìn)程則繼續(xù)處理已經(jīng)接收的請(qǐng)求。當(dāng)舊的進(jìn)程處理完所有的請(qǐng)求后才會(huì)退出。因此,雖然 PID 發(fā)生了變化,但服務(wù)依舊保持了無(wú)縫銜接。
值得注意的是,由于 endless 的這種機(jī)制,當(dāng)你的項(xiàng)目是通過(guò)類似 supervisor 的軟件來(lái)管理進(jìn)程時(shí),這種方式就不再適用了。因?yàn)?supervisor 會(huì)根據(jù) PID 來(lái)管理進(jìn)程,而在優(yōu)雅重啟過(guò)程中 PID 是會(huì)變化的,這會(huì)導(dǎo)致 supervisor 認(rèn)為服務(wù)已經(jīng)崩潰。
總結(jié)
在實(shí)際的生產(chǎn)環(huán)境中,優(yōu)雅重啟是非常實(shí)用的一項(xiàng)技術(shù),它可以幫助我們?cè)诓挥绊懹脩趔w驗(yàn)的前提下,對(duì)服務(wù)進(jìn)行升級(jí)和維護(hù)。
到此這篇關(guān)于Go Web服務(wù)優(yōu)雅平滑重啟的文章就介紹到這了,更多相關(guān)Go 平滑重啟內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Go語(yǔ)言調(diào)用DeepSeek?API實(shí)現(xiàn)流式輸出和對(duì)話
DeepSeek是一個(gè)強(qiáng)大的AI模型服務(wù)平臺(tái),本文將詳細(xì)介紹如何使用Go語(yǔ)言調(diào)用DeepSeek?API實(shí)現(xiàn)流式輸出和對(duì)話功能,感興趣的小伙伴可以了解一下2025-02-02
golang語(yǔ)言http協(xié)議get拼接參數(shù)操作
這篇文章主要介紹了golang語(yǔ)言http協(xié)議get拼接參數(shù)操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-12-12
Golang?Compare?And?Swap算法詳細(xì)介紹
CAS算法是一種有名的無(wú)鎖算法。無(wú)鎖編程,即不使用鎖的情況下實(shí)現(xiàn)多線程之間的變量同步,也就是在沒(méi)有線程被阻塞的情況下實(shí)現(xiàn)變量的同步,所以也叫非阻塞同步Non-blocking?Synchronization2022-10-10
Go語(yǔ)言實(shí)現(xiàn)Viper配置管理筆記
Viper 是一個(gè)功能強(qiáng)大、靈活易用的配置管理工具,本文主要介紹了Go語(yǔ)言實(shí)現(xiàn)Viper配置管理筆記,具有一定的參考價(jià)值,感興趣的可以了解一下2025-04-04
Go語(yǔ)言實(shí)現(xiàn)順序存儲(chǔ)的線性表實(shí)例
這篇文章主要介紹了Go語(yǔ)言實(shí)現(xiàn)順序存儲(chǔ)的線性表的方法,實(shí)例分析了Go語(yǔ)言實(shí)現(xiàn)線性表的定義、插入、刪除元素等的使用技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-03-03

