ZooKeeper_6_Java操作ZK_删除节点
2017-09-03 10:28
351 查看
删除节点
同步删除节点
void org.apache.zookeeper.ZooKeeper.delete(String path, int version)
异步删除节点
void org.apache.zookeeper.ZooKeeper.delete(String path, int version, VoidCallback cb, Object ctx)
参数说明:
同步删除节点Demo
public class TestDelete implements Watcher {
// 屏障,计数器
private static CountDownLatch downLatch = new CountDownLatch(1);
public static void main(String[] args) throws Exception {
ZooKeeper zookeeper = new ZooKeeper("10.0.227.66:2181", 5000, new TestDelete());
System.out.println("zookeeper.getState()1 : " + zookeeper.getState());
try {
downLatch.await();// 在计数器未归零之前,所有线程等待
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("zookeeper.getState()2 : " + zookeeper.getState());
zookeeper.delete("/cyx", -1);
System.out.println("删除完成");
}
@Override
public void process(WatchedEvent event) {
System.out.println("receive watched event : " + event);
if (KeeperState.SyncConnected == event.getState()) {
downLatch.countDown();// 计数器-1
}
}
}
输出结果:
zookeeper.getState()1 : CONNECTING
receive watched event : WatchedEvent state:SyncConnected type:None path:null
zookeeper.getState()2 : CONNECTED
删除完成
这里就不贴ZooKeeper服务端的结果了..反正就是删掉了..
异步删除节点:
public class TestDelete implements Watcher {
// 屏障,计数器
private static CountDownLatch downLatch = new CountDownLatch(1);
public static void main(String[] args) throws Exception {
ZooKeeper zookeeper = new ZooKeeper("10.0.227.66:2181", 5000, new TestDelete());
System.out.println("zookeeper.getState()1 : " + zookeeper.getState());
try {
downLatch.await();// 在计数器未归零之前,所有线程等待
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("zookeeper.getState()2 : " + zookeeper.getState());
zookeeper.delete("/cyx", -1, new myCallBack(), "123");
System.out.println("删除完成");
Thread.sleep(Integer.MAX_VALUE);
}
static class myCallBack implements VoidCallback {
@Override
public void processResult(int arg0, String arg1, Object arg2) {
System.out.println(arg0);
System.out.println(arg1);
System.out.println(arg2);
}
}
@Override
public void process(WatchedEvent event) {
System.out.println("receive watched event : " + event);
if (KeeperState.SyncConnected == event.getState()) {
downLatch.countDown();// 计数器-1
}
}
}
输出结果:
zookeeper.getState()1 : CONNECTING
receive watched event : WatchedEvent state:SyncConnected type:None path:null
zookeeper.getState()2 : CONNECTED
删除完成
0
/cyx
123
这个回调和上面创建节点的使用方式差不多耶...
不多说了...
自己体会....
同步删除节点
void org.apache.zookeeper.ZooKeeper.delete(String path, int version)
异步删除节点
void org.apache.zookeeper.ZooKeeper.delete(String path, int version, VoidCallback cb, Object ctx)
参数说明:
path | 执行数据节点的节点路径 |
version | 指定节点的版本数据,表明本次删除是针对该数据版本进行的 |
cb | 注册一个异步回调函数 |
ctx | 用于传递上下文信息的对象 |
public class TestDelete implements Watcher {
// 屏障,计数器
private static CountDownLatch downLatch = new CountDownLatch(1);
public static void main(String[] args) throws Exception {
ZooKeeper zookeeper = new ZooKeeper("10.0.227.66:2181", 5000, new TestDelete());
System.out.println("zookeeper.getState()1 : " + zookeeper.getState());
try {
downLatch.await();// 在计数器未归零之前,所有线程等待
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("zookeeper.getState()2 : " + zookeeper.getState());
zookeeper.delete("/cyx", -1);
System.out.println("删除完成");
}
@Override
public void process(WatchedEvent event) {
System.out.println("receive watched event : " + event);
if (KeeperState.SyncConnected == event.getState()) {
downLatch.countDown();// 计数器-1
}
}
}
输出结果:
zookeeper.getState()1 : CONNECTING
receive watched event : WatchedEvent state:SyncConnected type:None path:null
zookeeper.getState()2 : CONNECTED
删除完成
这里就不贴ZooKeeper服务端的结果了..反正就是删掉了..
异步删除节点:
public class TestDelete implements Watcher {
// 屏障,计数器
private static CountDownLatch downLatch = new CountDownLatch(1);
public static void main(String[] args) throws Exception {
ZooKeeper zookeeper = new ZooKeeper("10.0.227.66:2181", 5000, new TestDelete());
System.out.println("zookeeper.getState()1 : " + zookeeper.getState());
try {
downLatch.await();// 在计数器未归零之前,所有线程等待
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("zookeeper.getState()2 : " + zookeeper.getState());
zookeeper.delete("/cyx", -1, new myCallBack(), "123");
System.out.println("删除完成");
Thread.sleep(Integer.MAX_VALUE);
}
static class myCallBack implements VoidCallback {
@Override
public void processResult(int arg0, String arg1, Object arg2) {
System.out.println(arg0);
System.out.println(arg1);
System.out.println(arg2);
}
}
@Override
public void process(WatchedEvent event) {
System.out.println("receive watched event : " + event);
if (KeeperState.SyncConnected == event.getState()) {
downLatch.countDown();// 计数器-1
}
}
}
输出结果:
zookeeper.getState()1 : CONNECTING
receive watched event : WatchedEvent state:SyncConnected type:None path:null
zookeeper.getState()2 : CONNECTED
删除完成
0
/cyx
123
这个回调和上面创建节点的使用方式差不多耶...
不多说了...
自己体会....
相关文章推荐
- ZooKeeper_9_Java操作ZK_检测节点
- Zookeeper客户端基本操作java实现——创建连接、创建节点、添加修改节点内容、获取子节点、获取节点数据、删除节点
- ZooKeeper_5_Java操作ZK_创建节点
- ZooKeeper_Java操作(创建节点/获取节点/删除节点)
- zookeeper递归删除znode节点java Demo
- Java单链表接本操作(三)--删除当前节点
- Zookeeper命令行操作(常用命令;客户端连接;查看znode路径;创建节点;获取znode数据,查看节点内容,设置节点内容,删除节点;监听znode事件;telnet连接zookeeper)
- java对XML文件的解析、节点的增加、删除操作总结
- zookeeper学习心得一:基础讲解---zk节点类型以及对节点的相应操作
- ZooKeeper_7_Java操作ZK_获取数据
- Java单链表基本操作(六)--删除重复节点;
- ZooKeeper之Java客户端API使用—删除节点。
- zookeeper生成节点、删除节点 For Java
- zookeeper生成节点、删除节点 For Java
- 线上zk节点报org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:187) at java.lang.Thread.run(libgcj.so.10)
- zookeeper学习之java api查找并删除节点<五>
- ZooKeeper_4_Java操作ZK_创建会话
- Zookeeper系列(八)Zookeeper客户端(JAVA)API之修改、删除节点
- java对XML文件的解析、节点的增加、删除操作总结