Future在获取akkahttp响应时超时

Question

m是Futures概念的新手，当我试图检索HTTPResponse时，我得到了一个Future超时异常。

val responseFuture: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = sampleUrl).withHeaders(Authorization(validCredentials)))
val timeout = 2.seconds
responseFuture.flatMap { resp => resp.entity.toStrict(timeout) }.map { strictEntity => strictEntity.data.utf8String }

当我检查日志时，它在托管它并崩溃的集群上按预期工作一段时间。它说Future在2秒钟后超时。我该如何更正？

Answer 1

您的sampleUrl似乎在2秒内没有持续响应。默认情况下，HTTP客户端最多要等待60秒才能收到响应。也许，您可以将类似行上的Future超时设置为60秒。