一、優(yōu)雅關(guān)機(jī)

生活化例子

餐館關(guān)門(mén)：你去餐館吃火鍋，剛坐下點(diǎn)完菜（客戶(hù)端發(fā)請(qǐng)求），餐館老板突然接到通知要停電（收到關(guān)機(jī)指令）。老板很貼心，先停止接待新客人（停止接收新請(qǐng)求），等你這桌和其他正在吃飯的客人（正在處理的請(qǐng)求）都吃完了，再關(guān)門(mén)走人。這樣你的火鍋就能安安全全吃完，不會(huì)有任何損失。

代碼示例

package main
 
import (
	"context"
	"log"
	"net/http"
	"os"
	"os/signal"
	"syscall"
	"time"
 
	"github.com/gin-gonic/gin"
)
 
func main() {
	// 創(chuàng)建路由器
	router := gin.Default()
	router.GET("/cook-hotpot", func(c *gin.Context) {
		time.Sleep(5 * time.Second) // 模擬煮火鍋需要時(shí)間
		c.String(http.StatusOK, "火鍋煮好了，可以吃啦！")
	})
 
	// 創(chuàng)建服務(wù)器
	srv := &http.Server{
		Addr:    ":8080",
		Handler: router,
	}
 
	// 在單獨(dú)的goroutine中啟動(dòng)服務(wù)器
	go func() {
		if err := srv.ListenAndServe(); err != nil && err != http.ErrServerClosed {
			log.Fatalf("服務(wù)器監(jiān)聽(tīng)錯(cuò)誤: %s", err)
		}
	}()
 
	// 創(chuàng)建一個(gè)通道來(lái)接收系統(tǒng)信號(hào)
	quit := make(chan os.Signal, 1)
	signal.Notify(quit, syscall.SIGINT, syscall.SIGTERM) // 監(jiān)聽(tīng)Ctrl+C和系統(tǒng)終止信號(hào)
 
	// 阻塞等待信號(hào)
	<-quit
	log.Println("開(kāi)始優(yōu)雅關(guān)機(jī)...")
 
	// 設(shè)置一個(gè)5秒超時(shí)的上下文
	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancel()
 
	// 調(diào)用Shutdown方法優(yōu)雅關(guān)閉服務(wù)器
	if err := srv.Shutdown(ctx); err != nil {
		log.Fatalf("服務(wù)器優(yōu)雅關(guān)機(jī)失敗: %s", err)
	}
 
	log.Println("服務(wù)器已安全退出")
}

驗(yàn)證效果

• 運(yùn)行上面的代碼，啟動(dòng)服務(wù)。
• 打開(kāi)瀏覽器訪問(wèn) http://127.0.0.1:8080/cook-hotpot，模擬開(kāi)始煮火鍋。
• 在終端迅速執(zhí)行 Ctrl+C 命令，向程序發(fā)送關(guān)機(jī)信號(hào)。
• 觀察程序不會(huì)立即退出，而是等待火鍋煮好（請(qǐng)求處理完）后才退出，實(shí)現(xiàn)優(yōu)雅關(guān)機(jī)。

二、優(yōu)雅重啟

生活化例子

保安換班：小區(qū)門(mén)口有兩名保安，保安A（老進(jìn)程）正在值班，保安B（新進(jìn)程）來(lái)接班。保安A不會(huì)直接走人，而是等手頭的事（比如處理一輛正在進(jìn)入的車(chē)）忙完，再讓保安B接管工作。這樣小區(qū)門(mén)口的秩序不會(huì)因?yàn)閾Q班而受到影響。

代碼示例

package main
 
import (
	"log"
	"net/http"
	"time"
 
	"github.com/fvbock/endless"
	"github.com/gin-gonic/gin"
)
 
func main() {
	// 創(chuàng)建路由器
	router := gin.Default()
	router.GET("/greet", func(c *gin.Context) {
		time.Sleep(5 * time.Second) // 模擬處理請(qǐng)求需要時(shí)間
		c.String(http.StatusOK, "你好呀，歡迎來(lái)到小區(qū)！")
	})
 
	// 使用endless啟動(dòng)服務(wù)器，支持優(yōu)雅重啟
	if err := endless.ListenAndServe(":8080", router); err != nil {
		log.Fatalf("服務(wù)器監(jiān)聽(tīng)錯(cuò)誤: %s", err)
	}
 
	log.Println("服務(wù)器已安全退出")
}

驗(yàn)證效果

• 編譯并運(yùn)行上述代碼，終端會(huì)輸出當(dāng)前進(jìn)程的 PID。
• 修改代碼中處理請(qǐng)求函數(shù)的返回值，如將 "你好呀，歡迎來(lái)到小區(qū)！" 修改為 "歡迎光臨，小區(qū)新保安在此！"，然后重新編譯。
• 打開(kāi)瀏覽器訪問(wèn) http://127.0.0.1:8080/greet，模擬車(chē)輛進(jìn)入小區(qū)。
• 在終端迅速執(zhí)行 kill -1 <PID> 命令，向程序發(fā)送優(yōu)雅重啟信號(hào)。
• 等當(dāng)前請(qǐng)求處理完（保安A處理完手頭的事），再次訪問(wèn)時(shí)會(huì)收到新的歡迎語(yǔ)，說(shuō)明在不影響當(dāng)前請(qǐng)求的情況下完成了優(yōu)雅重啟，同時(shí)進(jìn)程號(hào)也變成了新的（保安B接班）。

三、總結(jié)

優(yōu)雅關(guān)機(jī)和優(yōu)雅重啟的核心就是“有始有終”，不甩手不管正在做的事。

優(yōu)雅關(guān)機(jī)就像餐館老板等你吃完火鍋再關(guān)門(mén)，通過(guò)監(jiān)聽(tīng)系統(tǒng)信號(hào)（如Ctrl+C），調(diào)用Shutdown()方法，停止接收新請(qǐng)求并等待現(xiàn)有請(qǐng)求處理完。

優(yōu)雅重啟就像保安換班，使用endless庫(kù)監(jiān)聽(tīng)特定信號(hào)（如SIGHUP），啟動(dòng)新進(jìn)程處理新請(qǐng)求，同時(shí)讓老進(jìn)程處理完現(xiàn)有請(qǐng)求再退出。

在實(shí)際項(xiàng)目中，根據(jù)需求選擇：需要安全關(guān)閉服務(wù)就用優(yōu)雅關(guān)機(jī)；需要更新代碼且不影響現(xiàn)網(wǎng)運(yùn)行就用優(yōu)雅重啟。

到此這篇關(guān)于Go語(yǔ)言實(shí)現(xiàn)優(yōu)雅關(guān)機(jī)和重啟的示例詳解的文章就介紹到這了,更多相關(guān)Go語(yǔ)言?xún)?yōu)雅關(guān)機(jī)和重啟內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論