6

我正在写一个函数：

1) 发送 HTTP GET 请求（响应是一个有效的 JSON）

2）解析对json对象的响应

代码片段：

val page = url("http://graph.facebook.com/9098498615")
val response = Http(page OK dispatch.as.String)
Await.result(response , 10 seconds)
val myJson= JSON.parseFull(response .toString)
//this isnt helping -> val myJson= JSON.parseRaw(response .toString)

问题是在这个myJson是None之后，我希望它保存响应中的 json 数据。

帮助 ？

4

3 回答 3

16

Dispatch 包括一些非常好的（并且宣传不足）的解析 JSON 的工具，您可以像这样使用它们（请注意，您可以使用任何标准方法来处理非 200 响应来处理失败的期货）：

import dispatch._
import org.json4s._, org.json4s.native.JsonMethods._
import scala.concurrent.ExecutionContext.Implicits.global
import scala.util.{ Failure, Success }

val page = url("http://graph.facebook.com/9098498615")
val response = Http(page OK dispatch.as.json4s.Json)

response onComplete {
  case Success(json) => println(json \ "likes")
  case Failure(error) => println(error)
}

此示例使用Json4s 库，并且为Lift JSON提供了类似的支持（但不幸的是Argonaut没有，虽然自己编写这样的东西并不难）。

于 2013-11-11T11:49:06.573 回答
7

这不是一个好主意，Http(page OK as.String)因为所有不同于 HTTP 200 的响应都会导致 Futures 失败。如果您需要对错误处理/报告进行更细粒度的控制，请改为针对特定场景。

import org.jboss.netty.handler.codec.http.{ HttpRequest, HttpResponse, HttpResponseStatus }
def getFacebookGraphData: Either[Exception, String] = {
  val page = url("http://graph.facebook.com/9098498615")
  val request = Http(page.GET);
  val response = Await.result(request, 10 seconds);
  (response.getStatusCode: @annotation.switch) match {
    case HttpResponseStatus.OK => {
      val body = response.getResponseBody() // dispatch adds this method
      // if it's not available, then:
      val body = new String(response.getContent.array);
      Right(body)
    }
    // If something went wrong, you now have an exception with a message.
    case _ => Left(new Exception(new String(response.getContent.array)));
  }
}

默认的 Scala JSON 库也不是一个好主意，与其他库相比它非常粗糙。例如尝试lift-json。

import net.liftweb.json.{ JSONParser, MappingException, ParseException };

case class FacebookGraphResponse(name: String, id: String);// etc
implicit val formats = net.liftweb.DefaultFormats;
val graphResponse = JSONParser.parse(body).extract[FacebookGraphResponse];
// or the better thing, you can catch Mapping and ParseExceptions.
于 2013-11-11T11:22:55.190 回答
1

你也可以像这样使用你自己喜欢的 json-library（例如 play-framework-json-lib）：

val response = Http(requestUrl OK CarJsonDeserializer)

您只需通过 JsonDeserializer 扩展 (Response => Car) 特征。

object CarJsonDeserializer extends (Response => Car) {
  override def apply(r: Response): Car = {
    (dispatch.as.String andThen (jsonString => parse(jsonString)))(r)
  }
}

和 json 解析器：

implicit val carReader: Reads[Car] = (
  (JsPath \ "color").read[String] and
  (JsPath \ "model").read[String]
)(Monitor.apply _)

private def parse(jsonString: String) = {
  val jsonJsValue = Json.parse(jsonString)
  jsonJsValue.as[Car]
}

请参阅此博客文章：https ://habashics.wordpress.com/2014/11/28/parsing-json-play-lib-with-dispatch/

于 2014-11-28T11:36:48.450 回答