java - 如何将种子节点添加到正在运行的 akka-cluster

Question

我正在尝试创建一个容错的 akka 集群，它将部署在 AWS 中。它是一个标准集群，具有 3 个种子节点 SN1、SN2 和 SN3 以及连接到一个种子节点的多个 Akka 系统。SN 具有 ASG，它将在一个新实例出现故障时旋转一个新实例。

我知道如果 SN1 发生故障，系统将故障转移到其他 SN（种子节点）。但是如何在不停止集群的情况下无缝注册现在具有新 IP 地址的 SN1。

我尝试了以下没有运气

有没有人知道如何将种子节点添加到正在运行的 Akka 集群中？

谢谢

score 4 · Accepted Answer

请检查：

在 scala 中，但也在使用自动缩放，并解释了如何找到您的新 IP (S1) 和其余 ips (S2...) 并加入它们。

希望会有所帮助。

score 3 · Accepted Answer

我们最终通过 zookeeper-seed 插件将 ip address:port 注册到 zookeeper。如果我没记错的话，该插件实现了一个闩锁。

基本上每个 aka 系统都从 zookeeper 获取系统列表。然后它将自己从列表中删除并使用新列表作为其种子节点。

如果我有时间，我会尝试写一些关于实现 24 系统 akka 集群的经验教训。

谢谢

score 0 · Accepted Answer

该问题的答案不是，您不能将种子节点添加到正在运行的 Akka 集群。

来自 Akka scala-doc：

一个actor系统只能加入一个集群一次。其他尝试将被忽略。成功加入后，必须重新启动它才能加入另一个集群或再次加入同一个集群。

但是您可以启动节点并连接到已创建的种子节点之一，并将动态添加到集群中。

3 回答 3