您可以使用ExchangeFilterFunction轻松完成此 *** 作
在
logRequest创建
WebClientusing 时,只需添加自定义过滤器
WebClient.Builder。
这是此类过滤器的示例以及如何将其添加到中
WebClient。
@Slf4j@Componentpublic class MyClient { private final WebClient webClient; // Create WebClient instance using builder. // If you use spring-boot 2.0, the builder will be autoconfigured for you // with the "prototype" scope, meaning each injection point will receive // a newly cloned instance of the builder. public MyClient(WebClient.Builder webClientBuilder) { webClient = webClientBuilder // you can also just use WebClient.builder() .baseUrl("https://httpbin.org") .filter(logRequest()) // here is the magic .build(); } // Just example of sending request public void send(String path) { ClientResponse clientResponse = webClient .get().uri(uriBuilder -> uriBuilder.path(path) .queryParam("param", "value") .build()) .exchange() .block(); log.info("Response: {}", clientResponse.toEntity(String.class).block()); } // This method returns filter function which will log request data private static ExchangeFilterFunction logRequest() { return ExchangeFilterFunction.ofRequestProcessor(clientRequest -> { log.info("Request: {} {}", clientRequest.method(), clientRequest.url()); clientRequest.headers().forEach((name, values) -> values.forEach(value -> log.info("{}={}", name, value))); return Mono.just(clientRequest); }); }}
然后,只需致电
myClient.send("get");和日志消息就在那里。
输出示例:
Request: GET https://httpbin.org/get?param=valueheader1=value1header2=value2
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)