导入maven依赖：

<dependencies> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>RELEASE</version> </dependency> <dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-core</artifactId> <version>2.8.2</version>
</dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.5.7</version> </dependency> 
</dependencies>

创建日志文件：

需要在项目的 src/main/resources 目录下，新建一个文件，命名为“log4j.properties”

log4j.rootLogger=INFO, stdout 
log4j.appender.stdout=org.apache.log4j.ConsoleAppender 
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout 
log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] 
- %m%n 
log4j.appender.logfile=org.apache.log4j.FileAppender 
log4j.appender.logfile.File=target/spring.log 
log4j.appender.logfile.layout=org.apache.log4j.PatternLayout 
log4j.appender.logfile.layout.ConversionPattern=%d %p [%c] 
- %m%n

创建API客户端：

（1）创建全局变量：

  String connectString="hadoop102:2181,hadoop103:2181,hadoop104:2181";int sessionTimeout=2000;ZooKeeper zkClient=null;

String connectString---要连接那个zookeeper,
int sessionTimeout ---延迟时间
ZooKeeper zkClient ---表示要创建的客户端  申请为全局变量有助于后边各方法的调用

（2）初始化（init）:

  @Before
public void init() throws Exception {// Watcher watcher ---监听器zkClient= new ZooKeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent watchedEvent) {List<String> children = null;System.out.println("-------------------------------");try {children = zkClient.getChildren("/", true);} catch (KeeperException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}for (String child : children) {System.out.println(child);}}});
}

@Befor注解在此不在解释不会可看本人前面文章（Java注解篇）

首先初始化了一个zookeeper的客户端对象

重写了process方法，这个方法在不使用监听器的时候可以不写代码

在开启监听器的时候（可以听后续监听器API）

由于监听器是调用一次只能使用一次，不能实时监听，所以我们要在初始化方法里添加监听逻辑（process方法），就会在每次所监听的数据发生改变的时候调用该方法，我们在创建客户端对象的时候为该对象设置了监听器，从而在删除的时候也会触发监听

（3）创建节点（create）:

@Test
public void create() throws Exception {//String path,---在那个节点下创建节点// byte[] data, ----节点数据// List<ACL> acl,----权限// CreateMode createMode)----创建节点的类型String nodecreate = zkClient.create("/atguigu","tangxiaocong".getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
}

（4）监听API：

@Testpublic void getChildren() throws Exception {//String path----监听路径, boolean watch---设置监听器为true//true注册一次监听（记不起来就去看监听原理）就只能生效一次，所以在init哪里就需要添加注册List<String> children = zkClient.getChildren("/", true);for (String child : children) {System.out.println(child);}// 延时阻塞--实时监控Thread.sleep(Long.MAX_VALUE);}

（5）检测节点是否存在：

 @Test//查看节点是否存在public void exists() throws InterruptedException, KeeperException {//关闭监听Stat exists = zkClient.exists("/atguigu", false);System.out.println(exists==null?"not exist":"exist");}