Spring Webflux Mono总是以成功响应进行响应

Question

    public Mono<ServerResponse> deleteProduct(ServerRequest request) {
     String id = request.pathVariable("id");
     Mono<Product> productMono = this.repository.findById(id);
     return productMono
            .flatMap(existingProduct ->
                    ServerResponse.noContent()
                            .build(productService.delete(existingProduct))
            );
}

     * Build the response entity with no body.
     * The response will be committed when the given {@code voidPublisher} completes.
     * @param voidPublisher publisher publisher to indicate when the response should be committed
     * @return the built response
     */
    Mono<ServerResponse> build(Publisher<Void> voidPublisher);

提前谢谢你。

Answer 1

问题是由于使用VoidPublisher引起的。如果您使用void publisher创建ServerResponse，它只会返回HTTP200，甚至是您的下游完成错误信号。它只是不关心你的流如何完成，它只关心下游的完成。

如果您想在构建响应时处理下游错误，只需简单使用

 ServerResponse.noContent()
    .body(productService.delete(existingProduct), Void.class)

现在，当任何错误发生在下游，服务器将响应错误。