Scala akka HttpResponse 以字符串形式读取响应体

在本文中，我们将介绍如何使用 Scala 和 akka-http 库来发送 HTTP 请求，并将 HTTP 响应的内容以字符串的形式读取出来。

阅读更多：Scala 教程

akka-http 简介

akka-http 是一个基于 akka actor 模型的高性能 HTTP 客户端和服务器端框架。它提供了一种简单而强大的方式来处理 HTTP 请求和响应，并且具有优秀的性能和可扩展性。

发送 HTTP 请求

首先，我们需要在 Scala 项目中添加 akka-http 的依赖。可以在 build.sbt 文件中添加以下代码：

libraryDependencies += "com.typesafe.akka" %% "akka-http" % "<akka-http-version>"

其中，<akka-http-version> 是 akka-http 的版本号。然后，我们可以在 Scala 代码中导入相关的依赖：

import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.http.scaladsl.Http
import akka.http.scaladsl.model.{HttpMethods, HttpRequest, HttpResponse}

接下来，我们可以创建一个 ActorSystem 和一个 ActorMaterializer，这是使用 akka-http 的前提：

implicit val system: ActorSystem = ActorSystem("my-system")
implicit val materializer: ActorMaterializer = ActorMaterializer()

然后，我们可以使用 akka-http 发送一个简单的 GET 请求：

val request = HttpRequest(
  method = HttpMethods.GET,
  uri = "https://api.example.com/users"
)

val responseFuture: Future[HttpResponse] = Http().singleRequest(request)

在上述代码中，我们创建了一个 HttpRequest 对象，指定了请求的方法和 URI。然后，我们使用 Http().singleRequest 方法发送请求，并得到一个 Future 对象，该对象在异步操作完成后会包含 HTTP 响应。

读取响应体

一旦获取到 HttpResponse 对象，我们可以使用 entity 方法来读取响应体。akka-http 提供了多种方式来读取响应体，例如将其转换为字符串、字节数组或流。

下面是一个例子，演示如何将响应体以字符串的形式读取出来：

import akka.http.scaladsl.unmarshalling.Unmarshal

// 必须导入这个隐式对象，以便可以正确地解析响应体
import akka.http.scaladsl.unmarshalling.PredefinedFromEntityUnmarshallers._
import akka.util.ByteString

def readEntityAsString(response: HttpResponse): Future[String] = {
  response.entity.dataBytes.runFold(ByteString.empty)(_ ++ _).map(_.utf8String)
}

// 使用上述方法来读取响应体
responseFuture.flatMap(readEntityAsString).onComplete {
  case Success(body) =>
    println(s"Response body:  $body") case Failure(ex) => println(s"Request failed:$ {ex.getMessage}")
}

在上述代码中，我们通过 response.entity.dataBytes 获取到一个流(Stream)对象，并使用 runFold 方法将流中的所有字节串联起来。然后，我们可以将字节流通过 .utf8String 转换为字符串。