Spring Batch Step未重新执行导致Elastic查询结果缓存问题排查

Spring 中@Bean注解默认生成单例Bean，仅在Spring上下文初始化阶段执行一次对应方法。你定义rowItemReader Bean时直接在构造参数中调用了usualService.getLastAlerts()，相当于Bean首次初始化时就执行了Elastic查询拿到固定数据集，后续所有作业运行都会复用同一个Reader实例，不会重新执行查询，因此每次批处理拿到的都是首次查询的旧数据。

你当前配置的allowStartIfComplete(true)、Job动态参数逻辑都正常，Step确实每次都在执行，问题仅出在Reader的数据加载时机。

可选以下两种方案修复：

方案1：给Reader添加@StepScope注解（改动最小） #

@StepScope是Spring Batch提供的特殊作用域，标记后Bean会在每一次Step执行时重新初始化，每次运行都会重新调用rowItemReader()方法执行查询，拿到最新数据：

@Bean
@StepScope // 新增此注解
public ItemReader<AlertDocument> rowItemReader() {
    return new UsualItemReader(usualService.getLastAlerts());
}

方案2：将查询逻辑移入Reader的read()方法（可控性更高） #

不要在构造Reader时提前查询数据，改为在Reader执行读操作时再加载数据，自行控制数据的加载时机：

1. 修改UsualItemReader实现：

public class UsualItemReader implements ItemReader<AlertDocument> {
    private final UsualService usualService;
    private List<AlertDocument> cachedData;
    private int cursor = 0;

    // 构造仅注入Service，不执行查询
    public UsualItemReader(UsualService usualService) {
        this.usualService = usualService;
    }

    @Override
    public AlertDocument read() {
        // 首次读的时候再查询数据
        if (cachedData == null) {
            cachedData = usualService.getLastAlerts();
        }
        if (cursor < cachedData.size()) {
            return cachedData.get(cursor++);
        }
        // 读完重置状态，下次Step执行重新查询
        cursor = 0;
        cachedData = null;
        return null;
    }
}

2. 调整Reader的Bean定义：

@Bean
public ItemReader<AlertDocument> rowItemReader(UsualService usualService) {
    return new UsualItemReader(usualService);
}

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