如何使用Curator檢查Zookeeper服務器是否已啓動？

Question

對於我的測試，我正在使用Zookeeper測試服務器，但我希望能夠等到服務器完全啓動（因爲我將它作爲測試init進程的一部分啓動）。

如何可以乾淨地檢查使用Curator正確啓動（Test）Zookeeper服務器？某種形式的ping/etc？

Answer 1

我設法找到答案並希望分享。

策展人有一個方法blockUntilConnected它將等待，直到它從Zookeeper獲得連接。

CuratorFramework curator = CuratorFrameworkFactory.newClient("localhost:" + TestConstants.TEST_ZOOKEEPER_PORT, new RetryOneTime(100)); 
curator.start(); 
curator.blockUntilConnected();