cor*_*ota 2 rest scala akka akka-http
我正在使用Akka-HTTP 2.0-M2设计REST服务,并且遇到了我想要提供额外标头的情况,这些标头取决于所查询的Actor的回复.
目前,我有以下......
val route = {
path("oncologist") {
get {
parameters('active.as[Boolean].?, 'skip.as[Int].?, 'limit.as[Int].?).as(GetAllOncologists) {
req =>
complete {
(oncologistActor ? req).mapTo[OncologistList]
}
}
}
}
Run Code Online (Sandbox Code Playgroud)
虽然这是没有问题的回归.我想将OncologistList的一些属性移动到响应头中,而不是将它们返回到正文中.也就是说,我正在返回总记录数和偏移量,我想生成一个上一个和下一个URL头值供客户端使用.我对如何进行感到茫然.
我认为你可以使用onComplete和respondWithHeaders指令来完成你想要的.该onComplete指令使用a的结果,Future这正是ask (?)将返回的结果.以下是使用case类的示例:
case class Foo(id:Int, name:String)
Run Code Online (Sandbox Code Playgroud)
一个简单的路线显示onComplete如下:
get{
parameters('active.as[Boolean].?, 'skip.as[Int].?, 'limit.as[Int].?).as(GetAllOncologists) { req =>
val fut = (oncologistActor ? req).mapTo[Foo]
onComplete(fut){
case util.Success(f) =>
val headers = List(
RawHeader("X-MyObject-Id", f.id.toString),
RawHeader("X-MyObject-Name", f.name)
)
respondWithHeaders(headers){
complete(StatusCodes.OK)
}
case util.Failure(ex) =>
complete(StatusCodes.InternalServerError )
}
}
}
Run Code Online (Sandbox Code Playgroud)
因此,如果我们从askon 获得了成功的结果,那么oncologistActor我们可以利用它respondWithHeaders来为响应添加一些自定义标头.希望这是你想要的.
| 归档时间: |
|
| 查看次数: |
2875 次 |
| 最近记录: |