Akka-Http客户端：如何从http响应中获取二进制数据？

我打电话给一个API来获得一个zip文件响应。该API正确响应，但我无法从响应得到字节数组，因为未来应该完成获得ByteString永远不会完成：Akka-Http客户端：如何从http响应中获取二进制数据？

val authorization = akka.http.javadsl.model.headers.Authorization.basic("xxxxx", "xxxxxx") 
    val query = Map("fed" -> "xxxx", "trd" -> "yyy", "id" -> "zzz") 
    val request = HttpRequest(HttpMethods.GET, Uri("https://xxxx.yyyy.com/ggg/ttt.php").withQuery(Query(params = query))).addHeader(authorization) 
    val responseFut = http.singleRequest(request) 
    responseFut1.map(response => { 
    println("*******************************") 
    println(response) 
    response.status match { 
     case akka.http.javadsl.model.StatusCodes.OK => { 
     println("^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^" + response._3) 
     val entityFut = response.entity.toStrict(60.seconds) 
     val byteStringFut = entityFut.flatMap(entity => { 
      entity.dataBytes.runFold(ByteString.empty)(_ ++ _) 
     }) 
     println("@@@@@@@@@@@@@@@@@@@@@@@@@@@@@") 
     try { 
      byteStringFut.map(x => { 
      //this never prints =======================================problem  
      println("----------------------------" + x.toArray[Byte]) 
      }) 
     }catch{ 
      case e: Exception => println("Error: " + e) 
     } 
     } 
     case _ => {} 
    } 
    })

如果我打印出来的response这是什么样子：

******************************* 
HttpResponse(200 OK,List(Date: Fri, 08 Sep 2017 20:58:43 GMT, Server: Apache/2.4.18 (Ubuntu), Content-Disposition: attachment; filename="xxxxx.zip", Pragma: public, Cache-Contr 
ol: public, must-revalidate, Content-Transfer-Encoding: binary),HttpEntity.Chunked(application/x-zip),HttpProtocol(HTTP/1.1)) 
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^HttpEntity.Chunked(application/x-zip) 
@@@@@@@@@@@@@@@@@@@@@@@@@@@@@

因此，响应恢复正常，但仍无法获取zip文件的二进制数据。

我们在其他地方使用akka-http来调用返回json响应的API，这种方法似乎在那里工作得很好。为什么不在这里工作？我究竟做错了什么？

任何意见表示赞赏。谢谢。

更新

添加byteStringFut.failed.foreach(println(_))显示此异常：akka.http.scaladsl.model.EntityStreamException: HTTP chunk size exceeds the configured limit of 1048576 bytes

来源

2017-09-08 An Illusion

1.确保匹配成功。 2.如果是这样，但未来从未完成，那么尝试检查是否没有抛出任何异常。 'byteStringFut.failed.foreach（println）' 为什么你匹配'response._1'而不是'response.status'或类似的东西？ – michaJlS

@michaJlS：我添加了更多的printlns和try-catch来查看错误。匹配工作正常。没有错误可见。至于我为什么使用response._1：除了我不知道response.status存在之外，没有其他原因。 –

Try ... catch在这里没有用。你可以看看Future是否失败，或者使用上面提供的代码片断。它可能会更早。 – michaJlS

它看起来像出了问题，一个例外是在异步计算抛出。您可以通过以下方式检查Future来检查例外情况：

byteStringFut.failed.foreach(println)

来源

2017-09-09 08:40:28 michaJlS

Akka-Http客户端：如何从http响应中获取二进制数据？

回答

相关问题