spring - 在 AOP 中从 Mono 中抛出新的 RuntimeException()

Question

我有一个响应式(Reactive) springboot 应用程序，其中一个方面

@Before("approveRejectPointcut()")
public void logAfterReturning(JoinPoint joinPoint) {
   
    Status newStatus = AspectUtils.returnFirstParameterOfTypeOrFail(allParameters, Status.class, "approveRejectPointcut");
    String comments = AspectUtils.returnFirstParameterOfTypeOrFail(allParameters, String.class, "approveRejectPointcut");
    
    Mono<Object> someObjectOrException = someService.updateApplicationStatus(appId, newStatus, comments);
    
    someObjectOrException
      .subscribe(i->log.info(i),
            error->{
                log.info("we have some ex: "+error.getMessage());
                throw new RuntimeException("PLEASE LORD: "+error.getMessage()); 
      });
}

这里发生了什么，来自某些服务的 updateApplicationStatus() 在某个时候抛出了一个业务异常(这很好)，在这方面我打印了异常消息，这也很好。但是，当我尝试抛出业务异常(其基础为 RuntimeException)时......我可以在控制台中看到这个异常，但是......它没有到达客户端。
我怀疑它被扔到了另一个线程上。有什么线索吗？

Answer 1

最后，将方面更改为@Around

@Around("approveRejectPointcut()")
public Mono<Object> logAfterReturning(ProceedingJoinPoint pjp) {
...
Mono<Object> someObjectOrException = someService.updateApplicationStatus(appId, newStatus, comments);
someObjectOrException
      .map(unused->pjp.proceed(pjp.getArgs())
      .onErrorMap(RuntimeException.class, (s)->{
            return new GenericBusinessException(s.getMessage());
      }); 
}

这样，以防万一服务一切顺利 -> 我们继续执行，否则，我们使用来自服务的异常消息抛出业务异常。也许那 map() 应该用其他一些接受函数的运算符替换.. :)