Zookeeper的HelloWorld之旅

      今天在学习zookeeper来实现配置管理的功能,因为以前都是看资料来了解相关的知识,觉得对zookeeper的了解已经比较多,结果动起手来却截然不同,并且是很是细微的一小地方让我调试了老半天,细节见真章!就是卡在一个很简单的一个地方,链接zookeeper服务器后判断是否存在根节点,如不存在则建立。 服务器

ZooKeeper zk = new ZooKeeper(url,3000,new Watcher(){
@Override
public void process(WatchedEvent event) {
    System.out.println("触发了事件:"+ event.getType());
    System.out.println("事件状态:"+ event.getState());
}
});

if(zk.exists("/root", true) == null){
    zk.create("/root", "root".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
}
而后运行的时候就报错链接异常的信息,新手,而后一直觉得是url地址没写对,又仔细检查了zookeeper的服务器,都没啥问题,就是一直连不上,并且debug后肯定是在if(zk.exists("/root", true) == null)在这里抛的异常,折腾了老半天!最后才想是否是链接的时候初始化须要必定时间,还没连上就运行到判断这里了,果断添加了延迟时间后就能够了。。。。修改后的代码以下:
ide

ZooKeeper zk = new ZooKeeper(url,3000,new Watcher(){
@Override
public void process(WatchedEvent event) {
    System.out.println("触发了事件:"+ event.getType());
    System.out.println("事件状态:"+ event.getState());
}
});
学习

while(!"CONNECTED".equals(zk.getState().toString())){
    Thread.sleep(3000);
}
url

if(zk.exists("/root", true) == null){ spa

    zk.create("/root", "root".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT); debug

} 调试

惭愧啊,个人第一次zookeeper之旅! 事件

相关文章
相关标签/搜索