pom.xml文件
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.10</version>
</dependency>
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.10</version>
</dependency>
zkClient的好处1：递归创建，2：递归删除，3：避免不存在异常
递归创建
public class CreateNodeDemo {
public static void main(String[] args) {
ZkClient client = new ZkClient("10.143.143.185:6181", 5000);
String path = "/zk-client/c1";
// 递归创建节点
client.createPersistent(path, true);
}
}
image.png
zkClient注册事件
1：subscribeChildChanges/unsubscribeChildChanges(节点变化)
2：subscribeDataChanges/unsubscribeDataChanges（数据变化）
/**
* 监听节点变化
*/
public class GetChildrenDemo {
public static void main(String[] args) throws InterruptedException {
String path = "/zk-client";
ZkClient client = new ZkClient("10.143.143.185:6181", 5000);
client.subscribeChildChanges(path, new IZkChildListener() {
@Override
public void handleChildChange(String parentPath, List<String> currentChilds) throws Exception {
System.out.println(parentPath + "的子节点发生变化: " + currentChilds);
}
});
client.createPersistent(path);
Thread.sleep(1000);
System.out.println(client.getChildren(path));
client.createPersistent(path + "/c1");
Thread.sleep(1000);
client.delete(path + "/c1");
Thread.sleep(1000);
client.delete(path);
Thread.sleep(Integer.MAX_VALUE);
}
}
image.png
/**
* 监听节点数据变化
*/
public class GetDataDemo {
public static void main(String[] args) throws InterruptedException {
String path = "/zk-client";
ZkClient client = new ZkClient("10.143.143.185:6181", 5000);
client.createEphemeral(path, "123");
client.subscribeDataChanges(path, new IZkDataListener() {
@Override
public void handleDataChange(String dataPath, Object data) throws Exception {
System.out.println(dataPath + " changed: " + data);
}
@Override
public void handleDataDeleted(String dataPath) throws Exception {
System.out.println(dataPath + " deleted");
}
});
System.out.println(client.readData(path).toString());
client.writeData(path, "456");
Thread.sleep(1000);
client.delete(path);
Thread.sleep(Integer.MAX_VALUE);
}
}
image.png
