zk.Connect() 是异步连接，立即返回不代表 ZooKeeper 会话已建立；必须监听会话事件通道，确认收到 StateConnected 状态后，方可执行创建 znode 等操作。
go-zookeeper 连接后需等待会话就绪才能安全操作
在使用 github.com/samuel/go-zookeeper 客户端进行服务发现或分布式协调开发时，一个常见误区是误以为 zk.Connect() 的返回即代表 ZooKeeper 连接已就绪。实际上，该函数仅启动连接流程并立即返回一个 *zk.Conn 和一个事件通道 ，底层 TCP 握手、会话协商与 watcher 注册仍在后台进行——此时若直接调用 <code>Create()、Get() 等操作，极可能触发 zk.ErrNoConnection 或超时失败。
正确的做法是主动等待会话进入 zk.StateConnected 状态。zk.Connect() 返回的 session 通道会持续推送连接状态变更事件（如 StateConnecting → StateConnected → StateExpired），我们应在获取连接后阻塞监听该通道，直到收到 StateConnected 事件再继续后续逻辑：
func zkConnect(zkServer string, timeout time.Duration) (*zk.Conn, error) {
conn, session, err := zk.Connect([]string{zkServer}, timeout)
if err != nil {
return nil, fmt.Errorf("failed to initiate ZooKeeper connection: %w", err)
}
// 设置超时保护，避免永久阻塞
done := make(chan struct{})
go func() {
for event := range session {
if event.State == zk.StateConnected {
log.Printf("ZooKeeper connected successfully (session ID: 0x%x)", event.SessionID)
close(done)
return
}
if event.State == zk.StateDisconnected || event.State == zk.StateExpired {
log.Printf("ZooKeeper session failed: %s", event.State)
close(done)
return
}
}
}()
select {
case <-done:
return conn, nil
case <-time.After(timeout * 2): // 建议设为 Connect timeout 的 2 倍
conn.Close()
return nil, fmt.Errorf("timed out waiting for ZooKeeper connection")
}
}⚠️ 关键注意事项：
-
永不忽略会话事件通道：即使连接成功，也应长期监听
session通道以响应断连、会话过期等异常（建议在独立 goroutine 中处理）； - 显式设置超时：原始示例中无超时机制，生产环境必须添加，防止因网络问题导致服务启动卡死；
-
连接复用优于频繁重建：
*zk.Conn是线程安全且可复用的，应作为全局单例或依赖注入管理，而非每次操作都重新连接； -
检查返回值与错误语义：
zk.Create()等方法在未连接时通常返回zk.ErrNoConnection，但依赖运行时错误不如前置状态校验可靠。
综上，ZooKeeper 的 Go 客户端遵循“连接即启动、就绪需等待”的异步模型。将连接初始化与状态就绪解耦，是构建健壮分布式服务发现系统的第一道防线。
