问答

Curator 5.0 监听子节点状态的疑问

作者:admin 2021-05-06 我要评论

public class Solution { public static void main(String[] args) { try { RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 3); CuratorFramewor...

在说正事之前,我要推荐一个福利:你还在原价购买阿里云、腾讯云、华为云服务器吗?那太亏啦!来这里,新购、升级、续费都打折,能够为您省60%的钱呢!2核4G企业级云服务器低至69元/年,点击进去看看吧>>>)
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 分别代表什么意思呢?

版权声明:本文转载自网络,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。本站转载出于传播更多优秀技术知识之目的,如有侵权请联系QQ/微信:153890879删除

相关文章
  • Curator 5.0 监听子节点状态的疑问

    Curator 5.0 监听子节点状态的疑问

  • TypeScript 和 Array.map() 匿名函数返

    TypeScript 和 Array.map() 匿名函数返

  • xss情况下视频(video)怎么能正常使用

    xss情况下视频(video)怎么能正常使用

  • github被pull bot 自动更新了,怎么恢

    github被pull bot 自动更新了,怎么恢

腾讯云代理商
海外云服务器