今天在学习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之旅! 事件