Akka-HTTP：使用Flow完成请求

Question

假设我已经设置了一个任意复杂的Flow [HttpRequest，HttpResponse，Unit]。 我已经可以使用这个流来处理传入的请求。

Http().bindAndHandle(flow, "0.0.0.0", 8080)

现在我想要添加日志记录，利用一些现有的指令，比如logRequestResult("my-service"){...}。是否有一种方法将这个指令与我的流程结合起来？我想我正在寻找另一个指令，类似于...

def completeWithFlow(flow: Flow): Route

这真的可能吗？

N.B.：logRequestResult只是一个例子，我的问题适用于任何您可能发现有用的指令。

- Stefano Bonetti

---

为什么日志记录必须由指令提供？为什么不能只使用Flow.log？ - Ramón J Romero y Vigil

是的，我可以在这个特定的例子中使用Flow.log。我的问题有点更通用，比如说：如果我有一个可重用的指令，我想要利用它，那么我该怎么做呢？比如说，我想要利用下面的指令来处理 .favicon 请求：path("favicon.ico") { getFromResource("favicon.ico", image/x-icon) }我希望能够将这个指令与我的流程结合起来使用，例如使用我的流程来服务于一个特定的路径，并使用上述指令来服务于 /favicon。 - Stefano Bonetti

Answer 1

原来唯一的方法是连接并实现一个新的流程，并将提取的请求传送给它。下面是示例。

  val myFlow: Flow[HttpRequest, HttpResponse, NotUsed] = ???

  val route =
    get {
      logRequestResult("my-service") {
        extract(_.request) { req ⇒
          val futureResponse = Source.single(req).via(myFlow).runWith(Sink.head)
          complete(futureResponse)
        }
      }
    }

  Http().bindAndHandle(route, "127.0.0.1", 9000)

- Stefano Bonetti

---

这在2019年仍然是现状吗？ - shay__

Answer 2

http://doc.akka.io/docs/akka/2.4.2/scala/http/routing-dsl/overview.html

你正在寻找 route2HandlerFlow 或者 Route.handlerFlow 吗？

我认为 Route.handlerFlow 基于 implicit 可以工作。

例如 /

val serverBinding = Http().bindAndHandle(interface = "0.0.0.0", port = 8080, 
handler = route2HandlerFlow(mainFlow()))

- tacos_tacos_tacos

---

谢谢，实际上我正在寻找相反的东西。 - Stefano Bonetti

总是很高兴能够帮助别人...也许是某个人... - tacos_tacos_tacos