Spring Batch重复执行同一作业无处理逻辑触发问题排查

你遇到的核心问题是：第二次执行同一作业时，Spring Batch复用了已完成的JobInstance，因此直接返回COMPLETED状态，不会触发Reader/Processor/Writer的执行。

最可能的触发原因是两次执行的JobParameters实际完全相同——尽管你添加了currentTime参数，但测试中代码执行速度极快，两次调用runJobAndGetExecution的操作可能在同一毫秒内完成，导致System.currentTimeMillis()返回相同数值。如果此时JobID参数的区分逻辑未生效（或也出现重复），最终会让Spring Batch判定两次执行属于同一个JobInstance；而该实例已经处于COMPLETED状态，因此直接返回完成状态，不会重新执行步骤。

Spring Batch中，JobInstance由作业名称 + 所有标识性（identifying）Job参数共同确定。只要标识参数组合完全一致，就会复用同一个实例；若实例已完成，就不会再次执行步骤。

你可以通过以下方式确认问题根源：

1. 打印参数值，检查两次currentTime是否重复：

   long currentTime = System.currentTimeMillis();
   System.out.println("当前时间戳：" + currentTime);
   JobParameters param = new JobParametersBuilder()
       .addString("JobID", jobId)
       .addLong("currentTime", currentTime)
       .toJobParameters();
   

2. 查询JobRepository中的实例数量，验证是否创建了新的JobInstance：

   // 第二次执行后添加
   List<JobInstance> jobInstances = jobRepository.getJobInstances(job.getName(), 0, 10);
   assertEquals(2, jobInstances.size()); // 若结果为1，说明参数重复
   

针对参数重复问题，你可以采用以下方式确保每次执行的JobParameters绝对唯一：

1. 使用纳秒级时间戳：替换System.currentTimeMillis()为System.nanoTime()，避免同一毫秒内参数重复：

   JobParameters param = new JobParametersBuilder()
       .addString("JobID", jobId)
       .addLong("currentTime", System.nanoTime())
       .toJobParameters();
   

2. 添加随机数参数：额外增加随机数参数，确保参数组合唯一：

   JobParameters param = new JobParametersBuilder()
       .addString("JobID", jobId)
       .addLong("currentTime", System.currentTimeMillis())
       .addInt("randomSeed", new Random().nextInt(Integer.MAX_VALUE))
       .toJobParameters();
   

3. 检查参数标识性配置：确保JobID和currentTime都被标记为标识性参数（默认所有参数都是标识性的，除非你在作业配置中显式将其设为非标识性）。若作业配置过滤了这些参数，需调整配置保留它们作为标识依据。

另外，你可以复用SimpleJobLauncher实例，无需每次执行都创建新实例，优化代码：

// 在测试类中初始化一次
private SimpleJobLauncher jobLauncher;

@BeforeEach
void setUp() {
    jobLauncher = new SimpleJobLauncher();
    jobLauncher.setJobRepository(jobRepository);
    jobLauncher.setTaskExecutor(new SyncTaskExecutor());
}

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