如何在Spring Batch中让步骤异常时仍执行指定步骤

针对你的需求——step7必须在所有前置步骤（1-6）成功或失败时都执行，step8仅在前置步骤无异常时执行，可以通过两种方案实现，具体选择取决于你的清理逻辑复杂度：

方案一：使用Flow流程控制（推荐用于独立Step的清理逻辑） #

这种方式将清理步骤（step7）设为job的"必经收尾步骤"，通过状态跳转控制流程，完全利用Spring Batch内置的流程管理机制，适合step7本身是完整Step（有独立配置、监控需求）的场景。

调整后的XML配置如下：

<job id="myJob">
    <!-- 主流程：step1到step6的线性执行 -->
    <flow id="mainProcessingFlow">
        <step id="step1" next="step2"/>
        <step id="step2" next="step3"/>
        <step id="step3" next="step4"/>
        <step id="step4" next="step5"/>
        <step id="step5" next="step6"/>
        <step id="step6"/>
    </flow>

    <!-- 无论主流程成功（COMPLETED）还是失败（FAILED），都跳转到step7执行清理 -->
    <next on="*" to="step7"/>

    <!-- 只有主流程成功（step7执行后状态仍为COMPLETED），才执行step8 -->
    <next on="COMPLETED" to="step8"/>

    <!-- 如果主流程失败，step7执行完后直接结束job，不执行step8 -->
    <end on="FAILED"/>
</job>

<!-- 清理步骤：无论前置状态如何都会执行 -->
<step id="step7">
    <!-- 你的清理临时文件配置 -->
</step>

<!-- 最终成功步骤：仅在所有前置步骤无异常时执行 -->
<step id="step8">
    <!-- 你的后续处理配置 -->
</step>

配置说明： #

• mainProcessingFlow：封装原有的step1-step6线性流程，任意步骤失败会让整个flow的状态变为FAILED，成功则为COMPLETED。
• <next on="*" to="step7"/>：*匹配所有结束状态，确保mainFlow结束后必然执行step7。
• <next on="COMPLETED" to="step8"/>：只有当step7执行完成（且前置主流程成功）时，才触发step8。
• <end on="FAILED"/>：主流程失败时，step7执行完直接终止job，跳过step8。

方案二：使用JobExecutionListener（适合简单清理逻辑） #

如果你的清理逻辑只是简单的文件删除操作，不需要Step级别的监控、重试等特性，可以用JobExecutionListener在job结束后自动执行清理，无需调整原有流程结构。

步骤1：实现Listener类 #

public class TempFileCleanupListener implements JobExecutionListener {

    @Override
    public void beforeJob(JobExecution jobExecution) {
        // 无需前置操作
    }

    @Override
    public void afterJob(JobExecution jobExecution) {
        // 这里写清理临时文件的逻辑
        // 例如：Files.deleteIfExists(Paths.get("/temp/batch-files"));
    }
}

步骤2：XML中配置Listener #

<job id="myJob">
    <!-- 注册监听器，job结束后自动执行清理 -->
    <listeners>
        <listener ref="tempFileCleanupListener"/>
    </listeners>

    <!-- 原有的线性流程，成功则执行step8 -->
    <step id="step1" next="step2"/>
    <step id="step2" next="step3"/>
    <step id="step3" next="step4"/>
    <step id="step4" next="step5"/>
    <step id="step5" next="step6"/>
    <step id="step6" next="step8"/>
    <step id="step8"/>
</job>

<!-- 注册监听器Bean -->
<bean id="tempFileCleanupListener" class="com.yourpackage.TempFileCleanupListener"/>

说明： #

• afterJob方法会在job的所有步骤执行完成（无论成功还是失败）后触发，确保清理逻辑始终执行。
• 这种方式代码更简洁，但无法对清理逻辑进行Step级别的监控（比如查看执行时长、重试次数等）。

方案对比 #

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