用Mono流处理异常

Question

我有一个WebFlux处理程序如下所示。

@Transactional
  public Mono<ServerResponse> submitOrder(final ServerRequest request) {
    return context.retrieveUser().flatMap(usr -> {
      try {
        return Mono.zip(branchSetting, labOrderDetail, labOrderTests).flatMap(response -> {
          final Mono<String> submitOrderMono = service.submitOrder(usr);
          final Mono<Integer> updateStatusMono = orderRepository.updateStatus(orderId);
          return Mono.zip(submitOrderMono, updateStatusMono).flatMap(submitResponse -> {
            return ok().bodyValue(submitResponse.getT1());
          }).onErrorResume(e -> {
            if (e instanceof ServiceException) {
              ServiceException ex = (ServiceException) e;
              return status(ex.getStatusCode()).bodyValue(e.getMessage());
            } else {
              return status(500).bodyValue(e.getMessage());
            }
          });
        });
      } catch (Throwable e) {
        if (e instanceof ServiceException) {
          ServiceException ex = (ServiceException) e;
          return status(ex.getStatusCode()).bodyValue(e.getMessage());
        } else {
          return status(500).bodyValue(e.getMessage());
        }
      }
    });
  }

服务类的submitOrder方法，

public Mono<String> submitOrder(final Order order,
      if (order.getPatientId() != null) {
        throw new ServiceException("Missing Id for patient !!!", HttpStatus.BAD_REQUEST.value());
      }
  }

在这里，我正在做一些验证和抛出异常。

但是，这个异常并没有进入调用main方法中的onErrorResume或catch块，因此服务调用方会看到500个错误。

不知道这里出了什么问题。

Answer 1

当在反应性的WebFlux上下文中工作时，抛出异常并使用尝试捕获块并不是真正的最佳实践。

更惯用的方法是使用Mono.error()而不是throw命令。Mono.error()发出一个错误信号，以便后续的onErrorResume()能够处理它。

话虽如此，submitOrder()看起来可能是这样的：

    public Mono<String> submitOrder(final Order order) {
        if (order.getPatientId() == null) {
           Mono.error(new ServiceException("Missing Id for patient !!!", 500));
        }
       return Mono.just("some reasonable result");
    }

通过这种重写，第一个片段应该(可能需要进行一些小的调整)以这样的方式工作：

    public Mono<ServerResponse> submitOrder(final ServerRequest request) {
        return context.retrieveUser().flatMap(usr -> {
                return Mono.zip(branchSetting, labOrderDetail, labOrderTests).flatMap(response -> {
                    final Mono<String> submitOrderMono = service.submitOrder(usr);
                    final Mono<Integer> updateStatusMono = orderRepository.updateStatus(orderId);
                    return Mono.zip(submitOrderMono, updateStatusMono).flatMap(submitResponse -> {
                        return ok().bodyValue(submitResponse.getT1());
                    }).onErrorResume(e -> {
                        if (e instanceof ServiceException) {
                            ServiceException ex = (ServiceException) e;
                            return status(ex.getStatusCode()).bodyValue(e.getMessage());
                        } else {
                            return status(500).bodyValue(e.getMessage());
                        }
                    });
                });
        });
    }