Akka键入：如何让演员推荐给当地演员？

Question

我正在将现有应用程序从Akka Classic移植到Akka Typed。最初，您可以使用上下文获取对参与者的引用。actorSelection（）。resolveOne（）

我知道在Akka Type中不再支持这一点，我们应该使用Receptionist来注册演员以供ServiceKey发现。

但是，我只想将消息发送到本地参与者，即存在于集群中每个节点上的本地单例。我有它的本地路径，但没有对它的直接引用。这是因为它是由Akka管理系统创建的健康检查参与者。

从文档中可以看出，向接待员注册一个参与者以获得服务密钥，这使得集群的所有成员都可以使用该服务密钥。因此，如果我查询服务键，我将在所有节点上收到对单例参与者的引用。

似乎没有一种方法可以仅在本地注册Receptionist，并且在集群中发布这些内部引用似乎不必要地泄漏并且违反了封装。从Receptionist返回的列表中找出哪个ref是本地参与者似乎也不容易。我想用于注册的ServiceKey可能是系统特定的？

我错过了一个明显的解决方案吗？

Answer 1

在Akka管理参与者的特殊情况下，由于该项目不依赖于Akka类型（因此所涉及的参与者是典型的参与者），您可以将键入的ActorContext视为经典的ActorContext，并使用ActorSelection。

从您的问题来看，我猜Java（在Scala中，隐式使其不那么冗长，也许可以澄清意图）：

akka.actor.typed.javadsl.Adapter.toClassic(context).actorSelection(path).resolveOne(timeout)

对于只想要解析类型化本地参与者的情况，我发现最有效的策略是将解析功能合并到创建ActorSystem时提供的行为中。想要被找到的参与者将向ActorSystem注册，其他参与者可以向ActorSystem询问ActorRef。

这里的一个微妙之处是context.getSystem（）为您提供了一个ActorSystem

// Might not actually be syntactically valid Java, but hopefully the fix to make it
// legal is obvious...
ActorRef<MyActorSystemCommand> systemRef = context.getSystem().unsafeUpcast<MyActorSystemCommand>()

请注意，正确获取ActorSystem的消息类型非常重要：如果ActorSystem的行为不接受该类型的消息，则在发送消息时，actor系统将崩溃（据我所知，无法阻止actor系统关闭）。

这种方法的一个演变是定义一个仅本地的接待员参与者，该参与者在ActorSystem启动时产生：希望与该接待员交互的参与者通过上述方法获得其ActorRef，然后该参与者处理解决方案。

当然，请注意，在这两种方法中（与集群感知的Receptionist一样），只有明确选择加入这样解决的参与者才是可解决的。这与Akka Type的基本主题一致：让参与者更多地负责它向外界暴露的程度。