java - SpringWebFlux doOnError 处理

Question

在我们的项目中，如果发生不好的事情，我们有某种后备措施，并由 doOnError 处理。我唯一担心的是 doOnError 运算符可能没有以正确的方式使用。那么让我们看一下下一个示例:

callService1()
.flatMap(service1Response -> {
  //process service1Response
})
.doOnError(callService2.subscribe())

当流程到达 doOnError 时，我们将调用另一个服务。

在 doOnError 中，我们必须手动订阅由 callService2 检索到的 Mono 才能执行代码，除此之外，如果 doOnError 中抛出错误，该错误不会被我们的 GlobalErrorHandler 捕获。

在这种情况下我们是否应该重新考虑错误处理？我真的不想手动订阅出版商。你怎么认为 ？提前谢谢。

Answer 1

如果发生错误，您可以使用onErrorResume运算符返回另一个Mono。请参阅reactor operator guide供其他相关运营商使用。

callService1()
.flatMap(service1Response -> {
  //process service1Response
})
.onErrorResume(err -> callService2())