使用Spring WebFlux在不同endpoint上的不同JSON（反）序列化配置

Question

我的微服务需要通过HTTP与2个不同的服务进行通信。1个与snake_caseJSON有API契约，而另一个使用camelCase。如何配置WebFlux在一组功能endpoint上使用某个JacksonObjectMapper反序列化和序列化JSON，而在不同endpoint上使用另一个？

WebFlux文档展示了如何连接另一个ObjectMapper，但这适用于我的API的所有endpoint。所以现在要么我所有的JSON都在snake_case中，要么在camelCase中。找不到任何资源来解决这个问题，但它必须是可行的，对吗？

更新：为了清楚起见，我想配置接收来自其他服务的请求的Web服务器，而不是用于自己发送http请求的web客户端。我知道该怎么做后者。

Answer 1

好的，所以这不是清理后的解决方案，我将使用我们图书馆中的这个解决方案，但是我工作的基本要点是这样的：

@Controller
public class Handler {

    private ObjectMapper mapper;

    public Handler(@Qualifier("snakeCaseWrapper") ObjectMapper mapper) {
        this.mapper = mapper;
    }

    Mono<ServerResponse> returnUser(final ServerRequest request) {
        //REQUEST DESERIALIZATION
        var messageReader = new DecoderHttpMessageReader<>(new Jackson2JsonDecoder(mapper));
        var configuredRequest = ServerRequest.create(request.exchange(), List.of(messageReader));

        //RESPONSE SERIALIZATION
        return configuredRequest.bodyToMono(UserDto.class)
                                .map(userDto -> {
                                    try {
                                        return mapper.writeValueAsString(userDto);
                                    } catch (JsonProcessingException e) {
                                        e.printStackTrace();
                                        //properly handle the error here
                                        return "";
                                    }
                                })
                                .flatMap(json -> ServerResponse.ok()
                                                               .contentType(MediaType.APPLICATION_JSON)
                                                               .body(BodyInserters.fromObject(json))
                                );
    }
}

对于响应序列化，诀窍是首先使用ObjectMapper将响应主体序列化为String，然后将该String放入带有BodyInserters.fromObject（json）的响应中。

它有效，所以我很高兴。

Answer 2

您可以在想要序列化/反序列化的类上使用< code>@JsonNaming注释，并指定想要的命名策略类型。

杰克逊高级注释