Go服务需显式监听SIGTERM并优雅关闭:用signal.Notify捕获信号,context.WithTimeout控制缓冲期,server.Shutdown停止接收新连接并等待请求完成;HTTP handler必须响应req.Context().Done(),对阻塞操作使用带context版本。

Go 服务如何响应系统 SIGTERM 信号
Go 程序默认不处理 SIGTERM,收到后直接退出,导致正在处理的 HTTP 请求被中断、gRPC 流未关闭、数据库事务未提交等问题。必须显式监听并延迟退出。
核心是用 signal.Notify 捕获信号,配合 context.WithTimeout 给出缓冲窗口:
sigChan := make(chan os.Signal, 1) signal.Notify(sigChan, syscall.SIGTERM, syscall.SIGINT)server := &http.Server{Addr: ":8080", Handler: mux} go func() { if err := server.ListenAndServe(); err != http.ErrServerClosed { log.Fatal(err) } }()
<-sigChan log.Println("received shutdown signal")
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second) defer cancel()
if err := server.Shutdown(ctx); err != nil { log.Printf("server shutdown error: %v", err) } log.Println("server gracefully stopped")
注意:server.Shutdown 不会主动 kill 正在运行的 handler,它只关闭 listener 并等待已有请求完成(或超时)。所以 handler 内部也需支持上下文取消。
HTTP handler 中如何感知服务即将下线
仅靠 server.Shutdown 不够——如果某个 handler 正在执行耗时操作(如调用第三方 API、写入大文件),它可能拖过整个超时时间,导致强制 kill。必须让 handler 主动响应 ctx.Done()。
立即学习“go语言免费学习笔记(深入)”;
常见错误写法:http.HandleFunc("/api/upload", uploadHandler),但 uploadHandler 未检查 req.Context().Done()。
正确做法:
- 所有 handler 必须接收并传递
req.Context() - 对阻塞操作(如
io.Copy、db.QueryRowContext、http.DefaultClient.Do)使用带 context 的版本 - 自定义长循环需定期检查
select { case
示例:
func uploadHandler(w http.ResponseWriter, r *http.Request) {
ctx := r.Context()
// 上传前检查是否已取消
select {
case <-ctx.Done():
http.Error(w, "request cancelled", http.StatusServiceUnavailable)
return
default:
}
// 使用 Context-aware 的 io.Copy
_, err := io.CopyContext(ctx, dst, r.Body)
if err != nil {
if errors.Is(err, context.Canceled) || errors.Is(err, context.DeadlineExceeded) {
log.Println("upload cancelled due to shutdown")
return
}
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}}
白月生产企业订单管理系统GBK2.0 Build 080807
请注意以下说明:1、本程序允许任何人免费使用。2、本程序采用PHP+MYSQL架构编写。并且经过ZEND加密,所以运行环境需要有ZEND引擎支持。3、需要售后服务的,请与本作者联系,联系方式见下方。4、本程序还可以与您的网站想整合,可以实现用户在线服务功能,可以让客户管理自己的信息,可以查询自己的订单状况。以及返点信息等相关客户利益的信息。这个功能可提高客户的向心度。安装方法:1、解压本系统,放在
下载
如何协调多个 goroutine 同时下线(如定时任务、后台 worker)
服务常含非 HTTP 组件:定时器(time.Ticker)、消息消费者(Kafka consumer)、连接池维护协程等。它们不会因 server.Shutdown 自动停止,必须统一接入 shutdown 流程。
推荐方案:全局 sync.WaitGroup + 共享 context.Context:
- 启动时用
wg.Add(1)和go runWorker(ctx, &wg) - worker 内部用
select监听ctx.Done()或业务事件 -
server.Shutdown后,调用wg.Wait()等待所有 worker 退出
关键点:worker 必须在退出前调用 wg.Done(),且不能遗漏任何 goroutine。
反例:用 for range chan 但未在 ctx.Done() 触发时 break,会导致 goroutine 泄漏。
为什么 os.Exit(0) 不能放在 Shutdown 之后直接调用
很多人在 server.Shutdown(ctx) 后立刻写 os.Exit(0),这是危险的——它会跳过 defer、忽略仍在运行的 goroutine、绕过资源清理逻辑(如关闭数据库连接、释放锁、flush 日志 buffer)。
正确顺序是:
- 停止 listener(
server.Shutdown) - 关闭数据库连接池(
db.Close()) - 关闭消息客户端(
kafkaConsumer.Close()) - 等待所有后台 goroutine 结束(
wg.Wait()) - 最后才
os.Exit(0)或自然返回 main 函数
最容易被忽略的是:第三方 SDK 的 Close() 方法往往有内部 goroutine,必须显式调用且等待其完成;不查文档就假设“调了 Close 就安全”,大概率留下残留连接或 panic。









