如何用行为接收信息处理生命周期信号

Question

我有一个演员，创建如下：

    Behaviors.setup { context =>
          val greeter = context.spawn(HelloWorld.greeter, "greeter")

          Behaviors.receiveMessage { message =>
            val replyTo = context.spawn(HelloWorldBot.bot(greetingCounter = 0, max = 3), message.name)
            greeter ! HelloWorld.Greet(message.name, replyTo)
            Behaviors.same
          }
        }

我希望在Behaviors.receiveMessage中处理信号消息（例如PostStop)，并在文档中表示：

只有一个参数的Receive的简化版本--要处理的消息。当上下文已经可以通过其他方式访问时，如包装在设置中或类似的方式，这很有用。构造一个能够对传入消息和生命周期信号做出反应的参与者行为。从另一个actor（或者作为Akka.actor.typed.actorSystem的监护人）生成这个actor之后，它将在ActorContext中执行，该ActorContext允许访问系统、生成和监视其他actor等。处理下一个消息会导致可能与此消息不同的新行为。状态是通过返回一个新的行为来维护的，该行为持有新的不可变状态。

但是如何在Behaviors.ReceiveMessage中实现生命周期信号呢？

以下是指向文档https://doc.akka.io/api/akka/current/akka/actor/typed/scaladsl/achaviors$.html#receiveMessaget:akka.actor.typed.scaladsl.Behaviors.receive[T]

Answer 1

因为ReceiveMessage[A]只能在符合类型A的消息上进行匹配，并且您无法声明包含PostStop等系统消息的类型A。相反，Akka-Typed有一个专用的ReceiveSignal。

在您的示例中，您已经通过behavior.setup捕获了共享上下文，您可以将Receivesignal链接到消息行为中，作为相同行为的一部分：

Behaviors.setup { context =>
      val greeter = context.spawn(HelloWorld.greeter, "greeter")

      Behaviors.receiveMessage { message =>
        val replyTo = context.spawn(HelloWorldBot.bot(greetingCounter = 0, max = 3), message.name)
        greeter ! HelloWorld.Greet(message.name, replyTo)
        Behaviors.same
      }.receiveSignal {
         case (context, PostStop) =>
           context.log.info("behavior stopped")
           Behaviors.same
    }