zk.Connect() 是异步连接方法，立即返回不代表 ZooKeeper 会话已建立；必须监听会话事件通道，等待 StateConnected 状态到达，才能安全执行创建 znode 等操作。
go-zookeeper 连接后需监听会话事件确认连接就绪
在使用 github.com/samuel/go-zookeeper 客户端进行服务发现或分布式协调开发时，一个常见误区是认为 zk.Connect() 返回即代表已建立可用的 ZooKeeper 连接。实际上，该函数仅启动连接流程并立即返回一个未就绪的连接对象和一个事件通道（），真正的会话建立（包括 SASL 认证、会话恢复、leader 选举同步等）是异步完成的。若在此时直接调用 <code>zooKeeper.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.StateDisconnected ||
event.State == zk.StateExpired {
log.Printf("❌ ZooKeeper connection failed or expired: %v", 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("timeout waiting for ZooKeeper connection to become ready")
}
}? 关键注意事项：
- 不要忽略
eventChan—— 它是客户端与 ZooKeeper 会话生命周期的唯一通知机制； - 始终设置超时（如上例中的
time.After），防止因网络异常或 ZooKeeper 不可达导致 goroutine 永久挂起； -
zk.StateConnected是唯一表示“可安全执行读写操作”的状态；zk.StateConnecting、zk.StateAuthFailed等均为中间或错误状态； - 生产环境建议配合重试机制（如指数退避）与健康检查，而非单次连接即退出；
- 连接成功后，应妥善管理
*zk.Conn生命周期，在应用退出前调用conn.Close()释放会话。
通过上述方式，你不仅能确保连接真正就绪，还能获得清晰的状态反馈与错误处理路径，为构建高可用的服务发现系统打下坚实基础。
