如何自定义SpringWebFlux WebClient JSON反序列化？

Question

我正在使用spring-webflux WebClient（build 20170502.221452-172)访问一个Web应用程序，该应用程序生成一个条目对象流(application/stream+JSON)，如下所示：

final WebClient producerClient = WebClient.create("http://localhost:8080/");

Flux<Entry> entries = producerClient.get().uri("json-stream")
        .accept(MediaType.APPLICATION_STREAM_JSON)
        .exchange()
        .flatMapMany(clientResponse -> clientResponse.bodyToFlux(Entry.class));

虽然条目对象的反序列化对于使用标准通用类型（包括Java.time.instant等Java time(JSR-310)数据类型）的POJO很好，但我想知道，为了将任何自定义JSON添加到Java反序列化（例如，自定义Jackson ObjectMapper）中，我必须做些什么。

有人使用过带有定制反序列化的WebClient吗？

（也许API还没有出现？）

Answer 1

下面的示例为JSON(de)序列化定制ObjectMapper。请注意，为了流的目的，使用不同的编码器/解码器，但对于它们的配置，原理仍然相同。

    ExchangeStrategies strategies = ExchangeStrategies
            .builder()
            .codecs(clientDefaultCodecsConfigurer -> {
                clientDefaultCodecsConfigurer.defaultCodecs().jackson2JsonEncoder(new Jackson2JsonEncoder(new ObjectMapper(), MediaType.APPLICATION_JSON));
                clientDefaultCodecsConfigurer.defaultCodecs().jackson2JsonDecoder(new Jackson2JsonDecoder(new ObjectMapper(), MediaType.APPLICATION_JSON));

            }).build();

    WebClient webClient = WebClient.builder().exchangeStrategies(strategies).build();