Akka: Jak znaleźć aktualne węzły w klastrze?

Question

Jak rozpoznać węzły klastra od aktora Akka? Oznacza to, że węzły, które węzeł lokalny uważa za dostępne.

Dzięki - Daniel

Answer 1

rzeczywiście nie trzeba subskrybować ClusterDomainEvent lub MemberEvent. Można tylko dostęp członu state rozszerzenia Cluster np

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

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

Answer 2

Jednym ze sposobów może być mieć inny aktor subskrybować do ClusterDomainEvent wiadomości, a konkretnie szuka członków poprzez imprezy CurrentClusterState. To może wyglądać mniej więcej tak:

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 
    } 
} 

Jest to rodzaj szorstkiej zarysu (może potrzebować kilku poprawek), ale stąd, każdy aktor, który chciał znać listę obecnych członków może wysłać wiadomość GetMembers temu aktor przez ? i czekać na odpowiedź.

Teraz to podejście zakłada, że ​​możesz mieć wielu aktorów, którzy chcą tych informacji. Jeśli okaże się, że masz tylko jednego aktora, który chce tych informacji, to po prostu poproś tego aktora, aby zasubskrybował to wydarzenie i zaktualizował jego wewnętrzny stan z członkami.

Answer 3

Tweaked próbka z 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 
    } 
}