Scala 使用 Akka Http 的 Json Support 和 Xml Support

在本文中，我们将介绍如何在 Scala 中使用 Akka Http 的 Json Support 和 Xml Support。Akka Http 是一个非常流行的 Scala 库，可用于构建高性能的 HTTP 服务器和客户端应用程序。它提供了许多功能强大的功能，包括对 JSON 和 XML 的支持。

阅读更多：Scala 教程

Json Support

Akka Http 的 Json Support 提供了一种简便的方式来处理 JSON 数据。它使用了 Spray Json 库，该库提供了许多方便的方法来解析和生成 JSON 数据。

首先，我们需要添加 Akka Http 和 Spray Json 的依赖。在 build.sbt 文件中添加以下代码：

libraryDependencies ++= Seq(
  "com.typesafe.akka" %% "akka-http" % "10.2.6",
  "com.typesafe.akka" %% "akka-http-spray-json" % "10.2.6"
)

接下来，我们需要导入必要的类和方法：

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.server.Directives._
import akka.http.scaladsl.server.Route
import akka.stream.ActorMaterializer
import spray.json.DefaultJsonProtocol._

定义一个简单的 case class 来表示我们的数据模型：

case class Person(name: String, age: Int)

然后，我们可以使用 Spray Json 的 jsonFormat 方法来自动生成 JSON 的读写器：

implicit val personFormat = jsonFormat2(Person)

现在，我们可以开始构建路由：

val route: Route =
  path("person") {
    get {
      complete {
        val person = Person("John", 30)
        person
      }
    } ~
    post {
      entity(as[Person]) { person =>
        complete {
          "Person created: " + person.name
        }
      }
    }
  }

在这个例子中，我们定义了一个名为 /person 的路由，其中包含了两个路径：GET /person 用于获取一个人的信息，POST /person 用于创建一个新的人物。

启动服务并监听指定端口：

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

val bindingFuture = Http().bindAndHandle(route, "localhost", 8080)

println("Server online at http://localhost:8080/")

现在我们可以使用任何 HTTP 客户端工具来测试我们的服务。

Xml Support

Akka Http 的 Xml Support 提供了类似的方式来处理 XML 数据。它使用了 Scala 的 xml.XML 库来解析和生成 XML。

首先，我们需要添加 Akka Http 的 Xml Support 依赖。在 build.sbt 文件中添加以下代码：

libraryDependencies += "com.typesafe.akka" %% "akka-http-xml" % "10.2.6"

接下来，我们需要导入必要的类和方法：

import akka.http.scaladsl.model.ContentTypes
import akka.http.scaladsl.marshalling.Marshal
import akka.http.scaladsl.marshalling.ToResponseMarshallable
import akka.http.scaladsl.unmarshalling.Unmarshal
import scala.xml.NodeSeq

定义一个简单的 XML 数据：

val xmlData: NodeSeq =
  <person>
    <name>John</name>
    <age>30</age>
  </person>

使用 Marshal 方法来将 XML 转换为 HTTP 实体：

val entity = Marshal(xmlData).to[Message.Entity]

使用 Unmarshal 方法来将 HTTP 实体转换为 XML：

val xml = Unmarshal(entity).to[NodeSeq]

与 Json Support 类似，我们可以根据需要在路由中使用 XML 数据。

总结

本文介绍了如何在 Scala 中使用 Akka Http 的 Json Support 和 Xml Support。我们学习了如何配置依赖，定义数据模型，构建路由，并使用 JSON 和 XML 数据进行交互。Akka Http 提供了一种简单而强大的方式来处理 Web 服务中的数据。希望本文对您有所帮助！