Spring Batch：如何通过Java/Spring内置功能重试超时的ItemProcessor？

这个需求刚好可以用Spring Retry自带的超时重试机制来解决，完全不用自己写复杂的超时逻辑，我给你梳理下具体实现步骤：

核心思路：组合超时重试策略与原有重试策略 #

Spring Retry提供了TimeoutRetryPolicy专门用于触发超时重试，你可以把它和已有的SimpleRetryPolicy组合成CompositeRetryPolicy，这样既能保留原有的重试次数限制，又能实现“超时即重试”的效果。

具体代码实现 #

1. 配置RetryTemplate（组合两种重试策略） #

首先创建一个RetryTemplate Bean，将超时策略和简单重试策略组合起来：

@Configuration
public class RetryConfig {

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

        // 1. 配置超时重试策略：设定2小时超时（单位：毫秒）
        TimeoutRetryPolicy timeoutRetryPolicy = new TimeoutRetryPolicy();
        timeoutRetryPolicy.setTimeout(2 * 60 * 60 * 1000L); // 7200000毫秒 = 2小时

        // 2. 保留你原有的SimpleRetryPolicy：比如最多重试3次
        SimpleRetryPolicy simpleRetryPolicy = new SimpleRetryPolicy();
        simpleRetryPolicy.setMaxAttempts(3);

        // 3. 组合两种策略：满足任一条件（超时/未达重试次数上限）就触发重试
        CompositeRetryPolicy compositeRetryPolicy = new CompositeRetryPolicy();
        compositeRetryPolicy.setPolicies(new RetryPolicy[]{timeoutRetryPolicy, simpleRetryPolicy});
        compositeRetryPolicy.setOptimistic(false); // 只要有一个策略允许重试就执行

        // 4. 可选：配置重试间隔（比如每次重试间隔5分钟）
        FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
        backOffPolicy.setBackOffPeriod(5 * 60 * 1000L); // 300000毫秒 = 5分钟

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

        return retryTemplate;
    }
}

2. 将RetryTemplate应用到ItemProcessor #

有两种方式可以让ItemProcessor使用这个重试模板：

方式一：使用@Retryable注解（更简洁）

直接在你的ItemProcessor的process方法上添加@Retryable注解，指定使用我们配置的组合策略：

@Component
public class CustomItemProcessor implements ItemProcessor<InputItem, OutputItem> {

    @Retryable(
        retryPolicy = "compositeRetryPolicy", // 对应我们配置的组合策略Bean名
        backoff = @Backoff(delay = 300000) // 5分钟重试间隔，和配置一致
    )
    @Override
    public OutputItem process(InputItem item) throws Exception {
        // 这里写你耗时30-35分钟的业务逻辑
        return generateOutput(item);
    }

    // 重试耗尽后的兜底处理方法（可选）
    @Recover
    public OutputItem recover(Exception ex, InputItem item) {
        // 比如返回默认值、记录告警日志等
        log.error("ItemProcessor重试耗尽，item: {}", item.getId(), ex);
        return new OutputItem().setId(item.getId()).setStatus("FAILED");
    }
}

方式二：手动用RetryTemplate包装调用（更灵活）

如果需要更灵活的控制，可以在调用ItemProcessor时手动用RetryTemplate包裹：

@Service
public class BatchProcessingService {

    @Autowired
    private RetryTemplate itemProcessorRetryTemplate;

    @Autowired
    private CustomItemProcessor itemProcessor;

    public OutputItem processItemWithRetry(InputItem item) {
        return itemProcessorRetryTemplate.execute(retryContext -> {
            return itemProcessor.process(item);
        });
    }
}

关键注意事项 #

• 超时判断逻辑：TimeoutRetryPolicy是从方法调用开始计时，只要线程执行时间超过设定值就会触发重试，不管任务是否真的卡住，这个逻辑刚好匹配你的需求。
• 线程安全：确保你的ItemProcessor是线程安全的，因为重试过程中会重复调用process方法，避免共享状态导致的问题。
• 策略组合逻辑：CompositeRetryPolicy的optimistic参数设为false，意味着只要超时或者未达重试次数上限，就会触发重试；如果设为true，需要两个策略都允许才会重试，这里显然应该用false。

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