java - 集群中的 Akka 成员( Actor )查找

Question

我的 actor A1 可以在集群中的任何种子节点中启动。在某些情况下，其他参与者 A2(可能来自另一个节点)需要为 A1 获取 ActorRef。执行此操作的最佳方法是什么？
1) 我想避免硬编码种子节点网络地址。
2) 我可以运行订阅集群事件的 actor，但我不知道如何强制他在集群开始之前查看集群中的节点。
3) 我可以尝试通过循环 ActorSelection 来查找 Actor ，但我仍然无法从我的 akka.Cluster 中获取种子节点列表。我找到的最接近的方法是:
Cluster cluster = Cluster.get(context().system());
SortedSet<Member>members = cluster.state().members();
Traversable<Member> filteredmembers = members.filter(_.status == MemberStatus.up());但这是 Scala 语法和类，我有异常(exception):

'_' used as an identifier (use of '_' as an identifier might not be supported in releases after Java SE 8)

如何避免这个异常？

Answer 1

检查一下:http://doc.akka.io/docs/akka/2.4.0-RC2/java/distributed-pub-sub.html

有了这个，您可以通过角色的路径在本地或远程向集群中的角色发送消息。当您有多个集群节点运行同一个 actor 时，它甚至可以为您执行简单的路由。