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]) 

該角色將隨着羣集成員的狀態更改而接收更新。

種子節點除了被羣集的其他成員列爲種子以外沒有特殊的特性。一旦成員使用種子加入，它們就不再有任何特殊關係，它們只是同一個羣集的成員。一個節點只能找出它認爲是種子的節點（儘管你可以編寫你自己的代碼來圍繞羣集傳輸數據，但我個人無法考慮這種情況）。