Zookeeper 客户端开发指南：Java API 调用与常见问题解决

一、环境准备

1. Maven依赖
   在pom.xml中添加最新客户端库：

   <dependency>
       <groupId>org.apache.zookeeper</groupId>
       <artifactId>zookeeper</artifactId>
       <version>3.8.0</version>
   </dependency>
   

2. 连接字符串配置
   标准格式：host1:port1,host2:port2/chrootPath

二、核心 API 调用

import org.apache.zookeeper.*;

public class ZkClient implements Watcher {
    private static ZooKeeper zk;
    
    // 1. 建立连接
    public void connect(String hosts) throws IOException {
        zk = new ZooKeeper(hosts, 3000, this); // 会话超时3秒
        System.out.println("连接状态: " + zk.getState());
    }

    // 2. 创建节点
    public void createNode(String path, byte[] data) throws KeeperException, InterruptedException {
        zk.create(path, data, ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    }

    // 3. 读取数据
    public byte[] getData(String path) throws KeeperException, InterruptedException {
        return zk.getData(path, false, null);
    }

    // 4. 监听节点变化
    @Override
    public void process(WatchedEvent event) {
        if (event.getType() == Event.EventType.NodeDataChanged) {
            System.out.println("节点数据已更新: " + event.getPath());
        }
    }
}

三、关键操作详解

1. 节点创建模式

   • CreateMode.PERSISTENT：持久节点
   • CreateMode.EPHEMERAL：临时节点（会话结束自动删除）
   • CreateMode.SEQUENTIAL：顺序节点（自动追加序号）

2. ACL权限控制

   List<ACL> acl = new ArrayList<>();
   acl.add(new ACL(ZooDefs.Perms.ALL, new Id("ip", "192.168.1.1")));
   zk.create("/secureNode", null, acl, CreateMode.PERSISTENT);
   

3. 异步操作示例

   zk.getData("/asyncNode", false, (rc, path, ctx, data, stat) -> {
       System.out.println("异步回调数据: " + new String(data));
   }, null);
   

四、常见问题解决方案

Stat stat = zk.exists(path, false);
zk.setData(path, data, stat.getVersion());

五、最佳实践

1. 连接管理

   • 复用ZooKeeper实例（避免频繁创建）
   • 实现ConnectionStateListener处理会话过期

2. 性能优化

   • 批量操作使用MultiTransaction
   • 临时节点数量控制在1万以内

3. 异常处理框架

   try {
       // ZK操作代码
   } catch (KeeperException e) {
       if (e.code() == KeeperException.Code.SESSIONEXPIRED) {
           // 会话过期处理
       }
   } catch (InterruptedException e) {
       Thread.currentThread().interrupt();
   }
   

重要提示：生产环境建议使用CuratorFramework（Apache高级客户端），封装了重试机制、分布式锁等高级特性。