Spring Batch多任务JUnit测试

@Configuration
public class BatchConfig {
    @Bean
    public Job job() {
        return jobBuilderFactory.get("job")
                .start(stepBuilderFactory.get("step1").tasklet((contribution, chunkContext) -> {
                    System.out.println("Step 1 is running");
                    return RepeatStatus.FINISHED;
                }).build())
                .build();
    }
}

@RunWith(SpringRunner.class)
@SpringBootTest
public class BatchJobTest {

    @Autowired
    private JobLauncherTestUtils jobLauncherTestUtils;

    @Test
    public void testJob() throws Exception {
        JobExecution execution = jobLauncherTestUtils.launchJob();
        assertEquals(BatchStatus.COMPLETED, execution.getStatus());
    }
}

@RunWith(SpringRunner.class)
@SpringBootTest
public class BatchIntegrationTest {

    @Autowired
    private JobLauncherTestUtils jobLauncherTestUtils;

    @Test
    public void testJobIntegration() throws Exception {
        // 启动job1
        JobExecution job1Execution = jobLauncherTestUtils.launchJob(new JobParametersBuilder()
                .addLong("time", System.currentTimeMillis())
                .toJobParameters());

        assertEquals(BatchStatus.COMPLETED, job1Execution.getStatus());

        // 启动job2
        JobExecution job2Execution = jobLauncherTestUtils.launchJob(new JobParametersBuilder()
                .addLong("time", System.currentTimeMillis())
                .addString("input.file", "outputFromJob1.txt")
                .toJobParameters());

        assertEquals(BatchStatus.COMPLETED, job2Execution.getStatus());
    }
}