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); }}欢送搜寻关注自己与敌人共同开发的微信面经小程序【大厂面试助手】和公众号【微瞰技术】