热重启golang服务器(graceful restart golang http server)

原文：热重启golang服务器(graceful restart golang http server)

服务端代码经常需要升级，对于线上系统的升级常用的做法是，通过前端的负载均衡（如nginx）来保证升级时至少有一个服务可用，依次（灰度）升级。
而另一种更方便的方法是在应用上做热重启，直接升级应用而不停服务。

原理

热重启的原理非常简单，但是涉及到一些系统调用以及父子进程之间文件句柄的传递等等细节比较多。
处理过程分为以下几个步骤：
监听信号（USR2）

收到信号时fork子进程（使用相同的启动命令），将服务监听的socket文件描述符传递给子进程
子进程监听父进程的socket，这个时候父进程和子进程都可以接收请求
子进程启动成功之后，父进程停止接收新的连接，等待旧连接处理完成（或超时）
父进程退出，升级完成

细节

父进程将socket文件描述符传递给子进程可以通过命令行，或者环境变量等
子进程启动时使用和父进程一样的命令行，对于golang来说用更新的可执行程序覆盖旧程序
server.Shutdown()优雅关闭方法是go1.8的新特性
server.Serve(l)方法在Shutdown时立即返回，Shutdown方法则阻塞至context完成，所以Shutdown的方法要写在主goroutine中

代码

代码部分加了些注释

