scala - Akka HTTP 客户端 EntityStreamSizeException

Question

我尝试使用 Akka HTTP 向本地主机发送 get 请求，但出现以下异常:

EntityStreamSizeException: actual entity size (Some(10166731700)) exceeded content length limit (8388608 bytes)! You can configure this by setting akka.http.[server|client].parsing.max-content-length or calling HttpEntity.withSizeLimit before materializing the dataBytes stream.)

基本上，我尝试请求的本地主机上的文件非常大。

我尝试使用withoutSizeLimit解决这个问题，但它不起作用:

val request = Get("http://localhost:8080/oa-ok.ntriples")
val limitedRequest = request.withEntity(request.entity.withoutSizeLimit())
val responseFuture = Http().singleRequest(limitedRequest)

我也尝试使用withSizeLimit，但没有帮助。有什么想法吗？

Answer 1

在响应实体上使用 withoutSizeLimit，而不是在请求实体上。例如:

val responseFuture: Future[HttpResponse] =
  Http().singleRequest(HttpRequest(uri = "http://localhost:8080/oa-ok.ntriples"))

val responseSource: Source[ByteString, NotUsed] =
  Source.fromFuture(responseFuture)
    .flatMapConcat(_entity.withoutSizeLimit.dataBytes)

responseSource 是响应实体的 Akka Streams Source。