如何从 Akka HTTP 中的 HttpResponse 获取 JSON 作为字符串数据

Question

我正在使用 Akka HTTP 并希望从 Rest API 获取 JSON 响应。

val responseFuture: Future[HttpResponse] = Http().singleRequest(HttpRequest(uri = uri, headers = List(authorization)))

responseFuture
  .onComplete {
    case Success(res) => {
      val strictEntity: Future[HttpEntity.Strict] = res.entity.toStrict(3.seconds)
      strictEntity.onComplete {
        case Success(se) => {
          se...
        }
        case Failure(sf) => {
          println(sf.getMessage)
        }
      }
    }
    case Failure(f) => {
      println("Error:  "+ f.getMessage)
    }
  }

我最终嵌套了很多 onComplete 回调。这甚至是最简单的方法吗？我应该如何处理se 对象以获取 JSON 作为字符串？

Answer 1

最简单的方法是：

val result: Future[String] = responseFuture.flatMap {
  case HttpResponse(StatusCodes.OK, _, e, _) =>
    Unmarshal(e).to[String]
  case HttpResponse(status, _, e, _) =>
    e.discardBytes() //all entities should be consumed or discarded, so... 
    Future.failed(new InvalidHttpStatus(s"service returned ${status.intValue()}"))
}