2

我正在使用 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]
          }
      }
    }
  }

虽然这返回没有问题。我想将 OncologistList 的一些属性移动到响应标头中，而不是在正文中返回它们。即，我正在返回总记录数和偏移量，并且我想生成前一个和下一个 URL 标头值以供客户端使用。我不知道如何进行。

4

1 回答 1

7

我认为你可以使用onCompleteandrespondWithHeaders指令来完成你想要的。该onComplete指令与 a 的结果一起工作，Future这正是ask (?)将返回的结果。这是一个使用案例类的示例，如下所示：

case class Foo(id:Int, name:String)

一个简单的路线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 )
    }
  }
}

因此，如果我们从一开始就获得了成功的结果，ask我们oncologistActor就可以利用respondWithHeaders向响应添加一些自定义标头。希望这就是你要找的。

于 2015-12-30T21:20:48.023 回答