本文介紹了WebClient-如何獲取請(qǐng)求正文？的處理方法，對(duì)大家解決問(wèn)題具有一定的參考價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)吧！
問(wèn)題描述
我已經(jīng)開(kāi)始使用WebClient，正在添加請(qǐng)求/響應(yīng)的日志記錄，并在構(gòu)建WebClient時(shí)使用Filter方法：
WebClient.builder()
.baseUrl(properties.getEndpoint())
.filter((request, next) -> {
// logging
request.body()
})
.build();
我可以訪問(wèn)url、http方法、標(biāo)頭，但獲取原始請(qǐng)求正文時(shí)遇到問(wèn)題，因?yàn)?code>body()請(qǐng)求的方法返回BodyInserter(BodyInserter<?, ? super ClientHttpRequest> body()。
如何將請(qǐng)求Body的BodyInserter表示轉(zhuǎn)換為String表示？或者，如何正確記錄整個(gè)請(qǐng)求/響應(yīng)，同時(shí)還能夠?qū)ζ渲械臐撛趹{據(jù)進(jìn)行散列？
推薦答案
您可以圍繞JSON編碼器創(chuàng)建自己的包裝器/代理類，并在序列化后的正文被發(fā)送到內(nèi)部管道之前將其攔截。
此blog post顯示如何記錄WebClient請(qǐng)求和響應(yīng)的JSON負(fù)載
具體地說(shuō)，您將擴(kuò)展Jackson2JsonEncoder的encodeValue方法(如果是流數(shù)據(jù)，則encodeValues)。然后，您可以隨心所欲地處理這些數(shù)據(jù)，如日志記錄等。您甚至可以根據(jù)環(huán)境/配置文件有條件地執(zhí)行此操作
此自定義日志編碼器可以在創(chuàng)建WebClient時(shí)由編解碼器指定：
CustomBodyLoggingEncoder bodyLoggingEncoder = new CustomBodyLoggingEncoder();
WebClient.builder()
.codecs(clientDefaultCodecsConfigurer -> {
clientDefaultCodecsConfigurer.defaultCodecs().jackson2JsonEncoder(bodyLoggingEncoder);
clientDefaultCodecsConfigurer.defaultCodecs().jackson2JsonDecoder(new Jackson2JsonDecoder(new ObjectMapper(), MediaType.APPLICATION_JSON));
})
...
更新2020/7/3：
這里是一個(gè)匆忙的例子，應(yīng)用了相同的原則，但對(duì)于解碼器：
public class LoggingJsonDecoder extends Jackson2JsonDecoder {
private final Consumer<byte[]> payloadConsumer;
public LoggingJsonEncoder(final Consumer<byte[]> payloadConsumer) {
this.payloadConsumer = payloadConsumer;
}
@Override
public Mono<Object> decodeToMono(final Publisher<DataBuffer> input, final ResolvableType elementType, final MimeType mimeType, final Map<String, Object> hints) {
// Buffer for bytes from each published DataBuffer
final ByteArrayOutputStream payload = new ByteArrayOutputStream();
// Augment the Flux, and intercept each group of bytes buffered
final Flux<DataBuffer> interceptor = Flux.from(input)
.doOnNext(buffer -> bufferBytes(payload, buffer))
.doOnComplete(() -> payloadConsumer.accept(payload.toByteArray()));
// Return the original method, giving our augmented Publisher
return super.decodeToMono(interceptor, elementType, mimeType, hints);
}
private void bufferBytes(final ByteArrayOutputStream bao, final DataBuffer buffer) {
try {
bao.write(ByteUtils.extractBytesAndReset(buffer));
} catch (IOException e) {
throw new RuntimeException(e);
}
}
}
您將使用WebClient上的codecs生成器方法將其與編碼器一起配置。
當(dāng)然，上面的方法只有在您的數(shù)據(jù)被反序列化為Mono的情況下才有效。但如果需要，可以覆蓋其他方法。另外，我只是在那里標(biāo)準(zhǔn)輸出結(jié)果JSON，但是您可以傳遞一個(gè)Consumer<String>或其他東西，讓解碼器將字符串發(fā)送到，或者只是從那里記錄；由您決定。
警告一句，在當(dāng)前形式下，這將使您的內(nèi)存使用量翻倍，因?yàn)樗彌_了整個(gè)響應(yīng)。如果您可以立即將該字節(jié)數(shù)據(jù)發(fā)送到另一個(gè)進(jìn)程/線程以寫(xiě)入日志文件或某個(gè)輸出流(甚至是Flux)，則可以避免在內(nèi)存中緩沖整個(gè)有效負(fù)載。
這篇關(guān)于WebClient-如何獲取請(qǐng)求正文？的文章就介紹到這了，希望我們推薦的答案對(duì)大家有所幫助，
