Spring反应式 Web 应用程序 POST 请求正文丢失

Question

我参与了一个小型测试项目，以检查Spring Reactive Web应用程序实际上是如何与MongoDB一起工作的。

我遵循手册https://docs.spring.io/spring/docs/5.0.0.M4/spring-framework-reference/html/web-reactive.html

它指出我可以在控制器中处理POST请求，例如：

@PostMapping("/person")
    Mono<Void> create(@RequestBody Publisher<Person> personStream) {
        return this.repository.save(personStream).then();
    }

虽然这似乎不起作用。这里是我实现的控制器：

https://github.com/pavelmorozov/reactor-poc/blob/master/src/main/java/com/springreactive/poc/controller/BanquetHallController.java

它只有一个POST映射，非常简单：

@PostMapping("/BanquetHall")
    Mono<Void> create(@RequestBody Publisher<BanquetHall> banquetHallStream) {
        return banquetHallRepository.insert(banquetHallStream).then();
    }

每次我发出带有 curl 的 POST 时都会调用它：

curl -v -XPOST -H "Content-type: application/json" -d '{"name":"BH22"}' 'http://localhost:8080/BanquetHall'
Note: Unnecessary use of -X or --request, POST is already inferred.
*   Trying 127.0.0.1...
* Connected to localhost (127.0.0.1) port 8080 (#0)
> POST /BanquetHall HTTP/1.1
> Host: localhost:8080
> User-Agent: curl/7.47.0
> Accept: */*
> Content-type: application/json
> Content-Length: 15
> 
* upload completely sent off: 15 out of 15 bytes
< HTTP/1.1 200 OK
< content-length: 0
< 
* Connection #0 to host localhost left intact

我看到新对象存储在mongoDB中，但它们不包含数据。为了调试，我构建了简单的订阅者，以查看实际作为请求正文传递给控制器的数据：

Subscriber s = new Subscriber() {
    @Override
    public void onSubscribe(Subscription s) {
        logger.info("Argument: "+s.toString());
    }
    @Override
    public void onNext(Object t) {
        logger.info("Argument: "+t.toString());

    }
    @Override
    public void onError(Throwable t) {
        logger.info("Argument: "+t.toString());
    }
    @Override
    public void onComplete() {
        logger.info("Complete! ");
    }
};
banquetHallStream.subscribe(s);

现在我看到订阅后错误方法调用。可投掷状态正文缺失：

Here error string:
Request body is missing: reactor.core.publisher.Mono<java.lang.Void> com.springreactive.poc.controller.BanquetHallController.create(org.reactivestreams.Publisher<com.springreactive.poc.domain.BanquetHall>)

为什么请求体是空的？

同样值得一提的是:由于我对所有这些反应式的东西都不熟悉，在不手动实现订阅者的情况下，调试发布者/订阅者是否有更好的方法？

更新我更新了POST处理程序方法说明，它将请求正文作为字符串对象传递：

Mono<Void> create(@RequestBody String banquetHallStream)

那幺这不是一个“反应”，对不对？字符串不是反应性的，因为发布者应该是。。。

Answer 1

我也遇到了同样的问题，通过将< code>@ResponseStatus放在方法上，我解决了这个问题。下面是方法控制器的样子:

@ResponseStatus(HttpStatus.CREATED)
@PostMapping(value = "/bulk", consumes = APPLICATION_STREAM_JSON_VALUE)
public Mono<Void> bulkInsert(@RequestBody Flux<Quote> quotes) {
    return quoteReactiveRepository.insert(quotes).then();
}

我正在使用< code>WebClient向该endpoint发出请求:

webClient.post()
        .uri("/quotes/bulk")
        .contentType(MediaType.APPLICATION_STREAM_JSON)
        .body(flux(), Quote.class)
        .retrieve()
        .bodyToMono(Void.class).block();

测试语言：org.springframework.boot：spring-boot-starter-webflux：2.1.0.RELEASE