我使用 Spring Boot 和 Spring Initializr 制作了一个简单的 Web 应用程序,并尝试使用 @Around 建议编写 @Aspect。
当我将自定义注释 @RetryOnFailure 添加到控制器的端点方法时 - 它有效,但是当我将此注释添加到由控制器端点执行的控制器方法时 - 它不起作用。我花了很多时间来理解这种行为的原因,但没有任何结果。所以请帮忙。
项目位于:https://github.com/zalizko/spring-aop-playground
@Aspect
@Component
public final class MethodRepeater {
@Around("execution(* *(..)) && @annotation(RetryOnFailure)")
public Object wrap(final ProceedingJoinPoint joinPoint) throws Throwable {
// code is here
}
}
所以,我的目标是:
@RequestMapping
public String index() {
inTry();
return "OK";
}
@RetryOnFailure(attempts = 3, delay = 2, unit = TimeUnit.SECONDS)
public void inTry() {
throw new RuntimeException("Exception in try " + ++counter);
}
你犯了一个典型的 Spring AOP 初学者错误:你忘记了基于代理的 AOP 只有在从外部调用代理方法时才有效,而不是通过
this
(避免代理)。但是内部调用inTry()
和this.inTry()
是一样的。因此,方面永远不会触发inTry
,你必须像这样重新安排你的代码:
package spring.aop;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.concurrent.TimeUnit;
@RestController("/")
public class HomeController {
static int counter = 0;
@RequestMapping
@RetryOnFailure(attempts = 3, delay = 2, unit = TimeUnit.SECONDS)
public String index() {
throw new RuntimeException("Exception in try " + ++counter);
}
}
我也稍微改变了一下外观
@annotation()
,package spring.aop;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.stereotype.Component;
@Aspect
@Component
public final class MethodRepeater {
@Around("execution(* spring.aop..*(..)) && @annotation(retryOnFailure)")
public Object wrap(final ProceedingJoinPoint joinPoint, RetryOnFailure retryOnFailure) throws Throwable {
System.out.println(joinPoint);
return proceed(joinPoint, retryOnFailure);
}
private Object proceed(ProceedingJoinPoint joinPoint, RetryOnFailure retryOnFailure) throws Throwable {
int attempt = 1;
while (true) {
try {
return joinPoint.proceed();
} catch (final Throwable ex) {
System.out.println("Try #" + attempt + " failed: " + ex);
if (++attempt >= retryOnFailure.attempts())
return "OK";
if (retryOnFailure.delay() > 0L)
retryOnFailure.unit().sleep(retryOnFailure.delay());
}
}
}
}
现在它可以工作并且控制台日志显示:
execution(String spring.aop.HomeController.index())
Try #1 failed: java.lang.RuntimeException: Exception in try 1
Try #2 failed: java.lang.RuntimeException: Exception in try 2
我遇到过类似的问题,我设法使用 AspectJ 解决了它:
https://github.com/mdanetzky/tour-of-heroes-java
另外 - 我花了一些时间才发现,我的 IDEA 没有正确地重建方面,所以在你尝试一些更激烈的措施之前尝试清理/重建项目可能是值得的。