我用管理员给Zookeeper编程。我想观察zonde的子znodes。我的代码看起来像:
CuratorFramework frameWork = CuratorFrameworkFactory.builder()
.retryPolicy(new RetryNTimes(3, 1000))
.connectString("127.0.0.1:2181").build();
frameWork.start();
CuratorWatcher watcher = new CuratorWatcher () {
@Override
public void process(WatchedEvent event) throws Exception {
System.out.println("event :" + event);
}
};
frameWork.getChildren().usingWatcher(watcher).forPath("/aa");
frameWork.setData().forPath("/aa/dd", "asdfd".getBytes());
当“/aa/dd”的setdata被调用时,我希望监视器被触发。但是失败了,有人知道吗?
1条答案
按热度按时间2w3rbyxf1#
馆长有一个方法可以做到这一点。请参阅TreeCache:http://curator.apache.org/curator-recipes/tree-cache.html