Spring Batch中如何从StepExecutionListener的beforeStep中跳过当前步骤

下面提供两种可直接落地的常用方案：

方案1：基于StepExecutionListener + 步骤跳转规则 #

该方案可直接复用你已实现的CustomStepListener，改造成本最低。

实现逻辑 #

1. 在beforeStep方法中完成数据库校验，确认需要跳过步骤时，给当前StepExecution设置自定义退出码并标记终止执行，此时步骤不会进入实际的读/处理/写业务逻辑
2. 在作业配置中给该步骤绑定跳转规则，匹配到自定义的跳过退出码时直接跳转到下一个步骤

代码示例 #

CustomStepListener 实现

@Component
public class CustomStepListener implements StepExecutionListener {

    @Autowired
    private YourBizRepository bizRepository;

    @Override
    public void beforeStep(StepExecution stepExecution) {
        // 按业务规则校验该步骤是否已执行过
        boolean isExecuted = bizRepository.existsByStepNameAndJobDate(
            stepExecution.getStepName(),
            // 补充你的业务校验参数，比如批次号、业务日期等
            stepExecution.getJobParameters().getString("bizDate")
        );
        if (isExecuted) {
            // 设置自定义跳过状态码
            stepExecution.setExitStatus(new ExitStatus("SKIPPED"));
            // 终止当前步骤执行，不会运行步骤的业务逻辑
            stepExecution.setTerminateOnly();
        }
    }

    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {
        // 可选：补充跳过日志记录、业务状态更新逻辑
        if ("SKIPPED".equals(stepExecution.getExitStatus().getExitCode())) {
            // 日志打印逻辑
        }
        return stepExecution.getExitStatus();
    }
}

作业配置（Java Config 示例）

@Configuration
@EnableBatchProcessing
public class BatchJobConfig {
    @Autowired
    private JobBuilderFactory jobBuilderFactory;
    @Autowired
    private StepBuilderFactory stepBuilderFactory;
    @Autowired
    private CustomStepListener customStepListener;
    // 注入业务步骤
    @Autowired
    private Step firstStep;
    @Autowired
    private Step nextStep;

    @Bean
    public Job batchJob() {
        return jobBuilderFactory.get("multiStepBatchJob")
                .start(firstStep)
                    // 匹配到跳过状态，直接跳转到下一个步骤
                    .on("SKIPPED").to(nextStep)
                    // 正常执行完成也跳转到下一个步骤
                    .from(firstStep).on("COMPLETED").to(nextStep)
                // 后续其他步骤配置
                .end()
                .build();
    }

    // 给需要校验的步骤绑定自定义监听器
    @Bean
    public Step firstStep() {
        return stepBuilderFactory.get("firstStep")
                .<Input, Output>chunk(100)
                .reader(yourReader())
                .processor(yourProcessor())
                .writer(yourWriter())
                .listener(customStepListener)
                .build();
    }
}

方案2：基于JobExecutionDecider 决策器 #

该方案适合多个步骤都需要类似跳过校验的场景，校验逻辑和步骤业务逻辑完全解耦，复用性更高。

实现逻辑 #

将校验逻辑抽成独立的决策器，在作业流配置中，执行目标步骤前先运行决策器，根据决策器返回的状态判断是执行当前步骤，还是直接跳转到下一个步骤。

代码示例 #

自定义决策器实现

@Component
public class StepSkipDecider implements JobExecutionDecider {
    @Autowired
    private YourBizRepository bizRepository;

    @Override
    public FlowExecutionStatus decide(JobExecution jobExecution, StepExecution stepExecution) {
        String stepName = "firstStep"; // 可根据作业上下文动态获取需要校验的步骤名
        String bizDate = jobExecution.getJobParameters().getString("bizDate");
        boolean isExecuted = bizRepository.existsByStepNameAndJobDate(stepName, bizDate);
        // 返回状态供作业流判断
        return isExecuted ? new FlowExecutionStatus("SKIP") : new FlowExecutionStatus("EXECUTE");
    }
}

作业配置

@Bean
public Job batchJob(@Autowired StepSkipDecider stepSkipDecider) {
    return jobBuilderFactory.get("multiStepBatchJob")
            .start(stepSkipDecider)
                // 决策器返回执行状态，运行目标步骤
                .on("EXECUTE").to(firstStep)
                // 决策器返回跳过状态，直接跳转到下一个步骤
                .from(stepSkipDecider).on("SKIP").to(nextStep)
            .from(firstStep).next(nextStep)
            // 后续其他步骤配置
            .end()
            .build();
}

注意事项 #

• 步骤跳过的场景建议补充日志记录或业务状态标记，方便后续问题排查和对账
• 如果作业有重启需求，注意和Spring Batch原生的重启逻辑兼容，可配合步骤的allowStartIfComplete属性调整规则
• 两种方案都兼容XML配置形式，逻辑和Java Config一致，仅配置写法不同

内容的提问来源于stack exchange，提问作者Shahjalal Sakil