本文记录自己在工作中排查etcd应用分布式锁而导致的泄露与死锁问题，并通过分析源码找到根因，最终解决。
服务出现数据入库失败，且伴随内存持续增长。关键现象：
etcdctl get --prefix /my-lock/可看到锁KEY长期存在etcdctl lease timetolive显示租约TTL不断重置pprof观测）func main() {
// ... etcd client初始化代码不变...
// 关键问题点1：缺失session关闭
session, _ := concurrency.NewSession(cli)
// defer session.Close() // 故意注释导致协程泄漏
// 关键问题点2：未释放锁
mutex := concurrency.NewMutex(session, "/my-lock/")
ctx, _ := context.WithTimeout(context.Background(), 5*time.Second)
_ = mutex.Lock(ctx)
// ...业务逻辑代码...
// 关键问题点3：阻止程序退出（仅用于demo）
select {}
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
+--------------+ 定期续约 +------+
| Go routine |----------------->| etcd |
+--------------+ (KeepAlive) +------+
▲
│ 未调用Close()
└──────+
|
+---------------------------+
| session.Close() 核心作用：|
| 1. 停止续约协程 |
| 2. 释放租约 |
+---------------------------+
1
2
3
4
5
6
7
8
9
10
11
12
协程泄漏路径： NewSession() → go keepAlive协程 → client.KeepAlive() → 后台协程续约(sendKeepAliveLoop)
资源释放路径： session.Close() → Orphan() → 关闭上下文 → 触发keepAlive协程退出
在创建session后，确保调用Close()方法，及时释放资源。
func main() {
// ...初始化代码不变...
session, err := concurrency.NewSession(cli)
if err != nil {
log.Fatal(err)
}
defer session.Close() // 新增关键修复
mutex := concurrency.NewMutex(session, "/my-lock/")
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel() // 确保上下文取消
if err := mutex.Lock(ctx); err != nil {
log.Fatal(err)
}
defer mutex.Unlock(context.TODO()) // 双保险释放锁
// ...业务逻辑...
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。