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

如何响应演员呼吁的结果?,第1张

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

这可以通过结合使用

onComplete
指令和Ask模式来实现。

在下面的示例中,

RequestHandlerActor
actor用于创建
HttpResponse
基于的
HttpRequest
。从路线内询问此演员。

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

import scala.concurrent.duration._import akka.actor.ActorSystemimport akka.http.scaladsl.model.HttpResponseimport akka.http.scaladsl.model.HttpRequestimport akka.actor.Actorimport akka.http.scaladsl.server.Directives._import akka.actor.Propsimport akka.pattern.askimport akka.util.Timeoutimport scala.util.{Success, Failure}import akka.http.scaladsl.model.StatusCodes.InternalServerErrorclass 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一样使用此路由传递给方法。



欢迎分享,转载请注明来源:内存溢出

原文地址: https://outofmemory.cn/zaji/5430619.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-11
下一篇 2022-12-11

发表评论

登录后才能评论

评论列表(0条)

保存