如何解决@Recover 方法没有被 Spring AOP 建议拦截
在使用 Spring/Java 和面向方面的编程编写代码时，我遇到了一个问题。 在服务类中，我有使用@Retryable 的重试方法和使用@Recover 的恢复方法。
这 2 个方法中的每一个都附加到 Aspects。 Retryable 方法 - TestProcessService 中的“triggerJob”附加到 TestAspect 类中的这些方法 - beforeTestTriggerJobsAdvice、afterTestTriggerJobsAdvice、onErrorTestTriggerJobsAdvice。 它们都运行良好，并且在正确的时间被触发。
问题说明： 恢复方法 - TestProcessService 中的“recover”附加到 TestAspect 类中的这些方法 - beforeRecoveryTestJobsAdvice、onErrorRecoveryTestTriggerJobsAdvice 和 afterRecoveryTestTriggerJobsAdvice。
但是一旦代码到达 TestProcessService 内部的恢复方法，这些方面的方法都不会被调用。
代码如下：
SCHEDULER CLASS（定期触发 TEST_MyProcessService 类中的方法）
@Slf4j
@Component
public class TEST_ScheduledProcessPoller {
private final TEST_MyProcessService MyProcessService;
private final MyServicesConfiguration MyServicesConfiguration;
public TEST_ScheduledProcessPoller(TEST_MyProcessService MyProcessService,MyServicesConfiguration MyServicesConfiguration) {
this.MyProcessService = MyProcessService;
this.MyServicesConfiguration = MyServicesConfiguration;
}
@Scheduled(cron = "0 0/2 * * * *")
public void scheduleTaskWithFixedDelay() {
try {
log.info("scheduleTaskWithFixedDelay");
this.triggerMyJobs(true);
} catch (Exception e) {
log.error(e.getMessage());
}
}
protected void triggerMyJobs(boolean isDaily) throws Exception {
log.info("triggerMyJobs");
MyServiceType serviceType = this.MyServicesConfiguration.getMy();
this.MyProcessService.triggerJob(serviceType,isDaily,1L);
}
}
服务等级：
@Slf4j
@Service
public class TEST_MyProcessService {
@Retryable(maxAttemptsExpression = "${api.retry.limit}",backoff = @Backoff(delayExpression = "${api.retry.max-interval}"))
public void triggerJob(MyServiceType MyServiceType,boolean isDaily,long eventId) {
// Some code here that can throw exceptions.
log.info("triggerJob");
throw new RuntimeException("triggerJob");
}
@Recover
public void recover(MyServiceType MyServiceType,long eventId) {
log.info("recover");
// Some code here that can throw exceptions.
throw new RuntimeException();
}
}
方面类别：
@Component
@Slf4j
public class TEST_MyAspect {
@Pointcut("execution(* packgName.otherProj.services.TEST_MyProcessService.triggerJob(..))")
public void MyTriggerJobs() {
}
@Pointcut("execution(* packgName.otherProj.services.TEST_MyProcessService.recover(..))")
public void MyRecoverJobs() {
}
@Before("MyTriggerJobs()")
public void beforeMyTriggerJobsAdvice(JoinPoint joinPoint) {
log.info("log beforeMyTriggerJobsAdvice");
}
@AfterReturning("MyTriggerJobs()")
public void afterMyTriggerJobsAdvice(JoinPoint joinPoint) {
log.info("log afterMyTriggerJobsAdvice");
}
@AfterThrowing(value = "MyTriggerJobs()",throwing = "error")
public void onErrorMyTriggerJobsAdvice(JoinPoint joinPoint,Throwable error) {
log.info("log onErrorMyTriggerJobsAdvice");
}
@Before("MyRecoverJobs()")
public void beforeMyRecoverJobsAdvice(JoinPoint joinPoint) {
log.info("log beforeMyRecoverJobsAdvice");
}
@AfterThrowing(value = "MyRecoverJobs()",throwing = "error")
public void onErrorRecoveryMyTriggerJobsAdvice(JoinPoint joinPoint,Throwable error) {
log.info("log onErrorRecoveryMyTriggerJobsAdvice");
}
@AfterReturning("MyRecoverJobs()")
public void afterRecoveryMyTriggerJobsAdvice(JoinPoint joinPoint) {
log.info("log afterRecoveryMyTriggerJobsAdvice");
}
}
日志输出：
2021-06-02 20:56:00.016 INFO [,60b7f0602b2ecb0deefc04d6840b6274,eefc04d6840b6274,true] 92605 --- [ scheduling-1] c.c.p.r.c.TEST_ScheduledProcessPoller : scheduleTaskWithFixedDelay
2021-06-02 20:56:00.016 INFO [,true] 92605 --- [ scheduling-1] c.c.p.r.c.TEST_ScheduledProcessPoller : triggerBdaJobs
2021-06-02 20:56:00.051 INFO [,true] 92605 --- [ scheduling-1] c.c.p.r.component.aspect.TEST_BdaAspect : log beforeBdaTriggerJobsAdvice
2021-06-02 20:56:00.060 INFO [,true] 92605 --- [ scheduling-1] c.c.p.r.services.TEST_BdaProcessService : triggerJob
2021-06-02 20:56:00.061 INFO [,true] 92605 --- [ scheduling-1] c.c.p.r.component.aspect.TEST_BdaAspect : log onErrorBdaTriggerJobsAdvice
2021-06-02 20:56:05.065 INFO [,true] 92605 --- [ scheduling-1] c.c.p.r.component.aspect.TEST_BdaAspect : log beforeBdaTriggerJobsAdvice
2021-06-02 20:56:05.066 INFO [,true] 92605 --- [ scheduling-1] c.c.p.r.services.TEST_BdaProcessService : triggerJob
2021-06-02 20:56:05.066 INFO [,true] 92605 --- [ scheduling-1] c.c.p.r.component.aspect.TEST_BdaAspect : log onErrorBdaTriggerJobsAdvice
2021-06-02 20:56:10.070 INFO [,true] 92605 --- [ scheduling-1] c.c.p.r.component.aspect.TEST_BdaAspect : log beforeBdaTriggerJobsAdvice
2021-06-02 20:56:10.070 INFO [,true] 92605 --- [ scheduling-1] c.c.p.r.services.TEST_BdaProcessService : triggerJob
2021-06-02 20:56:10.070 INFO [,true] 92605 --- [ scheduling-1] c.c.p.r.services.TEST_BdaProcessService : recover
2021-06-02 20:56:10.070 ERROR [,true] 92605 --- [ scheduling-1] c.c.p.r.c.TEST_ScheduledProcessPoller : null
解决方法
我不是 Spring 用户，但对 AOP 的所有东西都感兴趣，包括 AspectJ 和 Spring AOP。我喜欢你的小拼图。感谢您的 MCVE，我能够重现该问题并对其进行调试。这是一个完美的例子，说明为什么 MCVE 比简单地发布一堆代码片段要优越得多。所以谢谢你，请保持这种提问的方式。
查看调试器中的情况时，您会发现当切面进入 triggerJob 时，在某个时刻我们处于方法 AnnotationAwareRetryOperationsInterceptor.invoke 中，并且有以下代码：
@Override
public Object invoke(MethodInvocation invocation) throws Throwable {
MethodInterceptor delegate = getDelegate(invocation.getThis(),invocation.getMethod());
if (delegate != null) {
return delegate.invoke(invocation);
}
else {
return invocation.proceed();
}
}
此时 Spring 选择构造稍后将用于调用 recover 的委托。它由指向原始对象的目标对象 invocation.getThis() 构造而成，即一个 TEST_BdaProcessService 实例。此时，代码可以简单地使用 invocation.getProxy() 代替，它会指向 AOP 代理，即一个 TEST_BdaProcessService$$EnhancerBySpringCGLIB$$2f8076ac 实例。问题是目标对象引用被传递到调用 recover 的点，而此时对应的恢复器实例只知道目标对象，不再知道对应的代理对象。
当我实验性地将代理分配给委托作为目标时，您的建议方法被调用。
所以我们在这里讨论的是 Spring 限制。我不知道这是为了避免任何其他相关问题而故意做出的选择，还是仅仅是疏忽，我不知道。
更新：我代表您创建了 Spring Retry issue #244。您想订阅它，以便了解是否/何时修复。
更新 2： 该问题已得到修复，已合并到主分支中，并且很可能会成为即将发布的 1.3.2 版本的一部分。现在，您可以克隆 Spring Retry，自己构建并使用快照。我对您的 MCVE 进行了重新测试，现在恢复方法的方面已按预期启动。
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。
