键入Akka向父执行元发送消息

Question

标题是不言自明的，我希望能够向父执行元发送消息（意味着我希望父执行元的actorref)。在Akka Classic（非类型化）中，父执行元的ActorRef可以通过以下方式从子执行元的ActorContext获得：

context.parent

（例如，参见这个问题（在Java））。

但是，Akka Typed中的Akka.actor.Typed.Scaladsl.ActorContext不公开父级的ActorRef。Scala中是否有惯用的方法为父执行元获取actorref？

Answer 1

tldr：在创建父执行元引用时将其注入子执行元引用。

键入的Akka强制执行严格的协议，因此您需要绝对清楚地表明“这个演员与另一个演员对话”。公认的答案是一种变通方法（转换为classic并使用父级），但也有它的缺点：现在您不再强制执行类型了。

下面是一些可以让您开始的代码。查看如何强制执行所有类型。你可以用不同的方式来模拟这些特征，但是你应该得到一些改变：

object ParentActor {
  sealed trait Command 
  
  case class DoSomething() extends Command
  
  // you do not have to do this, but creating another trait
  // allows you to narrow the amount of messages the parent can receive from the child
  sealed trait ChildNotification extends Command
  case class MessageFromChild() extends ChildNotification

  
  def apply(): Behavior[Command] = {
    Behaviors.receive( (context, message) => 
      message match {
        case DoSomething() =>
          // create a child that knows about its parent
          context.spawn(ChildActor(context.self), "child")
          Behaviors.same

        case MessageFromChild() =>
          context.log.info("I received a message from my child")
          Behaviors.same
      })
  }
}

object ChildActor {
  sealed trait Command
  case class Work() extends Command
  
  // inject the parent here (or any other actor that matches the signature)
  def apply(parent: ActorRef[ParentActor.ChildNotification]): Behavior[Command] = {
     Behaviors.receive( (context, message) => 
       message match {
         case Work() =>
           // send message to parent actor (or any other actor with that type)
           parent ! ParentActor.MessageFromChild()
           Behaviors.same

     })
  }
}

顺便说一下，我使用的是akka类型的“函数”语法，但您也可以使用更“面向对象”的语法。它遵循同样的方法。

Answer 2

如果您使用的是类型化的Akka，那么可以包含所有可能的父执行元的actorref的唯一[Scala]类型是actorref[Nothing]，这是一个您不能向其发送消息的actorref，因此它的效用有限。

至少在经典API存在的时间内：

import akka.actor.typed.scaladsl.adapter._

type ClassicActorRef = akka.actor.ActorRef

val parentActorRef = context.toClassic.parent

这将是一个非类型化的actorref，即您可以自由地发送父执行元永远不会接受的消息。

如果您想要对执行元的父级的类型化引用，则需要在生成子执行元时嵌入该引用，就像如果您想要对当前消息的发件人的类型化引用，则需要在协议中嵌入replytos一样。

(Context.Sender在键入的ActorContext中不存在，原因与Context.Parent不存在相同；复制经典Context.Sender的解决办法类似:Context.ToClassic.Sender)