Akka集群成员查询

Question

对于akka集群，是否可以查询集群中当前有哪些成员？如果种子节点出现故障并最终恢复正常，是否可以找出其他成员将其用作种子节点的其他成员？

Answer 1

您可以获得当前群集成员像这样的快照：

val system = ActorSystem(...) // whatever 
val members = Cluster(system).state.members 

但是，这可能是过时的。如果您需要跟踪群集成员资格，则应订阅群集事件。

val monitor = system.actorOf(Props[MyClusterMonitor]) 
Cluster(system).subscribe(monitor, classOf[ClusterEvent.ClusterDomainEvent]) 

该角色将随着群集成员的状态更改而接收更新。

种子节点除了被群集的其他成员列为种子以外没有特殊的特性。一旦成员使用种子加入，它们就不再有任何特殊关系，它们只是同一个群集的成员。一个节点只能找出它认为是种子的节点（尽管你可以编写你自己的代码来围绕群集传输数据，但我个人无法考虑这种情况）。