检查akka集群中是否存在参与者

Question

我遇到了一个场景，我需要检查特定的参与者是否存在，这可以通过ActorSystem完成。actorSelection方法，指定参与者路径

但是，当本地节点上存在此类参与者时，此方法可以正常工作。若actor系统由多个节点组成，并且actor存在于另一个节点上，则该方法告诉我们actor不存在。若我给出指定远程参与者系统的字符串，那个么这个方法可以工作。但在actorSelection方法中指定远程actor系统字符串似乎不是一个好主意，因为集群中的节点可以加入和离开

def getOrCreate(customerId: String, deviceId: String): Future[ActorRef] = {
    context.system.actorSelection(s"/user/${customerId}{$deviceId}") ? Identify(deviceId) map {
    case ActorIdentity(`deviceId`, None) =>
      // create new actor
    case ActorIdentity(`deviceId`, Some(actor)) =>
      actor
  }
}

当actor存在于本地节点上时，上述代码工作正常，为了检查actor是否存在于集群中的其他节点上，我必须执行以下操作：

def getOrCreate(customerId: String, deviceId: String): Future[ActorRef] = {
    context.system.actorSelection(s"akka.tcp://Relay@node1:3503/user/${customerId}{$deviceId}") ? Identify(deviceId) map {
    case ActorIdentity(`deviceId`, None) =>
      // create new actor
    case ActorIdentity(`deviceId`, Some(actor)) =>
      actor
  }
}

有没有更好的方法来检查actor是否存在于整个akka集群中，而不仅仅是本地节点？

Answer 1

看起来只有当集群中不存在具有相同标识符的参与者时，才需要创建参与者实例。为此，我认为最好的方法是使用Akka集群切分，让Akka负责创建和分发实例。这还将负责将任何消息路由到参与者的正确节点，并在集群大小发生变化时重新分配参与者等。