首页 > 解决方案 > 如何记录传入的请求和响应?

问题描述

我正在使用 Akka HTTP,并希望记录每个传入请求和传出结果。我知道,它存在一个logRequestResult指令,但是如何使用它呢?或者它是否适合我的目的?

标签: scalaakkaakka-http

解决方案


是的,这是您正在寻找的指令,我同意 - 官方文档有点难以掌握。

以下是端点的logRequestResult样子:

    val requestHandler: Route = logRequestResult("req/resp", Logging.InfoLevel) {
        handleExceptions(errorHandler) {
            endpointRoutes
        }
    }

    def start()(implicit actorSystem: ActorSystem,
                actorMaterializer: ActorMaterializer): Future[Http.ServerBinding] =
        Http().bindAndHandle(
            handler = requestHandler,
            interface = host,
            port = port)

请注意,您可以为每个请求-响应条目选择一个通用前缀,即 ,req/resp以及请求-响应日志可用的日志级别,即Logging.InfoLevel

上面的示例生成类似于以下的日志行:

[your-actor-system-akka.actor.default-dispatcher-19] INFO  akka.actor.ActorSystemImpl - req/resp: Response for
  Request : HttpRequest(HttpMethod(GET),http://<host>/<path>,List(Host: <host>, Connection: close: <function1>),HttpEntity.Strict(none/none,ByteString()),HttpProtocol(HTTP/1.1))
  Response: Complete(HttpResponse(200 OK,List(),HttpEntity.Strict(text/plain; charset=UTF-8,OK),HttpProtocol(HTTP/1.1)))

哈克快乐 :)


推荐阅读