Spring webflux：从请求中使用mono或flux

Question

我有一个处理对象（例如产品）的资源API。

public Mono<ServerResponse> updateProduct(ServerRequest request){
  Mono<Product> productReceived = request.bodyToMono(Product.class);
  Mono<Product> result = productReceived.flatMap(item -> {
    doSomeThing(item);
    System.out.println("Called or not called!!");
    return Mono.just(productService.product);
  }).subscribe();

  return ok()
        .contentType(APPLICATION_JSON)
        .body(Mono.empty(), Product.class);
}

谢了。

Answer 1

我刚接触WebFlux时也遇到过类似的问题。简而言之，您不能在请求正文上调用subscribe并异步返回响应，因为订阅可能没有足够的时间读取正文。您可以在这里看到一个类似问题的完整解释。

为了使代码工作，您应该将响应与逻辑流耦合起来。应该如下所示：

public Mono<ServerResponse> updateProduct(ServerRequest request){
    return request
            .bodyToMono(Product.class)
            .flatMap(item -> {
                doSomeThing(item);
                System.out.println("Called or not called!!");
                return Mono.just(productService.product);
            })
            .then(ServerResponse.ok().build());
}