Spring WebFlux。如何使用@RequestBody注解获取两种不同格式的请求body？

Question

我正在使用 Spring Boot 2.5.6 和 Spring WebFlux。在我的业务案例中，我需要以两种不同的形式使用 HTTP 请求 body：

原始JSON字符串
已经解析 Java DTO

还有我的RestContoller:

@PostMapping("/play")
public Mono<PlayResponse> play(@RequestBody PlayCommand parsedBody,
                               @RequestBody String jsonBody) {
    //code here
}

当我运行测试时，我得到下一个异常：

java.lang.IllegalStateException: Only one connection receive subscriber allowed.
    at reactor.netty.channel.FluxReceive.startReceiver(FluxReceive.java:182) ~[reactor-netty-core-1.0.12.jar:1.0.12]
    Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException: 
Error has been observed at the following site(s):
    *__checkpoint ⇢ HTTP POST "/play" [ExceptionHandlingWebHandler]

当我使用下一个方法签名时：

@PostMapping("/play")
public Mono<PlayResponse> play(PlayCommand playCommand,
                               @RequestBody String body){
    //code here
}

PlayCommand parsedBody 将所有字段设置为 'null'。我找不到正确接收 body 的方法。

我明白，我可以使用 objectMapper 并将 playCommand 转换回 JSON，但这是不需要完成的额外工作。是否可以以两种不同的形式接收请求body？或者，也许我在示例中做错了什么？

Answer 1

不可能有多个@RequestBody。如果你真的需要原始 JSON 和它的序列化版本，你能做的最好的就是接收请求主体作为普通 String 然后将其转换为相应的 Java 对象，如下所示：

@Autowired
private ObjectMapper objectMapper;

@PostMapping("/play")
public Mono<PlayResponse> play(@RequestBody String body){
    PlayCommand playCommand = objectMapper.readValue(body, PlayCommand.class);
}

Spring WebFlux。如何使用@RequestBody注解获取两种不同格式的请求body？

Spring WebFlux. How to get the request body in two different formats using @RequestBody annotation?

java

spring

spring-webflux