Spring Batch：CompositeItemWriter、@BeforeStep和控制步骤执行

Question

我最近偶然发现了一个非常扭曲的Spring批次问题。要求如下：

我有两个主要步骤：

• 第一个从oracle数据库中读取一些数据，从一个表中写入另一个表
• 第二个基于第一步处理的数据，完成其他一些数据库工作

从设计的角度来看，第一步如下所示：

    @Bean
    public Step myFirstStep(JdbcCursorItemReader<Revision> reader) {

        return stepBuilderFactory.get("my-first-step")
            .<Revision, Revision>chunk(1)
            .reader(readerRevisionNumber)
            .writer(compositeItemWriter())
            .listener(executionContextPromotionListener())
            .build();

复合项目编写器：

    @Bean
    public CompositeItemWriter<Revision> compositeItemWriter() {
        CompositeItemWriter writer = new CompositeItemWriter();
        writer.setDelegates(Arrays.asList(somewriter(), someOtherwriter(), aWriterThatIsSupposedToPassDataToAnotherStep()));
        return writer;
    }

虽然前两位作者并不复杂，但我的兴趣集中在第三位。

aWriterThatIsSupposedToPassDataToAnotherStep()

正如您可能已经猜到的，这一个将用于获取之前正在处理的一些数据，以便在我的第二步中进行升级：

@Component
@StepScope
public class AWriterThatIsSupposedToPassDataToAnotherStep implements ItemWriter<SomeEntity> {

    private StepExecution stepExecution;

    public void write(List<? extends SomeEntity> items) {

        ExecutionContext stepContext = this.stepExecution.getExecutionContext();
        stepContext.put("revisionNumber", items.stream().findFirst().get().getSomeField());
        System.out.println("writing : " + items.stream().findFirst().get().getSomeField()+ "to ExecutionContext");
    }

    @BeforeStep
    public void saveStepExecution(StepExecution stepExecution) {
        this.stepExecution = stepExecution;
    }

}

问题是：只要这个writer是复合writer列表（如上所述）的一部分，我上一个writer的@BeforeStep就永远不会执行，这最终导致我无法将信息传输到执行上下文。在步骤定义中，用我的单个“awriterthatissedtopassdatatoatotherstep”替换CompositeItemWriter时，它会得到正确的执行。

它是否与某种申报单或其他东西有关？

非常感谢进一步的帮助。

Answer 1

找到了解决方案（在我的一些同事的帮助下），并来源：https://stackoverflow.com/a/39698653/1957764

您需要将编写器声明为复合编写器的一部分，并声明一个步骤侦听器，以使其执行@BeforeStep注释方法。