zk.Connect() 是异步连接，立即返回不代表 ZooKeeper 会话已就绪；必须监听会话事件通道，等待 StateConnected 状态到达，才能安全执行创建 znode 等操作。
go-zookeeper 连接后需监听会话事件确认实际连接状态
在使用 [`github.com/samuel/go-zookeeper`](https://github.com/samuel/go-zookeeper) 库时，`zk.Connect()` 方法设计为**非阻塞、异步初始化**：它会立即返回一个 `*zk.Conn` 实例和一个 `chan zk.Event`（会话事件通道），但此时 ZooKeeper 客户端可能尚未完成 TCP 握手、会话建立或 SASL 认证（如启用）。若在此刻调用 `zoo_keeper.Create()` 等操作，极大概率触发 `zk.ErrNoNode`、`zk.ErrConnectionClosed` 或静默失败——因为底层连接尚未真正就绪。✅ 正确做法是：阻塞等待会话事件流中出现 zk.StateConnected，该事件标志着客户端已成功建立有效会话、可安全发起请求。
以下是一个健壮的连接封装函数示例：
import (
"log"
"time"
"github.com/samuel/go-zookeeper/zk"
)
func zkConnect(zkServer string, timeout time.Duration) (*zk.Conn, error) {
conn, eventChan, err := zk.Connect([]string{zkServer}, timeout)
if err != nil {
return nil, err
}
// 设置超时控制，避免永久阻塞
done := make(chan struct{})
go func() {
for event := range eventChan {
if event.State == zk.StateConnected {
log.Printf("ZooKeeper connected successfully: %s", event.Path)
close(done)
return
}
if event.State == zk.StateExpired || event.State == zk.StateDisconnected {
log.Printf("ZooKeeper connection failed or expired: %v", event)
close(done)
return
}
}
}()
select {
case <-done:
return conn, nil
case <-time.After(timeout * 2): // 双倍超时兜底
conn.Close()
return nil, fmt.Errorf("failed to establish ZooKeeper connection within timeout")
}
}⚠️ 关键注意事项：
-
永不忽略
eventChan：即使你只关心首次连接，也必须消费该 channel，否则 goroutine 泄漏且后续事件无法接收； -
务必设置超时：网络不可达、ZooKeeper 服务宕机等情况会导致
eventChan永不发出StateConnected，需主动中断； -
连接失败需显式关闭：若超时或收到
StateExpired，应调用conn.Close()释放资源； -
重连逻辑需自行实现：
go-zookeeper不自动重连，生产环境建议结合zk.Event中的StateDisconnected/StateConnecting实现指数退避重连。
? 小结：zk.Connect() 返回的是“连接尝试已启动”，而非“连接已就绪”。真正的连接就绪信号始终来自 eventChan —— 这是 Go-Zookeeper 的核心设计契约，也是编写可靠服务发现组件的前提。
