测试参与者发件人是本地还是远程

Question

我需要确定消息的发送者是Akka集群中的本地行为者还是远程行为者之一。目前我找到的唯一方法是

def isLocal(sndr: ActorRef) = sndr.path.address.toString == context.system.toString

在每个节点上，路由器管理许多参与者来完成工作。工作参与者将结果发送回本地主参与者，并通过发件人引用分配新的职务。主参与者还定期向其他节点的主参与者发送结果，确保数据在不同节点的主参与者之间随机“混合”。在数据来自远程参与者的情况下，接收主机不应试图分配新的工作。它本质上是一个带有混合的岛屿方法的实现。

Answer 1

您可以通过扩展获得actorsystem的远程处理地址（请参见通过编程方式使用Akka获取临时端口）。这样，您可以比较地址而不是字符串，这样就不那么乏味了。

针对Ryan的观点，另一种方法是将结果信息包装在另一个信息中。当您在包装器上匹配时，您将知道它不是来自本地工作人员，然后您可以打开它，并对结果做任何需要做的事情。

def receive = {
  case NonLocalResults(results) => // do something with non-local results
  case Results(...)             => // do something with local results
  ...
}