project reactor中的异常处理问题并重试失败的事务

Question

我在测试错误处理部分的代码。看起来它不像预期的那样工作。我已经分解了代码片段如下所示。总体的补充是当有异常时重试5次。为了简单起见，我编写了一个方法来抛出NPE异常，并添加了一个错误处理程序。有人能解释什么是错误的。

public static void main(String[] args) {
    Mono.just( errorDemo() )
        .retry(5)
        .doOnError( e -> log.error( "Error {}", e.getStackTrace() ) )
        .doOnSuccess( e -> log.info( "done" ) );
}
public static Mono<Void> errorDemo() {
    return Mono.error( NullPointerException::new ); // throwing back 
exception to calling method
}

Answer 1

你应该订阅你的单声道。如果你不订阅什么也不会发生。

您可以为示例添加.block()。