Apache Curator 重新连接后丢失所有手表

Question

我在我的项目中使用 Apache Curator。 CuratorFramework 失去与 ZooKeeper 服务器的连接后，它会自动重新连接，但它似乎失去了我设置的所有手表，并且我不再收到任何通知。如果连接没有断开并重新启动，手表会按预期工作。

这是 Curator 错误还是我做错了什么？ 设置手表的代码如下：

CuratorFramework framework = CuratorFrameworkFactory.newClient(connectString, SESSION_TIMEOUT_MS, 0, new ExponentialBackoffRetry(CONNECT_TIMEOUT_MS, CONNECT_RETRY_COUNT));
framework.start();
framework.getChildren().usingWatcher(watcher).forPath(path);

谢谢，

Answer 1

如果连接发生变化，您的Watcher 应该会通知您。如果是这样，WatchedEvent 上的 EventType 将是 None，以此为契机重新启动您的手表：

@Override
public void process(WatchedEvent event) {
    if (event.getType == Event.EventType.None && event.getState() == Event.KeeperState.SyncConnected){
        framework.getChildren().usingWatcher(this).forPath(path);
...