下面将介绍怎样使用 Java 直接操作 Zookeeper，具体步骤如下：
（1）添加 Maven 依赖
（2）使用 Zookeeper API 操作节点
使用 IDEA 创建一个 Maven 项目，在 pom.xml 中添加如下依赖：
<dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.13</version> </dependency>
下面是 Java 代码，后续章节将详细介绍各个 API 的作用，这里仅仅演示如何通过 API 简单操作 zookeeper。代码如下：
package com.hxstrive.zookeeper;
import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;
/**
* 第一个 Zookeeper 示例
* @author hxstrive.com
*/
public class ZookeeperSimple {
public static void main(String[] args) throws Exception {
// 1.创建 zookeeper 连接
ZooKeeper zooKeeper = new ZooKeeper("127.0.0.1:2181", 2000, new Watcher() {
public void process(WatchedEvent watchedEvent) {
System.out.println("触发了 " + watchedEvent.getType() + " 事件");
}
});
// 2.创建节点
String path = zooKeeper.create("/hello", "hello world".getBytes(),
ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println("节点路径：" + path);
// 3.获取节点的值
byte[] bytes = zooKeeper.getData("/hello", false, new Stat());
System.out.println(new String(bytes));
}
}运行示例，输出如下：
触发了 None 事件 节点路径：/hello hello world
查看 zookeeper 节点信息，如下图：
川公网安备51010802032098