问题标签 [apache-curator]

我正在使用 curator 框架连接到 zookeeper 服务器，但遇到了奇怪的 DNS 解析问题。这是线程的 jstack 转储，

该线程似乎卡在本机方法中并且永远不会返回。它也非常随机地发生，因此无法始终如一地重现。有任何想法吗？

在测试设置中（单个客户端服务器 - 运行 Gatling 的本地主机，在测试期间创建和关闭连接）我的单节点 Zookeeper 保持所有 TCP 连接打开，直到测试运行完成。

在前 2 分钟的测试运行期间，我重复创建了多达 10 个并行客户端连接，这些连接处于活动状态大约 30 秒，然后再次关闭它们的连接。因此，在任何一个时刻，前 2 分钟内最多有 10 个连接处于活动状态。然后测试再继续 8 分钟，在此期间只有 1 个客户端连接处于活动状态。

客户端：使用 Curator 2.9.1 和 Zookeeper 3.4.6

Zookeeper 节点：3.4.8-1--1

AFAIK 客户端正确关闭了他们的连接（证明：我看到它的临时节点在执行 ls /path/to/ephemerals 时被删除，zookeeper 日志也​​指示关闭连接）

但是，在向 zookeeper 节点发送cons命令时，前 2 分钟 TCP 连接数一直在上升，总共达到 126 个。然后一直保持在这个数字，直到 testrun 完成，此时所有连接一下子就走了。

我预计连接数会低得多，例如 10 到 20，并且在测试的“活动”阶段保持稳定。相反，只要我打开/关闭新连接，它就会不断上升。

在最初的 2 分钟内，zookeeper 日志显示打开和关闭连接：

然后，仅在运行结束时，对于我看到的每个连接

（请注意，上面的日志是从手动中断的运行中获取的，但是如果我让运行完成到 16:02，行为是相同的）

我正在使用以下配置（摘录）运行：

连接数量的增加与测试设置有关，还是 Zookeeper 运行方式固有的？

我是 curator 的新手，只是好奇 curator 框架是否在内部处理客户端连接重新平衡？如果不是，我知道客户端会随机选择一个节点进行连接，是否需要做一些客户端连接再平衡？

非常感谢

我最近了解了 ZooKeeper 及其设计。我了解一个 ZooKeeper 服务由多个 ZooKeeper 服务器支持，但是，有必要选择其中一个服务器作为组的领导者。

接下来，我开始浏览 LeaderLatch 和 LeaderElection 的 Apache Curator 配方，而不是谈论选择领导者，他们谈论选择一个流程作为领导者（组织者）。

我对此感到困惑。有人可以帮我澄清一下为什么 Curator recipe 和 ZooKeeper 都在谈论两种不同的 Leader 吗？

如果他们确实不同，那么这些领导者如何相互关联？

我的代码是这样的：

策展人框架版本是 3.1.0。我收到下面列出的错误。

使用 curatortreeCache时，如何确保缓存已准备就绪？

之后cache.start()，如果我getCurrentData立即调用，它将返回null，那么如何确保缓存已准备好？有人可以举个例子吗？谢谢

我有一个有多个孩子的基本路径。我在基本路径上添加观察者，并在应用程序启动时添加所有孩子。

现在，我正在处理方法中捕获过期事件。

此方法在到期时执行，但不会因节点中的任何更改而触发手表。

我是 AMQP 的新手，但我想通过 Apache Zookeeper 上的 Curator Framework 获得 AMQP 的体验，所以如果你有 Github 示例项目的链接和有用的信息来理解这一点，请告诉我。

Spark 是否与 Zookeeper 集成？我想从 Spark 中的 Zookeeper 读取配置信息，而不使用 Apache Curator。我的问题是，如果使用 Spark 的 Java API，你可以获得这个。

谢谢！

我有一个Zookeeper写的配置信息。我正在使用 Apache Curator 通过 Curator Watcher 读取配置（如果有更好的读取解决方案，我很乐意使用它），因此如果 Zookeeper 中的配置发生更改，我将收到新的配置。我在 Spark 中使用这个配置。如何将它共享给同一应用程序的所有 Spark 执行器？

谢谢！

乐：

谢谢迪凯，

在以下代码中，您将在哪里执行观察程序？我是新来的火花，我不确定每个工人会发生什么。

谢谢！