Curator 5.0 监听子节点状态的疑问
public class Solution {
public static void main(String[] args) {
try {
RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3);
CuratorFramework curatorFramework = CuratorFrameworkFactory.builder()
.connectString("127.0.0.1:2181")
.sessionTimeoutMs(50000)
.connectionTimeoutMs(30000)
.retryPolicy(retryPolicy)
.namespace("servers")
.build();
curatorFramework.start();
CuratorCache curatorCache = CuratorCache.builder(curatorFramework, "/").build(); // ①
CuratorCacheListener curatorCacheListener = CuratorCacheListener.builder().forPathChildrenCache("/", curatorFramework, new PathChildrenCacheListener() { // ②
@Override
public void childEvent(CuratorFramework curatorFramework, PathChildrenCacheEvent pathChildrenCacheEvent) throws Exception {
// ...
}
}).build();
curatorCache.listenable().addListener(curatorCacheListener);
curatorCache.start();
Thread.sleep(Integer.MAX_VALUE);
} catch (Exception e) {
e.printStackTrace();
}
}
}
代码 ① 处需设置 path,代码 ② 处同样需要设置 path,这两处的 path 分别代表什么意思呢?
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论