在Spring Batch中重复步骤x次

Question

我正在使用配置了注释的Spring Batch 3.0.3来创建一个批处理作业，该作业以不确定的次数重复一个步骤。

我的第一步是将重复步骤中使用的项目列表读入内存。我希望重复这些步骤来遍历这个工作范围列表。

如何将作业配置为运行相同的步骤x次？我在xml中看到了指定下一步运行的示例。我想我可以在一个无限循环中指向彼此的两个步骤，直到列表被迭代。这行得通吗？有没有办法通过注释来实现？下面是我的主配置文件，其中有些代码不起作用。

@ComponentScan(excludeFilters = @Filter(IgnoreDuringScan.class))
@EnableAutoConfiguration
@EnableBatchProcessing
@Loggable
public class BatchCrudConfiguration
{
    @Bean
    public Job batchCRUDJob(JobBuilderFactory jobBuilderFactory, Step[] processSheetSteps)
    {
        JobBuilder jobBuilder = jobBuilderFactory.get("batchCRUDJob").incrementer(new RunIdIncrementer());
        FlowBuilder<FlowJobBuilder> jobFlowBuilder = jobBuilder.flow(processSheetSteps[0]);
        for (int i = 1; i < processSheetSteps.length; i++)
        {
            jobFlowBuilder = jobFlowBuilder.next(processSheetSteps[i]);
        }
        return jobFlowBuilder.end().build();
    }

    @Bean
    public Step[] processSheetSteps(
            StepBuilderFactory stepBuilderFactory,
            RawDataReader[] readers,
            DelegatingWriter writer,
            DelegatingProcessor processor,
            @Value("${batchcrud.chunkSize}") int chunkSize)
    {
        int numberOfReaders = readers.length;
        Step[] steps = new Step[numberOfReaders];
        for (int i = 0; i < numberOfReaders; i++)
        {
            steps[i] = stepBuilderFactory.get("processSheet" + i + "Step").<RawData, DataItem>
                    chunk(chunkSize).reader(readers[i]).processor(processor).writer(writer).build();
        }
        return steps;
    }

Answer 1

我将通过以下方式来实现这一点：

1. 第一步加载列表
2. 第二步处理列表中的项目
3. 第二个步骤有一个StepExecutionListener，用于评估列表中是否有更多项目需要处理。如果是这样，它将返回映射到同一步骤的ExitStatus。如果没有，它将返回一个映射到结束作业或继续作业（基于流的其余部分）的ExitStatus

例如：

StepExecutionListener

public class MyListener {

    @Autowired
    private List myItems;

    @AfterStep
    public ExitStatus afterStep(StepExecution stepExecution) {
        if(myItems.size() > 0) {
            return new ExitStatus("CONTINUE");
        }
        else {
            return new ExitStatus("FINISHED");
        }
    }
}

作业配置

...
@Bean
public Step step1() {...}

@Bean
public MyListener listener() {..}

@Bean
public Step step2(MyListener listener) {
    return stepBuilder.get("step2")
                .tasklet(myTasklet()) // Replace this piece as needed
                .listener(listener).build();
}

@Bean
public Job job1(Step step1, Step step2) {
    return jobBuilder.get("job1")
                     .start(step1)
                     .next(step2).on("CONTINUE").to(step2).on("FINISHED").end()
                     .build();
}
...

注意：我还没有测试过这段代码，所以可能会出现拼写错误等。