Spring Boot Batch MongoItemReader重复执行不读取文档问题

问题本质 #

MongoItemReader是有状态的ItemReader，它会在执行过程中记录当前读取的位置（基于排序字段的最后读取值），该状态会被Spring Batch持久化到作业仓库（默认内存或数据库）。当重复执行同一作业实例时，Spring Batch会从上次记录的状态位置继续读取，而非重新执行查询，这就导致你看到的“匹配文档无法读取”——实际是作业复用了之前的执行状态，跳过了已读取过的记录。

而FlatFileItemReader这类阅读器若未配置状态跟踪，每次执行都会从头读取，因此不存在该问题。

可行解决方案 #

1. 每次执行创建新作业实例 #

启动作业时传入唯一参数（如时间戳、随机数），让Spring Batch每次生成新的作业实例，避免复用旧状态。示例代码：

@RestController
public class BatchController {
    @Autowired
    private JobLauncher jobLauncher;
    @Autowired
    private Job myJob;

    @PostMapping("/run-batch")
    public String runBatch() throws Exception {
        JobParameters parameters = new JobParametersBuilder()
                .addLong("timestamp", System.currentTimeMillis()) // 唯一标识参数
                .toJobParameters();
        jobLauncher.run(myJob, parameters);
        return "Batch job started";
    }
}

2. 关闭MongoItemReader的状态保存（按需使用） #

若业务无需故障恢复能力，可将saveState设为false，让Reader不再记录读取位置。修改Reader配置：

@Bean
MongoItemReader<MyTarget> myReader() {
    MongoItemReader<MyTarget> reader = new MongoItemReader<>();
    reader.setTemplate(mongoTemplate);
    reader.setCollection("MyCollection");

    Map<String,Sort.Direction> sort= new HashMap<>();
    sort.put("_id",Sort.Direction.ASC);

    reader.setSort(sort);
    reader.setTargetType(MyTarget.class);
    reader.setQuery(mongoQuery);
    reader.setSaveState(false); // 关闭状态持久化
    return reader;
}

注意：关闭状态保存后，作业中途失败重启时会从头读取，无法从失败点恢复，仅适合无故障恢复需求的简单场景。

3. 手动重置作业实例状态 #

若需复用作业实例但要清除旧状态，可通过JobRepository手动更新作业执行状态：

@Autowired
private JobRepository jobRepository;

public void resetJobExecutionStatus(String jobName) {
    List<JobInstance> jobInstances = jobRepository.getJobInstances(jobName, 0, Integer.MAX_VALUE);
    for (JobInstance instance : jobInstances) {
        List<JobExecution> executions = jobRepository.getJobExecutions(instance);
        for (JobExecution execution : executions) {
            execution.setStatus(BatchStatus.COMPLETED);
            execution.setEndTime(new Date());
            jobRepository.update(execution);
        }
    }
}

核心知识点 #

• Spring Batch的ItemReader分为有状态和无状态两类，有状态Reader支持故障恢复，依赖JobRepository存储执行状态；
• MongoItemReader默认开启状态保存，作业实例的唯一性由JobParameters决定，相同参数会复用同一实例的状态。

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