pom 文件引入
<dependencies>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.14</version>
</dependency>
</dependencies>
zookeeper 原生 api 创立会话操作
public class CreateSession implements Watcher {private static CountDownLatch countDownLatch = new CountDownLatch(1);
public static void main(String[] args) throws IOException, InterruptedException {ZooKeeper zooKeeper = new ZooKeeper("119.45.52.68:2181",6000,new CreateSession());
System.out.println(zooKeeper.getState());
countDownLatch.await();
System.out.println("zk session create success");
}
@Override
public void process(WatchedEvent watchedEvent) {if (watchedEvent.getState()==Event.KeeperState.SyncConnected){countDownLatch.countDown();
}
}
}
失常创立回话
zookeeper 原生 api 获取信息操作
public class getNoetNode implements Watcher {
private static ZooKeeper zooKeeper;
public static void main(String[] args) throws InterruptedException, IOException {zooKeeper = new ZooKeeper("119.45.52.68:2181",10000,new getNoetNode());
//countDownLatch.await();
Thread.sleep(Integer.MAX_VALUE);
}
@Override
public void process(WatchedEvent event) {if(event.getType() ==Event.EventType.NodeChildrenChanged){
// 再次获取节点数据
try {
List<String> children =
zooKeeper.getChildren(event.getPath(), true);
System.out.println(children);
} catch (KeeperException e) {e.printStackTrace();
} catch (InterruptedException e) {e.printStackTrace();
}
}
// 当连贯创立了,服务端发送给客户端 SyncConnected 事件
if(event.getState() == Event.KeeperState.SyncConnected){
try {
// 调⽤获取单个节点数据⽅法
getNodeData();
getChildren();} catch (Exception e) {e.printStackTrace();
}
}
System.out.println();}
private static void getNodeData() throws Exception {byte[] data = zooKeeper.getData("/persistent/children", true,
null);
System.out.println(new String(data,"utf-8"));
}
public static void getChildren() throws Exception{List<String> childrens = zooKeeper.getChildren("persistent",true);
System.out.println(childrens);
}
}
欢送搜寻关注自己与敌人共同开发的微信面经小程序【大厂面试助手】和公众号【微瞰技术】