【发布时间】:2017-09-20 07:53:38
【问题描述】:
我使用 Curator 对 Zookeeper 进行编程。我想观察 zonde 的子 znode。我的代码如下所示:
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时,我希望触发观察者。但是失败了,请问有人知道吗?
【问题讨论】:
标签: apache apache-zookeeper apache-curator