ZooKeeper的java客户端api的监听功能代码示范
package cn.edu360.zk.demo;
import java.util.List;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.EventType;
import org.apache.zookeeper.Watcher.Event.KeeperState;
import org.apache.zookeeper.ZooKeeper;
import org.junit.Before;
import org.junit.Test;
public class ZookeeperWatchDemo {
ZooKeeper zk = null;
@Before
public void init() throws Exception {
zk = new ZooKeeper("hadoop1:2181,hadoop2:2181,hadoop3:2181", 2000, new Watcher() {
@Override
public void process(WatchedEvent event) {
if(event.getState() == KeeperState.SyncConnected && event.getType() == EventType.NodeDataChanged) {
System.out.println(event.getPath()); //收到的事件所发生的节点路径
System.out.println(event.getType()); //收到的事件的类型
System.out.println("赶紧换照片,换性感的浴衣..."); //收到事件后我们的处理逻辑
try {
zk.getData("/mygirls", true, null);
} catch (KeeperException | InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}else if(event.getState() == KeeperState.SyncConnected && event.getType() == EventType.NodeChildrenChanged) {
System.out.println("子节点变化了。");
}
}
});
}
@Test
public void testGetWatch() throws Exception {
byte[] data = zk.getData("/mygirls",true ,null); //监听节点变化
List<String> children = zk.getChildren("/mygirls", true); //监听子节点变化事件
System.out.println(new String(data,"UTF-8"));
Thread.sleep(Long.MAX_VALUE);
}
}