如何响应演员呼吁的结果？

Question

我们正在研究使用Akka-HTTP Java API-使用路由DSL。

目前尚不清楚如何使用路由功能来响应HttpRequest。使用无类型Akka演员。例如，在匹配Route路径后，我们如何将请求传递给“ handler”
ActorRef，该ActorRef随后将以异步方式通过HttpResponse进行响应？

类似的问题被张贴阿卡用户的邮件列表上，但没有后续的解决方案，例如- https://groups.google.com/d/msg/akka-
user/qHe3Ko7EVvg/KC-aKz_o5aoJ
。

Answer 1

这可以通过结合使用onComplete指令和Ask模式来实现。

在下面的示例中，RequestHandlerActoractor用于创建HttpResponse基于的HttpRequest。从路线内询问此演员。

我从来没有使用Java来路由代码，所以我的回应是在Scala中。

import scala.concurrent.duration._
import akka.actor.ActorSystem
import akka.http.scaladsl.model.HttpResponse
import akka.http.scaladsl.model.HttpRequest
import akka.actor.Actor
import akka.http.scaladsl.server.Directives._
import akka.actor.Props
import akka.pattern.ask
import akka.util.Timeout
import scala.util.{Success, Failure}
import akka.http.scaladsl.model.StatusCodes.InternalServerError

class RequestHandlerActor extends Actor {
  override def receive = {
    case httpRequest : HttpRequest =>
      sender() ! HttpResponse(entity = "actor responds nicely")
  }
}

implicit val actorSystem = ActorSystem()
implicit val timeout = Timeout(5 seconds)

val requestRef = actorSystem actorOf Props[RequestHandlerActor]

val route = 
  extractRequest { request =>
    onComplete((requestRef ? request).mapTo[HttpResponse]) {
      case Success(response) => complete(response)
      case Failure(ex) => 
        complete((InternalServerError, s"Actor not playing nice: ${ex.getMessage}"))
    } 
  }

然后，可以bindAndHandle像其他任何Flow一样使用此路由传递给方法。