如何通过Spring AOP实现无侵入式应用级重试逻辑并解决重试失效问题？

问题根源分析 #

你的重试逻辑失效核心原因有两点：

1. 异常传递被拦截：切面中额外的try-catch块看似在传递异常，但实际上干扰了RetryTemplate对原始异常的识别；
2. RetryCallback泛型缺失：Lambda表达式未明确声明异常类型，导致检查型异常（SQLTransientConnectionException）被RetryTemplate包装为RetryException，而你的重试策略仅配置了处理原始异常，因此无法触发重试。

修复代码实现 #

1. 修正切面类 #

移除不必要的异常捕获，明确指定RetryCallback的泛型类型，确保原始异常直接传递给RetryTemplate：

@Aspect
@Component
public class DbConnectionRetryAspect {

    private final RetryTemplate retryTemplate;

    public DbConnectionRetryAspect(RetryTemplate retryTemplate) {
        this.retryTemplate = retryTemplate;
    }

    @Around("@within(org.springframework.stereotype.Service)")
    public Object retry(ProceedingJoinPoint joinPoint) throws Throwable {
        System.out.println("Aspect invoked for method: " + joinPoint.getSignature());

        // 明确声明异常类型为Throwable，确保所有异常能被RetryTemplate正确识别
        return retryTemplate.execute((RetryCallback<Object, Throwable>) context -> {
            System.out.println("Retry attempt: " + context.getRetryCount());
            // 直接调用目标方法，异常交由RetryTemplate处理
            return joinPoint.proceed();
        });
    }
}

2. 优化RetryTemplate配置（可选增强） #

调整配置写法，提升可读性，同时确保重试策略精准生效：

@Bean
public RetryTemplate retryTemplate() {
    RetryTemplate retryTemplate = new RetryTemplate();

    // 重试策略：最多5次尝试，仅对SQL连接瞬态异常重试
    SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
    retryPolicy.setMaxAttempts(5);
    Map<Class<? extends Throwable>, Boolean> retryableExceptions = new HashMap<>();
    retryableExceptions.put(SQLTransientConnectionException.class, true);
    retryPolicy.setRetryableExceptions(retryableExceptions);

    // 退避策略：每次重试间隔1秒
    FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
    backOffPolicy.setBackOffPeriod(1000);

    retryTemplate.setRetryPolicy(retryPolicy);
    retryTemplate.setBackOffPolicy(backOffPolicy);

    return retryTemplate;
}

验证效果 #

调用MyService.performOperation()后，你会看到以下日志输出，说明服务方法被重试5次（符合maxAttempts配置）：

Aspect invoked for method: void com.example.MyService.performOperation()
Retry attempt: 0
Service method invoked
Retry attempt: 1
Service method invoked
Retry attempt: 2
Service method invoked
Retry attempt: 3
Service method invoked
Retry attempt: 4
Service method invoked

关键注意事项 #

• 不要捕获重试目标异常：RetryCallback中无需手动捕获异常，直接让目标方法抛出的异常传递给RetryTemplate，由重试策略判断是否触发重试；
• 精准控制切点范围：如果不需要对所有@Service类的方法重试，可以通过更具体的切点表达式（如@within(org.springframework.stereotype.Service) && execution(* com.yourpackage..*.*(..))）缩小作用范围，避免不必要的性能损耗；
• 保持配置集中化：所有重试规则（次数、退避间隔、异常类型）都通过RetryTemplate Bean配置，无需修改任何服务类代码。

内容的提问来源于stack exchange，提问作者concept_coding