Spray-Json：如何解析Json数组？

Question

我是 Spray-Json API 的新手，尝试解析来自 Docker REST API 的 Json 响应。

这里有一个干净的示例，展示了如何使用 Spray-Json 解析 Google Map 的 Json 响应：

{
   "results" : [
      {
         "elevation" : 8815.7158203125,
         "location" : {
            "lat" : 27.988056,
            "lng" : 86.92527800000001
         },
         "resolution" : 152.7032318115234
      }
   ],
   "status" : "OK"
}

在上面的示例中，最外层是一个 Object。但我需要直接解析一个 Json 响应，其最外层是由容器信息组成的 Array，如下所示：

[
     {
       "Id": "8dfafdbc3a40",
       "Image": "base:latest",
       "Command": "echo 1",
       "Created": 1367854155,
       "Status": "Exit 0",
       "Ports":[{"PrivatePort": 2222, "PublicPort": 3333, "Type": "tcp"}],
       "SizeRw":12288,
       "SizeRootFs":0
     },
     { ... },
     { ... }
]

这里有一段代码，我是从Google地图示例中调整出来的：

package main

import ...

case class Container(id: String, image: String, command: String, created: Long, status: String, ports: List[Port], sizeRW: Long, sizeRootFs: Long)
case class Port(privatePort: Long, publicPort: Long, portType: String)
case class DockerApiResult[T](results: List[T])

object ContainerListJsonProtocol extends DefaultJsonProtocol {
  implicit val portFormat = jsonFormat3(Port)
  implicit val containerFormat = jsonFormat8(Container)
  implicit def dockerApiResultFormat[T :JsonFormat] = jsonFormat1(DockerApiResult.apply[T])
}

object Main extends App {

  implicit val system = ActorSystem("simple-spray-client")
  import system.dispatcher // execution context for futures below
  val log = Logging(system, getClass)

  log.info("Requesting containers info...")

  import ContainerListJsonProtocol._
  import SprayJsonSupport._
  val pipeline = sendReceive ~> unmarshal[DockerApiResult[Container]]

  val responseFuture = pipeline {
    Get("http://<ip-address>:4243/containers/json")
  }

  responseFuture onComplete {
    case Success(DockerApiResult(Container(_,_,_,_,_,_,_,_) :: _)) =>
      log.info("Id of the found image: {} ")
      shutdown()

    case Success(somethingUnexpected) =>
      log.warning("The Docker API call was successful but returned something unexpected: '{}'.", somethingUnexpected)
      shutdown()

    case Failure(error) =>
      log.error(error, "Couldn't get containers information")
      shutdown()
  }

  def shutdown(): Unit = {
    IO(Http).ask(Http.CloseAll)(1.second).await
    system.shutdown()
  }
}

以下是我遇到的异常（对象未定义）：

spray.httpx.PipelineException: MalformedContent(Object expected,Some(spray.json.DeserializationException: Object expected))

我肯定错过了一些显而易见的东西，但是如何使用Spray-Json解析Json数组呢？

此外，有没有简单的方法可以不必处理自定义的JsonFormat或RootJsonFormat来完成这个操作？

- abronan

---

个人而言，我会转向使用 Lift-json :) - Ben Schmidt

Answer 1

通过执行unmarshal[DockerApiResult[Container]]，您告诉spray-json，您期望的格式是一个形如json对象的格式：

{ results: [...] }

由于case class DockerApiResult[T](results: List[T])被定义为一个只包含列表字段的对象。

因此你需要这样做：

unmarshal[List[Container]]

然后直接对结果列表进行操作（或在被spray-json解析后将其包装在DockerApiResult中）。

如果您想让spray-json直接解组成DockerApiResult，可以编写类似以下内容的JsonFormat：

implicit object DockerApiResultFormat extends RootJsonFormat[DockerApiResult] {
  def read(value: JsValue) = DockerApiResult(value.convertTo[List[Container]])
  def write(obj: DockerApiResult) = obj.results.toJson
}

- kong

---

谢谢！它起作用了。我实际上尝试使用unmarshal[List[Container]]，但是我对端口属性为null感到困惑，所以我不得不用Option进行包装。无论如何，非常好的答案，正是我在寻找的 ;) - abronan

Answer 2

我曾经遇到过这个问题，并找到了一种使用spray将json解析字符串转换为JsArray的方法：

import spray.json._   //parseJson
val kkkk =
  """
    |[{"a": "1"}, {"b": "2"}]
  """.stripMargin.parseJson.asInstanceOf[JsArray]

- Marco Aurelio

---

这会保持元素的顺序吗？ - Manali Bhosale