2017-10-04 158 views

回答

0

确保Zookeeper启动并运行的唯一方法是连接到它。

如果您使用Kafka,您可以重新使用它自带的Zookeeper库,org.I0Itec.zkclient.ZkClient

只要致电:

ZkClient client = new ZkClient("localhost:2181", 5000); 

第二个参数是连接超时。在这种情况下,它会尝试连接5秒钟。如果无法连接,则抛出ZkTimeoutException

+0

(意味着你有一个连接,与没有例外),你应该打一个电话来看看ZK是否能够回应,然后关闭连接 'client.numberOfListeners(); client.close();' – ShaharT

1

从shell脚本,你也可以使用nc -z命令 - 非常方便的时候启动脚本您的应用程序会检查它首先,你的应用程序不关心客户端存在后检查ZK

相关问题