自己的环境在虚拟机上,于是使用同事的环境调试问题,发现无法初始化成功,提示keepererrorcode = connectionloss for,于是上网查了下资料整理如下:
1.对比代码中引用的jar库是否跟服务器上的一致:
服务器端:zookeeper-3.4.10.jar
代码端:zookeeper-3.4.9.jar
2.网上还有一种说法是连接还没创建成功,就开始设置watcher了。我们可以在创建了链接后,判断链接状态OK了再进行下一步操作:
public static void waitUntilConnected(ZooKeeper zooKeeper, CountDownLatch connectedLatch) { if (States.CONNECTING == zooKeeper.getState()) { try { connectedLatch.await(); } catch (InterruptedException e) { throw new IllegalStateException(e); } } }
3.这里引申出zk的一个问题:
在创建连接时,不管是否成功,都会给一个看似正确的pid,并不会管这个链接是否可用,或者正在连接。所以最好的方式是在创建连接后,对连接状态进行判断。
在我之前的博客中也遇到在solaris上用zk的时候,单线程和多线程版本使用在solaris和centos上不一致导致连,定位了好几天,最后总结还是代码没有做好返回值判断造成的。