Akka HTTP 设置响应 header 基于 Future 的结果

Question

我正在使用 Akka-HTTP 2.0-M2 设计 REST 服务，遇到过这样一种情况，我想提供额外的 headers，这取决于查询的回复演员.

目前，我有以下...

val route = {
  path("oncologist") {
    get {
      parameters('active.as[Boolean].?, 'skip.as[Int].?, 'limit.as[Int].?).as(GetAllOncologists) {
        req =>
          complete {
            (oncologistActor ? req).mapTo[OncologistList]
          }
      }
    }
  }

虽然这会毫无问题地返回。我想将 OncologistList 的一些属性移动到响应 header 中，而不是在 body 中返回它们。也就是说，我要返回总记录数和偏移量，并且我想生成一个上一个和下一个 URL header 值供客户端使用。我不知道如何继续。

Answer 1

我认为您可以使用 onComplete 和 respondWithHeaders 指令来完成您想要的。 onComplete 指令与 Future 的结果一起工作，这正是 ask (?) 将 return 的结果。这是一个使用案例 class 的示例，如下所示：

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 )
    }
  }
}

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

Akka HTTP 设置响应 header 基于 Future 的结果

Akka HTTP set response header based on result of Future

rest

scala

akka

akka-http