Akka: Wie finden Sie die aktuellen Knoten in einem Cluster?

Question

Wie können Sie aus einem Akka-Akteur die Knoten des Clusters herausfinden? Das sind die Knoten, die der lokale Knoten derzeit als verfügbar erachtet.

Danke, - Daniel

Answer 1

Sie brauchen eigentlich nicht zu ClusterDomainEvent oder MemberEvent abonnieren. Sie können nur Zugriff auf das state Mitglied der Cluster-Erweiterung, zum Beispiel

val cluster = akka.cluster.Cluster(context.system) 

val members = cluster.state.members.filter(_.status == MemberStatus.Up) 

Answer 2

Ein Ansatz könnte sein, eine andere Schauspieler haben in ClusterDomainEvent Nachrichten abonnieren, die speziell für die Mitglieder über das CurrentClusterState Ereignis suchen. Das könnte wie folgt aussehen:

case object GetMembers 

class ClusterMembersHolder extends Actor{ 
    var members:Set[Member] = Set() 
    override def preStart = { 
    val clusterSys = Cluster(context.system) 
    clusterSys.subscribe(self, classOf[ClusterDomainEvent]) 
    clusterSys.publishCurrentClusterState //Forces the current state 
    } 

    def receive = { 
    case state: CurrentClusterState => 
     members = state.members 

    case GetMembers => 
     sender ! members 
    } 
} 

Diese Art einer groben Umriss ist (vielleicht ein paar Veränderungen müssen), aber von hier, jeder Akteur, der die aktuelle Mitgliederliste könnte eine GetMembers Nachricht senden, dies wissen wollten Schauspieler über ? und warten auf die Antwort.

Jetzt geht dieser Ansatz davon aus, dass Sie viele Akteure haben, die diese Informationen wünschen. Wenn sich herausstellt, dass Sie nur einen Akteur haben, der diese Information haben möchte, dann müssen Sie diesen Akteur nur bei diesem Event anmelden und seinen internen Status mit den Mitgliedern aktualisieren.

Answer 3

Gezwickt Probe aus Typesafe Activator tutorial:

case object GetNodes 

class MemberListener extends Actor { 

    val cluster = Cluster(context.system) 

    override def preStart(): Unit = 
    cluster.subscribe(self, classOf[MemberEvent]) 

    override def postStop(): Unit = 
    cluster unsubscribe self 

    var nodes = Set.empty[Address] 

    def receive = { 
    case state: CurrentClusterState => 
     nodes = state.members.collect { 
     case m if m.status == MemberStatus.Up => m.address 
     } 
    case MemberUp(member) => 
     nodes += member.address 
    case MemberRemoved(member, _) => 
     nodes -= member.address 
    case _: MemberEvent ⇒ // ignore 
    case GetNodes => 
     sender ! nodes 
    } 
}