Spring Batch中Spring Retry未触发重试问题求助

核心原因 #

Spring Retry的@Retryable注解基于AOP代理实现，但Spring Batch调用FlowDecider.decide()方法时，是直接调用原始对象的方法，而非Spring生成的代理对象。这导致AOP切面无法拦截方法调用，重试逻辑自然不会触发。

解决方案 #

放弃注解方式，改用RetryTemplate手动实现重试逻辑，具体步骤如下：

1. 配置RetryTemplate Bean
   在你的配置类中添加RetryTemplate配置，指定重试次数和触发重试的异常类型：

@Configuration
@ComponentScan(basePackages = { "xxxxxxxx", "xxxxxxxx" })
@EnableBatchProcessing
@Import(DataSourceConfig.class)
@EnableRetry
public class BatchConfiguration extends DefaultBatchConfigurer {

    @Bean
    public RetryTemplate retryTemplate() {
        SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
        // 设置最大重试次数
        retryPolicy.setMaxAttempts(3);
        // 指定触发重试的异常
        Map<Class<? extends Throwable>, Boolean> exceptionsMap = new HashMap<>();
        exceptionsMap.put(ValidationException.class, true);
        retryPolicy.setRetryableExceptions(exceptionsMap);

        RetryTemplate retryTemplate = new RetryTemplate();
        retryTemplate.setRetryPolicy(retryPolicy);
        // 可选：添加固定间隔重试策略
        retryTemplate.setBackOffPolicy(new FixedBackOffPolicy());

        return retryTemplate;
    }
}

2. 在ValidationFlowDecider中注入RetryTemplate并手动调用
   修改decide方法，通过RetryTemplate包装业务逻辑：

public class ValidationFlowDecider implements FlowDecider {

    private final RetryTemplate retryTemplate;
    private final ValidationStatus validationStatus;
    private static final Logger LOG = LoggerFactory.getLogger(ValidationFlowDecider.class);

    // 构造注入RetryTemplate
    public ValidationFlowDecider(RetryTemplate retryTemplate, ValidationStatus validationStatus) {
        this.retryTemplate = retryTemplate;
        this.validationStatus = validationStatus;
    }

    @Override
    public FlowExecutionStatus decide(JobExecution jobExec, StepExecution stepExec) {
        try {
            return retryTemplate.execute(context -> {
                boolean passed = validationStatus.getValidationStatus();
                if (!passed) {
                    LOG.info("******Batch job validation FAILED******");
                    throw new ValidationException("Batch job validation FAILED");
                }
                return FlowExecutionStatus.COMPLETED;
            });
        } catch (RetryException e) {
            // 重试耗尽后的处理逻辑，返回失败状态
            LOG.error("All retry attempts failed for batch job validation", e);
            return FlowExecutionStatus.FAILED;
        }
    }
}

额外说明 #

• 若坚持使用注解方式，需确保ValidationFlowDecider是Spring管理的Bean，且通过代理对象调用decide方法，但由于Spring Batch内部直接调用该方法，这种方式大概率无法生效，因此优先推荐手动使用RetryTemplate的方案。
• 可根据需求调整重试策略，比如改用ExponentialBackOffPolicy实现指数退避的重试间隔。

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