package mainimport ("context""errors""flag""log""net""net/http""os""os/exec""os/signal""syscall""time"
)var (server   *http.Serverlistener net.Listenergraceful = flag.Bool("graceful", false, "listen on fd open 3 (internal use only)")
)func handler(w http.ResponseWriter, r *http.Request) {time.Sleep(3 * time.Second)w.Write([]byte("hello world233333--!!!!"))
}func main() {flag.Parse()http.HandleFunc("/hello", handler)server = &http.Server{Addr: ":9999"}var err errorif *graceful {log.Print("main: Listening to existing file descriptor 3.")// cmd.ExtraFiles: If non-nil, entry i becomes file descriptor 3+i.// when we put socket FD at the first entry, it will always be 3(0+3)// 在linux中，值为0、1、2的fd，分别代表标准输入、标准输出、标准错误输出，因为 0 1 2已经被linux使用了// 返回具有给定文件描述符和名称的新文件。如果fd不是有效的文件描述符，则返回值为nil。// 3是什么？3其实就是从父进程继承过来的socket fd。虽然子进程可以默认继承父进程绝大多数的文件描述符（除了文件锁之类的），但是golang的标准库os/exec只默认继承stdin stdout stderr这三个。// 需要让子进程继承的fd需要在fork之前手动放到ExtraFiles中。由于有了stdin 0 stdout 1 stderr 2，因此其它fd的序号从3开始。f := os.NewFile(3, "")listener, err = net.FileListener(f) //返回与打开的文件f对应的网络侦听器的副本。log.Printf("ln:addr=%v", listener.Addr().String())// f.Close() 是干什么的，Close它会有什么影响。这个问题直接的答案是，没有任何影响，只是为了防止资源泄漏。f.Close()// 在测试发现，在kill -USR2原有的服务结束时，才会响应新打开的服务} else {log.Print("main: Listening on a new file descriptor.")listener, err = net.Listen("tcp", server.Addr)}if err != nil {log.Fatalf("listener error: %v", err)}go func() {// server.Shutdown() stops Serve() immediately, thus server.Serve() should not be in main goroutineerr = server.Serve(listener)log.Printf("server.Serve err: %v\n", err)}()signalHandler()log.Printf("signal end")
}func reload() error {tl, ok := listener.(*net.TCPListener)if !ok {return errors.New("listener is not tcp listener")}f, err := tl.File()if err != nil {return err}args := []string{"-graceful"}cmd := exec.Command(os.Args[0], args...)log.Printf("os.args[0]:%s\n", os.Args[0]) //可执行文件名cmd.Stdout = os.Stdoutcmd.Stderr = os.Stderr// put socket FD at the first entrycmd.ExtraFiles = []*os.File{f}return cmd.Start()
}func signalHandler() {ch := make(chan os.Signal, 1)signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM, syscall.SIGUSR2)for {sig := <-chlog.Printf("signal: %v", sig)// timeout context for shutdownctx, _ := context.WithTimeout(context.Background(), 20*time.Second)switch sig {case syscall.SIGINT, syscall.SIGTERM:// stoplog.Printf("stop")signal.Stop(ch)server.Shutdown(ctx)log.Printf("graceful shutdown")returncase syscall.SIGUSR2:// reloadlog.Printf("reload")err := reload()if err != nil {log.Fatalf("graceful restart error: %v", err)}server.Shutdown(ctx)log.Printf("graceful reload")return}}
}

% go build main.go
% ./main
% kill -USR2 77458  #热重启

os.NewFile(3, “”) 为什么是3，可以参考这篇文章Golang的Graceful Restart

systemd & supervisor

父进程退出之后，子进程会挂到1号进程上面。这种情况下使用systemd和supervisord等管理程序会显示进程处于failed的状态。解决这个问题有两个方法：

使用pidfile，每次进程重启更新一下pidfile，让进程管理者通过这个文件感知到mainpid的变更。
起一个master来管理服务进程，每次热重启master拉起一个新的进程，把旧的kill掉。这时master的pid没有变化，对于进程管理者来说进程处于正常的状态。一个简洁的实现

References

graceful
Graceful Restart in Golang
facebookgo/grace
endless
overseer

热重启golang服务器(graceful restart golang http server)相关推荐

linux环境搭建golang服务器,Linux下golang环境搭建-Go语言中文社区
1.首先从使用wget https://storage.googleapis.com/golang/go1.12.linux-amd64.tar.gz命令下载安装包,可以根据自己的需要选择版本. 2. ...
golang iris web项目热重启
在开发web的时候,如果项目不支持热重启,每添加或修改个接口都需要重启项目才能测试,会很麻烦.都知道beego有bee工具,bee run启动项目即可,而在iris项目中热重启方法如下 # 安装riz ...
golang 系统级服务器,golang 服务器监控
golang 服务器监控内容精选换一换本节定义了云耀云服务器上报云监控的监控指标的命名空间,监控指标列表,各项监控指标的具体含义与使用说明,用户可以通过云监控检索云耀云服务器服务产生的监控指标和 ...
oracle tlv,OSPF GR(Graceful Restart，平滑重启)技术
概述 GR(Graceful Restart,平滑重启)是一种在主备切换或协议重启时保证转发业务不中断的机制.其核心在于:设备进行协议重启时,能够通知其周边设备,使到该设备的邻居关系和路由在一定时间 ...
[golang Web开发] 1.golang web开发:简介以及web服务器的搭建以及http协议简介
一.web开发简介 1.简介 Web应用在我们的生活中无处不在,看看我们日常使用的各个应用程序,它们要么是 Web应用,要么是移动 App 这类 web应用的变种,无论哪一种编程语言,只要它能够开发出 ...
golang服务器代理
golang服务器代理 go env -w GOPROXY=https://goproxy.cn,direct
Go 如何实现热重启
作者:zhijiezhang,腾讯 PCG 后台开发工程师最近在优化公司框架 trpc 时发现了一个热重启相关的问题,优化之余也总结沉淀下,对 go 如何实现热重启这方面的内容做一个简单的梳理. 1 ...
【博客567】http/2 goaway frame 与 grpc graceful restart
http2 goway frame 与 grpc graceful restart 1.http/2 HTTP/2新增特性二进制分帧(HTTP Frames) 多路复用头部压缩服务端推送(ser ...
Golang指南：顶级Golang框架、IDE和工具列表
Golang指南:顶级Golang框架.IDE和工具列表 https://www.itcodemonkey.com/article/1053.html 2017-10-30 17:21:58 分类:人 ...
【Flutter】Flutter 混合开发 ( 混合开发中 Flutter 的热重启 / 热加载 )
文章目录前言一.混合开发中启用 Flutter 的热重启 / 热加载二.混合开发中 Flutter 的热重启 / 热加载命令测试三.指定混合应用连接的设备四.相关资源前言上一篇博客 ...

热重启golang服务器(graceful restart golang http server)

原理

细节

代码

systemd & supervisor

References

热重启golang服务器(graceful restart golang http server)相关推荐

最新文章

热门文章