如何测试在运行时产生子角色的Akka actor？

Question

在我的另一个问题之后，我有一个UDP服务器参与者，如下所示：

class Listener(addr: InetSocketAddress) extends Actor {
  import context.system
  IO(Udp) ! Udp.Bind(self, addr)

  def spawnChild(remote): ActorRef = {
    //Check if child already exist
    context.actorOf(Props[Worker])
  }

  def receive = {
    case Udp.Bound(local) =>
      context.become(ready(sender()))
  }

  def ready(socket: ActorRef): Receive = {
    case Udp.Received(data, remote) =>
      val worker = spawnChild(remote)
      worker ! data // forward data directly to child
    case Udp.Unbind  => socket ! Udp.Unbind
    case Udp.Unbound => context.stop(self)
  }
}

我正在根据数据从何处发送来创建子角色。这样做的原因是子参与者保持一些内部状态。内部状态包括上次连接时间、发送的数据包总数等

我想设置TestProbe来测试它

• 来自remoteA的数据被转发到TestProbeA
• 来自remoteB的数据被转发到TestProbeB
• 来自remoteA的数据不会转发到TestProbeB

我已经阅读了使用多个探针的部分。然而，在我的情况下，是父母演员负责创造孩子。

在这种情况下，我应该如何编写规范？或者，我应该如何重构代码以使其更易于测试？

Answer 1

akka文档中有一节概述了可以实现的几种方法：测试父子关系

在工作中，我们已经成功地使用了从父级外部化子级制作中解释的方法。在实践中，这意味着您的父参与者在初始化时（或通过消息）接受“子工厂”参数。

在测试代码中，您可以提供一个“假”工厂，它将返回一个测试探针，而不是一个纯粹的参与者。