Spring Boot @Retryable与JPA save()方法兼容问题排查

1. 异常匹配范围不足：默认@Retryable仅处理通用RuntimeException，但Spring Data JPA会将数据库异常（如数据截断对应的DataIntegrityViolationException）包装为DataAccessException子类，这类异常未被默认重试规则覆盖，导致失败后直接跳过重试流程。
2. 继承方法的代理兼容问题：JpaRepository自带的save()方法由框架实现，其异常抛出逻辑与自定义@Query方法存在差异，需显式声明要重试的异常类型才能触发预期的重试行为。

1. 显式指定@Retryable的重试异常范围 #

修改Repository接口的@Retryable注解，明确包含数据库操作相关的异常类型：

@EnableJpaRepositories
@Repository
@Retryable(
    retryFor = {
        DataAccessException.class,
        DataIntegrityViolationException.class,
        SQLException.class
    },
    maxAttempts = 3,  // 与自定义方法保持一致的重试次数
    backoff = @Backoff(delay = 1000),  // 可选：设置重试间隔1秒
    listeners = {"retryListeners"}
)
public interface ExampleRepo extends JpaRepository<ExampleRecord, Long> {

    @Query("select * from ExampleRepo where exampleParam = :exampleParam")
    List<ExampleRecord> exampleQuery(@Param("exampleParam") String exampleParam);

}

2. 统一全局Retry配置 #

确保AppConfig中的重试模板配置与接口注解规则一致，避免冲突：

@Configuration
@EnableRetry
public class AppConfig {

    @Bean
    public RetryTemplate retryTemplate() {
        // 构建重试策略：匹配指定异常，最多重试3次
        SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
        retryPolicy.setMaxAttempts(3);
        
        Map<Class<? extends Throwable>, Boolean> retryableExceptions = new HashMap<>();
        retryableExceptions.put(DataAccessException.class, true);
        retryableExceptions.put(DataIntegrityViolationException.class, true);
        retryableExceptions.put(SQLException.class, true);
        retryPolicy.setRetryableExceptions(retryableExceptions);

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

        RetryTemplate retryTemplate = new RetryTemplate();
        retryTemplate.setRetryPolicy(retryPolicy);
        retryTemplate.setBackOffPolicy(backOffPolicy);
        return retryTemplate;
    }

    @Bean
    public RetryListener retryListeners() {
        return new RetryListener() {
            @Override
            public <T, E extends Throwable> boolean open(RetryContext context, RetryCallback<T, E> callback) {
                System.out.println("Starting retryable method");
                return true;
            }

            @Override
            public <T, E extends Throwable> void close(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
                System.out.println("Finished retryable method");
            }

            @Override
            public <T, E extends Throwable> void onError(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {
                System.out.println("Retryable method threw exception, attempt count: " + context.getRetryCount());
                // 可选：打印异常详情，验证是否匹配目标异常
                throwable.printStackTrace();
            }
        };
    }
}

3. 验证事务配置（若存在） #

如果调用save()的方法带有@Transactional注解，确保事务回滚规则覆盖目标异常，保证异常能被Retry机制捕获：

@Service
public class ExampleService {
    private final ExampleRepo exampleRepo;

    public ExampleService(ExampleRepo exampleRepo) {
        this.exampleRepo = exampleRepo;
    }

    @Transactional(rollbackFor = {DataIntegrityViolationException.class, DataAccessException.class})
    public void saveExample(ExampleRecord record) {
        exampleRepo.save(record);
    }
}

触发数据库异常（如数据截断）后，观察控制台日志：

• 应出现3次Starting retryable method输出
• 对应3次Retryable method threw exception输出
• 最终会抛出异常（而非继续执行后续代码）

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