如何为反应式Spring WebClient (Spring-WebFlux)定义自定义HttpMessageConverter

import org.springframework.core.ParameterizedTypeReference;
import org.springframework.http.MediaType;
import org.springframework.http.codec.HttpMessageReader;
import org.springframework.http.codec.HttpMessageWriter;
import org.springframework.http.codec.json.Jackson2JsonDecoder;
import org.springframework.http.codec.json.Jackson2JsonEncoder;
import org.springframework.web.reactive.function.client.ExchangeStrategies;
import org.springframework.web.reactive.function.client.WebClient;

import java.util.List;

public class CustomWebClient {

    public WebClient createWebClient() {
        ExchangeStrategies strategies = ExchangeStrategies.builder()
                .codecs(this::customCodecs)
                .build();

        return WebClient.builder()
                .exchangeStrategies(strategies)
                .build();
    }

    private void customCodecs(ClientCodecConfigurer configurer) {
        configurer.customCodecs().register(new CustomHttpMessageReader());
        configurer.customCodecs().register(new CustomHttpMessageWriter());
    }

    private static class CustomHttpMessageReader implements HttpMessageReader<Object> {

        @Override
        public List<MediaType> getReadableMediaTypes() {
            // 返回支持的媒体类型
            return List.of(MediaType.APPLICATION_JSON);
        }

        @Override
        public boolean canRead(ResolvableType elementType, MediaType mediaType) {
            // 判断是否支持读取指定的数据类型和媒体类型
            return true;
        }

        @Override
        public Flux<Object> read(ResolvableType elementType, ReactiveHttpInputMessage message, Map<String, Object> hints) {
            // 读取请求数据并进行转换
            return message.getBody()
                    .map(buffer -> {
                        // 进行数据转换操作
                        return convert(buffer);
                    });
        }

        private Object convert(DataBuffer buffer) {
            // 使用Jackson或其他库进行数据反序列化操作
            // 返回转换后的Java对象
        }
    }

    private static class CustomHttpMessageWriter implements HttpMessageWriter<Object> {

        @Override
        public List<MediaType> getWritableMediaTypes() {
            // 返回支持的媒体类型
            return List.of(MediaType.APPLICATION_JSON);
        }

        @Override
        public boolean canWrite(ResolvableType elementType, MediaType mediaType) {
            // 判断是否支持写入指定的数据类型和媒体类型
            return true;
        }

        @Override
        public Mono<Void> write(Publisher<? extends Object> inputStream, ResolvableType elementType, MediaType mediaType, ReactiveHttpOutputMessage message, Map<String, Object> hints) {
            // 将Java对象转换为请求数据并写入输出流
            return Flux.from(inputStream)
                    .map(object -> {
                        // 进行数据转换操作
                        return convert(object);
                    })
                    .map(buffer -> {
                        // 将转换后的数据写入输出流
                        return message.writeWith(Mono.just(buffer));
                    })
                    .then();
        }

        private DataBuffer convert(Object object) {
            // 使用Jackson或其他库进行数据序列化操作
            // 返回转换后的请求数据
        }
    }
}