美文网首页Golang和微服务程序员
使用 Go 1.16 的 signal.NotifyContex

使用 Go 1.16 的 signal.NotifyContex

作者: Muninn | 来源:发表于2021-04-09 17:29 被阅读0次

    在 Go 1.16 的更新中,signal包增加了一个函数 NotifyContext
    这让我们优雅的重启服务(Graceful Restart)可以写的更加优雅。

    一个服务想要优雅的重启主要包含两个方面:

    • 退出的旧服务需要 Graceful Shutdown,不强制杀进程,不泄漏系统资源。
    • 在一个集群内轮流重启服务实例,保证服务不中断。

    第二个问题跟部署方式相关,改天专门写一篇讨论,今天我们主要谈怎么样优雅的退出。

    首先在代码里,用了外部资源,一定要使用defer去调用Close()方法关闭。
    然后我们就要拦截系统的中断信号,保证程序收到中断信号之后,主动有序退出,这样所有的 defer 才会被执行。

    在以前,大概是这么写:

    func everLoop(ctx context.Context) {
    LOOP:
        for {
            select {
            case <-ctx.Done():
                // 收到信号退出无限循环
                break LOOP
            default:
                // 用一个 sleep 模拟业务逻辑
                time.Sleep(time.Second * 10)
            }
        }
    }
    
    func main() {
        // 建立一个可以手动取消的 Context
        ctx, cancel := context.WithCancel(context.Background())
    
        // 监控系统信号,这里只监控了 SIGINT(Ctrl+c),SIGTERM
        // 在 systemd 和 docker 中,都是先发 SIGTERM,过一段时间没退出再发 SIGKILL
        // 所以这里没捕获 SIGKILL
        sig := make(chan os.Signal, 1)
        signal.Notify(sig, syscall.SIGINT, syscall.SIGTERM)
        go func() {
            <-sig
            cancel()
        }()
    
        // 开始无限循环,收到信号就会退出
        everLoop(ctx)
        fmt.Println("graceful shuwdown")
    }
    
    

    现在有了新的函数,这一段变得更简单了:

    func main() {
        // 监控系统信号和创建 Context 现在一步搞定
        ctx, stop := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)
        // 在收到信号的时候,会自动触发 ctx 的 Done ,这个 stop 是不再捕获注册的信号的意思,算是一种释放资源。
        defer stop()
    
        // 开始无限循环,收到信号就会退出
        everLoop(ctx)
        fmt.Println("graceful shuwdown")
    }
    
    

    感谢 Golang ,当年用别的语言需要写一大堆代码的功能,现在几行就可以轻松实现了。
    让它成为你服务程序的标配吧。

    最后,我是写最新的项目LetServerRun的时候,发现这种最新的写法的。
    LetServerRun 可以让你把微信公众号当作随身的 Terminal 控制你的服务端。
    在它的 Agent 的 main 函数中就有上述用法的示例,
    欢迎参考。

    相关文章

      网友评论

        本文标题:使用 Go 1.16 的 signal.NotifyContex

        本文链接:https://www.haomeiwen.com/subject/dmhwkltx.html