Как зарегистрировать запрос Spring-webflux WebClient + подробности ответа (тела, заголовки, elasped_time)?

Question

По сути, я хочу записать информацию о запросе / ответе в один журнал, содержащий тела / заголовки с помощью Spring WebClient,

С весны RestTemplate мы можем сделать это с ClientHttpRequestInterceptor, Я нахожу о ExchangeFilterFunction для весны WebClient но не удалось сделать что-то подобное в чистом виде. Мы можем использовать этот фильтр и регистрировать запрос И затем ответ, но мне нужны оба в одной и той же трассировке журнала.

Более того, мне не удалось получить ответное тело с ExchangeFilterFunction.ofResponseProcessor метод.

Я ожидаю такой журнал (текущая реализация работает с ClientHttpRequestInterceptor) со всей необходимой мне информацией:

{
    "@timestamp": "2019-05-14T07:11:29.089+00:00",
    "@version": "1",
    "message": "GET https://awebservice.com/api",
    "logger_name": "com.sample.config.resttemplate.LoggingRequestInterceptor",
    "thread_name": "http-nio-8080-exec-5",
    "level": "TRACE",
    "level_value": 5000,
    "traceId": "e65634ee6a7c92a7",
    "spanId": "7a4d2282dbaf7cd5",
    "spanExportable": "false",
    "X-Span-Export": "false",
    "X-B3-SpanId": "7a4d2282dbaf7cd5",
    "X-B3-ParentSpanId": "e65634ee6a7c92a7",
    "X-B3-TraceId": "e65634ee6a7c92a7",
    "parentId": "e65634ee6a7c92a7",
    "method": "GET",
    "uri": "https://awebservice.com/api",
    "body": "[Empty]",
    "elapsed_time": 959,
    "status_code": 200,
    "status_text": "OK",
    "content_type": "text/html",
    "response_body": "{"message": "Hello World!"}"
}

Кто-нибудь может сделать что-то подобное с Spring WebClient? Или как отследить проблему запроса / ответа с Spring WebClient?

Answer 1

Вы можете использовать filter(), что-то вроде этого:

this.webClient = WebClient.builder().baseUrl("your_url")
            .filter(logRequest())
            .filter(logResponse())
            .build();

private ExchangeFilterFunction logRequest() {
    return (clientRequest, next) -> {
        log.info("Request: {} {}", clientRequest.method(), clientRequest.url());
        clientRequest.headers()
                .forEach((name, values) -> values.forEach(value -> log.info("{}={}", name, value)));
        return next.exchange(clientRequest);
    };
}

private ExchangeFilterFunction logResponse() {
    return ExchangeFilterFunction.ofResponseProcessor(clientResponse -> {
        log.info("Response: {}", clientResponse.headers().asHttpHeaders().get("property-header"));
        return Mono.just(clientResponse);
    });
}

Answer 2

Я не думаю, что ты можешь позвонить .bodyToMonoдважды (один раз в фильтре, а затем еще раз, когда вы используете клиент), поэтому вы не сможете зарегистрировать это в фильтре. Что до остальных деталей ...

Конфигурация WebClient:

      @Configuration
class MyClientConfig {

    @Bean
    fun myWebClient(): WebClient {
        return WebClient
            .builder()
            .baseUrl(myUrl)
            .filter(MyFilter())
            .build()
    }
}

Фильтр:

      class MyFilter : ExchangeFilterFunction {

    override fun filter(request: ClientRequest, next: ExchangeFunction): Mono<ClientResponse> {
        return next.exchange(request).flatMap { response ->

            // log whenever you want here...
            println("request: ${request.url()}, response: ${response.statusCode()}")

            Mono.just(response)
        }
    }
}