Spring Batch实现步骤失败时作业继续执行并记录失败状态

针对动态生成步骤的场景，完全可以实现单个步骤失败时作业继续执行、同时标记该步骤为FAILED状态的需求，核心思路是捕获步骤执行异常并手动标记状态，同时配置作业流忽略单步骤失败的影响，具体实现如下：

1. 修改步骤构建逻辑，捕获异常并标记状态 #

修改你的step方法，在Tasklet中捕获service.action(id)抛出的所有异常，手动将步骤的退出状态设置为FAILED，同时返回RepeatStatus.FINISHED避免异常向上抛出终止作业：

public Step step(Long id) {
    return stepBuilderFactory.get("STEP_" + id)
        .tasklet((contribution, chunkContext) -> {
            try {
                service.action(id);
                // 执行成功，标记步骤为完成状态
                contribution.setExitStatus(ExitStatus.COMPLETED);
            } catch (Exception e) {
                // 记录异常日志（根据实际需求调整日志级别和内容）
                log.error("步骤STEP_{}执行失败", id, e);
                // 手动标记步骤为失败状态
                contribution.setExitStatus(ExitStatus.FAILED);
            }
            return RepeatStatus.FINISHED;
        })
        // 可选：允许步骤即使之前失败过，重新执行作业时仍能再次运行
        .allowStartIfComplete(true)
        .build();
}

2. 配置作业流，确保单步骤失败不中断后续执行 #

默认情况下，Spring Batch会在某个步骤失败后终止作业，因此需要通过Flow配置作业流，指定无论前一个步骤的退出状态是什么（成功/失败），都继续执行下一个步骤：

@Bean
public Job dynamicStepsJob(JobBuilderFactory jobBuilderFactory, List<Step> dynamicSteps) {
    if (dynamicSteps.isEmpty()) {
        throw new IllegalArgumentException("动态步骤列表不能为空");
    }

    // 构建作业流
    FlowBuilder<Flow> flowBuilder = new FlowBuilder<>("dynamicStepsFlow");
    Flow currentFlow = flowBuilder.start(dynamicSteps.get(0));

    // 依次添加后续步骤，设置无论前一步状态如何都执行
    for (int i = 1; i < dynamicSteps.size(); i++) {
        currentFlow = currentFlow.next(dynamicSteps.get(i)).on("*").end();
    }

    // 构建作业，可选添加监听器自定义作业最终状态
    return jobBuilderFactory.get("dynamicStepsJob")
        .start(currentFlow)
        .end()
        .listener(new JobExecutionListener() {
            @Override
            public void afterJob(JobExecution jobExecution) {
                // 检查是否有失败的步骤，自定义作业最终状态
                boolean hasFailedStep = jobExecution.getStepExecutions().stream()
                    .anyMatch(stepExec -> ExitStatus.FAILED.equals(stepExec.getExitStatus()));
                jobExecution.setExitStatus(hasFailedStep ? ExitStatus.FAILED : ExitStatus.COMPLETED);
            }
        })
        .build();
}

关键说明 #

• 手动设置contribution.setExitStatus(ExitStatus.FAILED)会将对应的StepExecution标记为失败状态，该状态会被Spring Batch持久化，可通过JobRepository查询到步骤的执行结果
• 作业流配置中的.on("*")表示匹配所有退出状态，确保后续步骤不受前一步失败的影响
• 作业监听器的作用是根据所有步骤的执行结果，统一设置作业的最终状态（可选，若不需要可省略）

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