Spring WebFlux。如何使用@RequestBody注释获取两种不同格式的请求正文?

2022-04-06 00:00:00 spring java spring-webflux

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

  1. 原始JSON字符串
  2. 已分析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’。 我找不到正确接收身体的方法。

我理解,我可以使用objectMapper并将playCommand转换回JSON,但这是不需要完成的额外工作。 可以以两种不同的形式接收请求正文吗?或者,也许我在示例中做错了什么?


解决方案

不可能有多个@RequestBody。如果您确实需要原始JSON及其序列化版本,最好的方法是以普通String的形式接收请求正文,然后将其转换为相应的Java对象,如下所示:

@Autowired
private ObjectMapper objectMapper;

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

相关文章