博客

一、使用apache提供的zookeeper依赖包进行操作

首先在pom.xml中引入下述依赖： 

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

1、创建会话

public ZooKeeper(String connectString, int sessionTimeout, Watcher watcher);

创建会话方法：客户端可以通过创建一个zookeeper实例来连接zookeeper服务器

connectString：连接服务器列表，以“,”分割

sessionTimeout：心跳检测时间周期(毫秒)

watcher：事件处理通知器

import java.util.concurrent.CountDownLatch;

import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.EventType;
import org.apache.zooke