akka-http:找不到参数解组的隐式值
akka-http : could not find implicit value for parameter unmarshalling
我的喷json支持是这样的
object MarshallingSupport extends SprayJsonSupport {
implicit def json4sFormats: Formats = DefaultFormats
}
在我的路线中,我想将请求映射到 dto
object Main extends App with AppConfig with BaseService with MainActorSystem {
val processor = system.actorOf(Props(), "processorActor")
val view = system.actorOf(Props(), "processorActor")
override protected implicit val executor: ExecutionContext = system.dispatcher
override protected val log: LoggingAdapter = Logging(system, getClass)
override protected implicit val materializer: ActorMaterializer = ActorMaterializer()
Http().bindAndHandle(routes(processor, view), httpInterface, httpPort)
}
trait BaseServiceRoute {
protected implicit def executor: ExecutionContext
protected implicit def materializer: ActorMaterializer
protected def log: LoggingAdapter
}
trait MainActorSystem {
implicit val system = ActorSystem("booking")
}
final case class CalculatePriceForRangeDto(unitId: Int, from: Long, to: Long)
trait PriceServiceRoute extends BaseServiceRoute {
implicit val timeout = Timeout(30 seconds)
import com.example.crudapi.utils.MarshallingSupport._
def customersRoute(command: ActorRef, query: ActorRef) = pathPrefix("price") {
post {
path("calculate") {
decodeRequest {
entity(as[CalculatePriceForRangeDto]) {
priceForRange => onComplete((query ? CalculatePriceForRange(
但我得到了
Error:(32, 20) could not find implicit value for parameter um: akka.http.scaladsl.unmarshalling.FromRequestUnmarshaller[com.example.crudapi.http.routes.CalculatePriceForRangeDto]
entity(as[CalculatePriceForRangeDto]) {
^
已查看所有相关的 SO 问题,但没有解决我的问题。奇怪的是我尝试了 Typesafe 模板 akka-dddd-cqrs 并且它可以工作,相同的代码。
我是否遗漏了隐含上下文的内容?
有什么想法吗?
SprayJsonSupport
与 spray-json 一起使用(不适用于 json4s)。因此,您需要按如下方式定义编组器
trait JsonMarshallers extends DefaultJsonProtocol {
implicit val DigestItemWireFormat = jsonFormat6(DigestItemWire.apply)
implicit val LocalDateTimeFormat = new JsonFormat[LocalDateTime] {
private val iso_date_time = DateTimeFormatter.ISO_DATE_TIME
def write(x: LocalDateTime) = JsString(iso_date_time.format(x))
def read(value: JsValue) = value match {
case JsString(x) => LocalDateTime.parse(x, iso_date_time)
case x => throw new RuntimeException(s"Unexpected type %s on parsing of LocalDateTime type".format(x.getClass.getName))
}
}
}
然后在您使用它们的范围内导入 JsonMarshallers._
或将其与 PriceServiceRoute
混合并在文件开头导入 akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport._
。
我的喷json支持是这样的
object MarshallingSupport extends SprayJsonSupport {
implicit def json4sFormats: Formats = DefaultFormats
}
在我的路线中,我想将请求映射到 dto
object Main extends App with AppConfig with BaseService with MainActorSystem {
val processor = system.actorOf(Props(), "processorActor")
val view = system.actorOf(Props(), "processorActor")
override protected implicit val executor: ExecutionContext = system.dispatcher
override protected val log: LoggingAdapter = Logging(system, getClass)
override protected implicit val materializer: ActorMaterializer = ActorMaterializer()
Http().bindAndHandle(routes(processor, view), httpInterface, httpPort)
}
trait BaseServiceRoute {
protected implicit def executor: ExecutionContext
protected implicit def materializer: ActorMaterializer
protected def log: LoggingAdapter
}
trait MainActorSystem {
implicit val system = ActorSystem("booking")
}
final case class CalculatePriceForRangeDto(unitId: Int, from: Long, to: Long)
trait PriceServiceRoute extends BaseServiceRoute {
implicit val timeout = Timeout(30 seconds)
import com.example.crudapi.utils.MarshallingSupport._
def customersRoute(command: ActorRef, query: ActorRef) = pathPrefix("price") {
post {
path("calculate") {
decodeRequest {
entity(as[CalculatePriceForRangeDto]) {
priceForRange => onComplete((query ? CalculatePriceForRange(
但我得到了
Error:(32, 20) could not find implicit value for parameter um: akka.http.scaladsl.unmarshalling.FromRequestUnmarshaller[com.example.crudapi.http.routes.CalculatePriceForRangeDto]
entity(as[CalculatePriceForRangeDto]) {
^
已查看所有相关的 SO 问题,但没有解决我的问题。奇怪的是我尝试了 Typesafe 模板 akka-dddd-cqrs 并且它可以工作,相同的代码。
我是否遗漏了隐含上下文的内容? 有什么想法吗?
SprayJsonSupport
与 spray-json 一起使用(不适用于 json4s)。因此,您需要按如下方式定义编组器
trait JsonMarshallers extends DefaultJsonProtocol {
implicit val DigestItemWireFormat = jsonFormat6(DigestItemWire.apply)
implicit val LocalDateTimeFormat = new JsonFormat[LocalDateTime] {
private val iso_date_time = DateTimeFormatter.ISO_DATE_TIME
def write(x: LocalDateTime) = JsString(iso_date_time.format(x))
def read(value: JsValue) = value match {
case JsString(x) => LocalDateTime.parse(x, iso_date_time)
case x => throw new RuntimeException(s"Unexpected type %s on parsing of LocalDateTime type".format(x.getClass.getName))
}
}
}
然后在您使用它们的范围内导入 JsonMarshallers._
或将其与 PriceServiceRoute
混合并在文件开头导入 akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport._
。