码迷,mamicode.com
首页 > 系统相关 > 详细

十九、curator recipes之PathChildrenCache

时间:2019-01-17 01:14:02      阅读:250      评论:0      收藏:0      [点我收藏+]

标签:import   tostring   one   java   create   out   监听   文档   read   

简介

curator可以监听路径下子节点的变更操作,如创建节点,删除节点

官方文档:http://curator.apache.org/curator-recipes/path-cache.html

javaDoc:http://curator.apache.org/apidocs/org/apache/curator/framework/recipes/cache/PathChildrenCache.html

代码示例

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.cache.PathChildrenCache;
import org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent;
import org.apache.curator.framework.recipes.cache.PathChildrenCacheListener;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class PathChildrenCacheDemo {
    private static CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(3000, 1));
    private static String path = "/path/test/0001";
    static {
        client.start();
    }

    public static void main(String[] args) throws Exception {
        PathChildrenCache pathChildrenCache = new PathChildrenCache(client, path, true);
        pathChildrenCache.getListenable().addListener(new PathChildrenCacheListener() {
            @Override
            public void childEvent(CuratorFramework curatorFramework, PathChildrenCacheEvent pathChildrenCacheEvent) throws Exception {
                System.out.println(pathChildrenCacheEvent.toString());
            }
        });
        pathChildrenCache.start();
        System.out.println("started");
        Thread.sleep(2000);
        System.out.println("sleep end");
        client.create().forPath(path + "/000002");
        client.delete().forPath(path + "/000002");
        System.out.println("updated");
        pathChildrenCache.close();
        System.out.println("close");
        Thread.sleep(50000);
        client.close();
    }
}

 

十九、curator recipes之PathChildrenCache

标签:import   tostring   one   java   create   out   监听   文档   read   

原文地址:https://www.cnblogs.com/lay2017/p/10280188.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!