Spring Batch：如何将Step1处理器数据传递至Step2处理器？

这是预期行为吗？ #

是的，这属于Spring Batch的预期行为。@BeforeStep注解默认仅作用于StepExecutionListener实现类，或是被Spring容器管理且明确关联到Step的监听器类。Processor本身默认不会被自动注册为Step的监听器，因此标注在Processor中的@BeforeStep方法不会被触发。

如何让@BeforeStep在Processor类中生效？ #

有两种常用解决方式：

方式一：让Processor实现StepExecutionListener接口 #

让Step2的Processor类实现StepExecutionListener接口，并重写beforeStep方法（可以直接使用接口方法，也可保留@BeforeStep注解，只要实现接口就能被Spring Batch识别）。示例代码：

public class Step2Processor implements ItemProcessor<Input, Output>, StepExecutionListener {

    private StepExecution stepExecution;

    @Override
    public void beforeStep(StepExecution stepExecution) {
        this.stepExecution = stepExecution;
        // 从JobExecutionContext获取Step1传递的数据
        ExecutionContext jobContext = stepExecution.getJobExecution().getExecutionContext();
        Object dataFromStep1 = jobContext.get("keyFromStep1");
    }

    @Override
    public Output process(Input item) throws Exception {
        // 业务处理逻辑，可使用stepExecution中的数据
        return null;
    }
}

方式二：在Step配置中显式注册Processor为监听器 #

若不想让Processor实现StepExecutionListener接口，可在Step配置时，将Processor对象添加为Step的监听器。示例配置：

@Bean
public Step step2(ItemReader<Input> reader, Step2Processor processor, ItemWriter<Output> writer) {
    return stepBuilderFactory.get("step2")
            .<Input, Output>chunk(10)
            .reader(reader)
            .processor(processor)
            .writer(writer)
            .listener(processor) // 显式将processor注册为Step监听器
            .build();
}

这样Spring Batch会将Processor当作Step监听器处理，@BeforeStep注解的方法就能正常执行。

补充说明 #

跨Step传递数据的核心是通过JobExecutionContext（跨Step共享）或StepExecutionContext（当前Step内使用）实现。Step1的处理器可将数据存入JobExecutionContext，Step2的Processor通过@BeforeStep获取StepExecution后，就能从JobExecutionContext中取出数据。

内容的提问来源于stack exchange，提问作者Mahmudul Khan