Akka: Cách tìm các nút hiện tại trong một cụm?

Question

Từ bên trong diễn viên Akka, làm thế nào bạn có thể tìm ra các nút của cụm? Đó là, các nút mà nút cục bộ xem là hiện có thể truy cập.

Cảm ơn, - Daniel

Answer 1

Bạn thực sự không cần phải đăng ký ClusterDomainEvent hoặc MemberEvent. Bạn chỉ có thể truy cập vào state thành viên của phần mở rộng cụm, ví dụ:

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

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

Answer 2

Một cách tiếp cận có thể có diễn viên khác đăng ký vào ClusterDomainEvent bài viết, đặc biệt tìm kiếm các thành viên thông qua các sự kiện CurrentClusterState. Điều đó có thể trông giống như thế này:

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

Đây là loại một phác thảo thô (có thể cần một vài điều chỉnh), nhưng từ đây, bất kỳ diễn viên mà muốn biết danh sách thành viên hiện tại có thể gửi tin nhắn GetMembers này diễn viên qua ? và chờ phản hồi.

Phương pháp tiếp cận này giả định rằng bạn có thể có nhiều diễn viên muốn có thông tin này. Nếu nó chỉ ra rằng bạn chỉ có một diễn viên muốn thông tin này thì chỉ cần có diễn viên đăng ký vào sự kiện đó và cập nhật trạng thái nội bộ của nó với các thành viên.

Answer 3

Tweaked mẫu từ 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 
    } 
}