如何使用zookeeper和策展人进行配置管理？

Question

我一直在读关于使用zookeeper进行配置管理的文章。

我知道有一位阿帕奇策展人可以方便地与zookeeper互动。

我有一些客户连接到一组资源。他们必须以同样的方式使用这些资源。比如资源之间的分片和主选举。

我想使用zookeeper，这样，如果一个客户端在给定时间内注意到其中一个资源已关闭，它可以更改配置，其他客户端可以立即开始使用新配置。

因此，一个客户端在znodezooManager中的路径中写入配置，而其他客户端正在监视该路径。

如何在策展人中设置数据：

zk.setData().forPath(pathName, "data".getBytes());

如何在策展人中观看路径：

zk.getData().usingWatcher(watcher).forPath(pathName);

现在，当路径的值改变，手表被触发时，我必须得到路径的新值。我该怎么做？

这总是返回null内的过程（）

zk.getData().watched().inBackground().forPath(pathName)

其他问题：正如文档中所说，在我获得新值后，我需要再次设置观察者吗？

观察者的来源：

CuratorWatcher watcher = new CuratorWatcher(){

                public void process(WatchedEvent event) {
                    System.out.println("event wt");
                    System.out.println(ToStringBuilder.reflectionToString(event));
                    try {
                        System.out.println(zk.getData().watched().inBackground().forPath(pathName));
                    } catch (Exception e1) {
                        // TODO Auto-generated catch block
                        e1.printStackTrace();
                    };
                    System.out.println("event wt");

                    try {
                        zk.getData().usingWatcher(this).forPath(pathName);
                    } catch (Exception e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }};

Answer 1

在馆长有适配器：

 * Get children and set the given watcher on the node.
         */
 return client.getChildren().usingWatcher(watcher).forPath(path);

或者你可以使用CuratorListener

/**
         * Get children and set a watcher on the node. The watcher notification will come through the
         * CuratorListener (see setDataAsync() above).
         */
        return client.getChildren().watched().forPath(path);