Akka Http - 如何解开ResponseEntity到CustomClass？

我正在使用Akka Http向第三方API发出请求。答案是“application/json”，我想使用Akka Http将它们转换为自定义案例类。我愿做这样的事情：Akka Http - 如何解开ResponseEntity到CustomClass？

val request = RequestBuilding.Get("https://service.com/v1/api/items") 

val response : Future[ItemsResponse] = http.singleRequest(request).flatMap({ response => 
    Unmarshal(response.entity).to[ItemsResponse] 
})

这编译失败，因为我缺少类型akka.http.scaladsl.unmarshalling.Unmarshaller的”隐式解组[akka.http.scaladsl.model.ResponseEntity ，com.mycompany.models.ItemsResponse]“

目前还不清楚这是什么与akka http做这种惯用的方式是。我知道我可以使用spray-json，但我想了解如何在不导入其他库的情况下执行此操作。 Akka Http似乎有可能，但文档不清楚（至少对我而言）。

来源

2017-01-30 Johan Anders

最简单的方法是使用喷雾JSON作为它作为阿卡HTTP的一部分：

import spray.json._ 
import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport 

// change 2 to the number of attributes of ItemsResponse 
implicit val ItemsResponseFormat = jsonFormat2(ItemsResponse)

这应该使你的现有代码的编译。

来源

2017-01-30 07:02:36 Sebastian

谢谢！我没有意识到spray-json现在是akka图书馆的一部分。这个伎俩。 –

它实际上并不是作为akka-http的一部分，我认为Johan的问题非常有效。虽然akka-http-spray-json是akka-http的一部分，但底层的spray.json仍然需要单独提供。我认为。 https://doc.akka.io/docs/akka-http/current/common/json-support.html – akauppi

我认为你的问题是有效的，有些情况下避免额外的依赖是有意义的。我从创建一个认证库，在那里我不想强制我的JSON库偏好给这样的库的用户。该库需要使用JSON解组来理解令牌信息响应。

给代码！ :)

case class TokenInfo private (uid: String, realm: String, scope: Seq[String]) 

object TokenInfo { 
    private 
    def parseOpt(s: String): Option[TokenInfo] = { 

    util.parsing.json.JSON.parseFull(s) match { 
     case Some(map: Map[String,Any] @unchecked) => 

     val tmp: Map[String,Any] = map.collect { 
      case ([email protected] "uid",x: String) => k -> x 
      case ([email protected] "realm",x: String) => k -> x 
      case ([email protected] "scope",x: Seq[String] @unchecked) => k -> x 
      // other keys are ignored 
     }.toMap 

     if (tmp.size == 3) { 
      Some(TokenInfo(tmp("uid").asInstanceOf[String], tmp("realm").asInstanceOf[String], tmp("scope").asInstanceOf[Seq[String]])) 
     } else { 
      None 
     } 

     case _ => None 
    } 
    } 

    implicit 
    val unm: FromEntityUnmarshaller[TokenInfo] = { 
    PredefinedFromEntityUnmarshallers.stringUnmarshaller.map{ s => parseOpt(s).getOrElse{ 
     throw new RuntimeException(s"Unknown TokenInfo: $s") 
    }} 
    } 
}

我选择使用util.parsing.json它属于斯卡拉。另一种选择只是正则表达式的，但在这种情况下，我要么修复预期的字段顺序，要么代码可能变得复杂。

来源

2018-01-03 17:56:14 akauppi

Akka Http - 如何解开ResponseEntity到CustomClass？

回答

相关问题