etcd Watcher 在节点故障时可能向监听 channel 发送 nil 值或关闭 channel，若未做空值与关闭状态检查，直接访问 r.Node 将触发 nil pointer dereference panic。本文详解正确处理方式及健壮实现模式。
etcd watcher 在节点故障时可能向监听 channel 发送 nil 值或关闭 channel，若未做空值与关闭状态检查，直接访问 `r.node` 将触发 nil pointer dereference panic。本文详解正确处理方式及健壮实现模式。
在使用 github.com/coreos/go-etcd/etcd（注意：该库已归档废弃，仅适用于旧版 etcd v2）进行键值监听时，client.Watch() 启动的 goroutine 可能在连接中断、节点下线或重试失败后主动关闭传入的 watchChan，甚至在某些错误路径中向 channel 发送 nil *etcd.Response。原代码中直接执行
r := >> got an updated config: %s: %s\n", r.Node.Key, r.Node.Value) // panic if r == nil!
✅ 正确做法是：同时检查 channel 是否已关闭，以及接收到的响应是否为 nil。以下是修复后的完整示例（兼容原库语义）：
package main
import (
"log"
"time"
"github.com/coreos/go-etcd/etcd"
)
func main() {
client := etcd.NewClient([]string{
"http://172.20.20.10:2379",
"http://172.20.20.11:2379",
"http://172.20.20.12:2379",
})
for {
watchChan := make(chan *etcd.Response, 1) // 建议设置缓冲，避免阻塞 watcher goroutine
go client.Watch("/config", 0, false, watchChan, nil)
log.Println("Waiting for an update...")
r, open := >> got an updated config: %s = %s", r.Node.Key, r.Node.Value)
} else {
log.Println("Watch event received but Node is nil — ignoring")
}
}
}
⚠️ 重要注意事项：
- github.com/coreos/go-etcd/etcd 已于 2018 年归档，不再维护，且仅支持 etcd v2 API。生产环境请务必迁移到官方推荐的 go.etcd.io/etcd/client/v3，它提供基于 gRPC 的强健 Watch 机制（自动重连、上下文控制、事件流式处理）。
- 原始代码中每次循环都新建 channel 并启新 goroutine，存在 goroutine 泄漏风险；实际应用中应复用 client、管理 watcher 生命周期，或改用 client.Watcher 接口配合 Next() 轮询。
- Watch() 的 recursive 参数为 false 时仅监听单 key；如需监听子路径，请设为 true 并确保 etcd server 支持。
? 总结：任何从 channel 接收指针类型值的 Go 代码，都应默认执行 nil 检查；对 etcd Watcher 这类外部服务交互逻辑，还需结合 channel 关闭状态判断，才能构建真正健壮的配置监听服务。
