Goroutine泄漏：隐蔽却致命的 Go性能杀手

mrkong

在 Go 语言的世界里，goroutine 是最亮眼的特性之一。轻量级、高并发、成本低——这几乎成了 Go 成为云原生时代“标配语言”的最大资本。
但与此同时，goroutine 泄漏（Goroutine Leak） 也在悄无声息中埋下隐患，它往往不易被察觉，却能在关键时刻将系统拖入崩溃的深渊。

今天，我们就从原理、案例、排查、预防等几个角度，深挖这一“隐蔽却致命”的性能杀手。

一、什么是 Goroutine 泄漏？

简单来说，goroutine 泄漏就是指那些已经不再需要，却依旧存活在内存中的 goroutine。它们通常因为阻塞或缺乏退出机制，无法被回收，最终像僵尸一样堆积。

特点：

• 隐蔽性强：不会像语法错误一样报红；
• 累积效应：少量泄漏看不出问题，但成百上千的僵尸 goroutine 会吃掉内存和 CPU；
• 致命性高：严重时可能导致 OOM、系统卡死、服务雪崩。
  
  

二、常见的 Goroutine 泄漏场景

• Channel 阻塞未关闭
  
  

1. func worker(ch <-chan int) {
   
2.     for v := range ch {
   
3.         fmt.Println(v)
   
4.     }
   
5. }
   
6. 
   
7. func main() {
   
8.     ch := make(chan int)
   
9.     go worker(ch)
   
10.     // 忘记 close(ch)，worker 一直阻塞
    
11. }
    

复制代码

没有关闭 channel，goroutine 永远等数据。
  2. select 中缺少退出分支

1. func doWork(ch <-chan int) {
   
2.     for {
   
3.         select {
   
4.         case v := <-ch:
   
5.             fmt.Println(v)
   
6.         // 没有退出条件
   
7.         }
   
8.     }
   
9. }
   

复制代码

goroutine 永远活着。

3. context 没有传递 / 取消

1. func fetch(ctx context.Context, url string) {
   
2.     req, _ := http.NewRequest("GET", url, nil)
   
3.     // 没有用 ctx 绑定请求，超时无法中断
   
4.     http.DefaultClient.Do(req)
   
5. }
   

复制代码

网络抖动时，goroutine 卡死在等待。

4. timer / ticker 忘记 stop

1. func main() {
   
2.     ticker := time.NewTicker(time.Second)
   
3.     go func() {
   
4.         for range ticker.C {
   
5.             fmt.Println("tick")
   
6.         }
   
7.     }()
   
8.     // ticker 没有 stop，goroutine 永远运行
   
9. }

复制代码

三、真实事故案例

在某大型金融 SaaS 平台的支付服务中，研发团队发现服务每周都会出现一次 内存飙升。经过排查，原因是：

• 每个支付请求会启动一个 goroutine 监听第三方支付回调；
• 但部分失败场景下，goroutine 并没有退出；
• 长期积累，导致数十万 goroutine 堆积。
  
  

结果：

• 内存占用飙升 8 倍；
• 部分节点 CPU 飙到 100%；
• 最终触发自动扩容，成本翻倍。
  
  

修复措施仅仅是：用 context.WithTimeout 控制 goroutine 生命周期，并确保退出路径。

四、如何排查 Goroutine 泄漏？

• pprof 工具
  
  

1. go tool pprof http://localhost:6060/debug/pprof/goroutine
   

复制代码

2. 运行时采样

1. import "runtime"
   
2. 
   
3. fmt.Println("当前 goroutine 数量:", runtime.NumGoroutine())
   

复制代码

3. goleak 库

1. import "go.uber.org/goleak"
   
2. 
   
3. func TestMain(m *testing.M) {
   
4.     goleak.VerifyTestMain(m)
   
5. }
   

复制代码

在单元测试中自动检测是否存在泄漏。

五、预防 Goroutine 泄漏的最佳实践

使用 context 管理生命周期

• context.WithCancel / context.WithTimeout
• 任何 goroutine 都应该有退出条件。
  
  

始终关闭 channel

• 在生产者端负责 close。
  
  

select 中增加退出分支

1. select {
   
2. case <-ctx.Done():
   
3.     return
   
4. }

复制代码

及时 stop timer / ticker

• 用 defer ticker.Stop() 收尾。
  
  

CI 中引入 goleak

• 把泄漏检测纳入测试流程。