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)
<p><!-- 启动 HTTP server -->
server := &http.Server{Addr: ":8080", Handler: mux}
go func() {
if err := server.ListenAndServe(); err != http.ErrServerClosed {
log.Fatal(err)
}
}()</p><p><!-- 等待信号 -->
<-sigChan
log.Println("received shutdown signal")</p><p><!-- 开始优雅关闭：先停止接收新连接 -->
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
defer cancel()</p><p>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:
}
<pre class='brush:php;toolbar:false;'>// 使用 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
}}
如何协调多个 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。
