如何处理响应超时？

在 akka-http 路由中我可以返回Future作为隐式转换为的响应ToResponseMarshaller.

有什么方法可以处理这个未来的超时吗？或者路由级别的连接超时？或者一种方法是使用Await()功能？

现在客户可以永远等待响应。

complete {
   val future = for {
     response <- someIOFunc()
     entity <- someOtherFunc()
   } yield entity
   future.onComplete({
     case Success(result) =>
       HttpResponse(entity = HttpEntity(MediaTypes.`text/xml`, result))
     case Failure(result) =>
       HttpResponse(entity = utils.getFault("fault"))
   })
   future
 }

向异步操作添加超时意味着创建一个由操作本身或超时完成的新 Future：

import akka.pattern.after
val future = ...
val futureWithTimeout = Future.firstCompletedOf(
    future ::
    after(1.second, system.scheduler)(Future.failed(new TimeoutException)) ::
    Nil
  )

第二个 Future 也可以保存一个成功的结果来替换错误，具体取决于您想要建模的具体内容。

附带说明：所提供的代码示例包含死代码，在 Future 上注册 onComplete 处理程序仅对副作用有意义，但您似乎想要转换 Future 的值并从中创建 HttpEntity。这应该使用完成map and recover:

future
  .map(result => HttpResponse(entity = HttpEntity(MediaTypes.`text/xml`, result)))
  .recover { case ex => HttpResponse(entity = utils.getFault("fault")) }

这将是传递给的总体返回值complete指示。