Akka-Http：如何测试请求

Question

我有一个请求，其响应取决于参与者的回复。我正在尝试以这种方式对其进行测试：

val myActor:TestProbe = TestProbe()

val route = new MyRoute() {
    override def myServiceActor:ActorRef = {
        myActor.ref
    }
}.route

"return a query result for GET" in {
    Get("/foo") ~> route ~> check {
        myActor.expectMsg(ExecuteFoo())
        myActor.reply(FOO)
        responseEntity shouldEqual toJsonEntity(RequestResult(FOO))
    }
}

我正确地知道 expectMsg 已验证，但 reply 与 responseEntity 检查是异步的。在这种情况下，测试失败。

有什么方法可以等待回复吗？

Answer 1

执行此操作的一种方法（可能不是正确的或唯一的方法）是使用 AutoPilot。这是一个例子：

val myProbe = TestProbe()
myProbe.setAutoPilot(new TestActor.AutoPilot {
  def run(sender: ActorRef, msg: Any) = msg match {
    case ExecuteFoo(_) =>
      //do something else if needed
      sender ! FOO
      TestActor.NoAutoPilot
  }
})

Answer 2

您使用 TestProbe 的方法是正确的。关键是将运行请求和检查请求的组合（您正在通过 check 作为第一步执行）分成两个明确的步骤。首先运行它，然后对 TestProbe 进行任何存根处理，最后进行检查。您的示例的更新代码如下所示：

  val result = Get("/foo") ~> route ~> runRoute
  myActor.expectMsg(ExecuteFoo())
  myActor.reply(FOO)

  check {
      responseEntity shouldEqual toJsonEntity(RequestResult(FOO))
  }(result)

你可以看到我首先使用 runRoute 来简化运行路线而不执行任何检查。我将此值分配给 result，因为稍后我将需要它来执行任何检查。然后，您可以安全地对 TestProbe 进行存根。此时，它已经收到消息，正在等待您的电话来验证它收到了什么消息以及如何响应。然后，完成后，我们可以调用 check，将显式结果（来自 runRoute 的结果）传递给该调用，而不是依赖于隐式。

如果您采用这种方法，您应该能够使用 TestProbe 正确测试调用 actor 的路由。

Akka-Http：如何测试请求

Akka-Http: How to TestProbe a request

unit-testing

scala

akka

akka-http