Spring Batch步骤失败时如何终止整个作业？

你的问题核心在于：仅通过StepExecutionListener返回ExitStatus.FAILED并不会自动终止作业，因为Spring Batch判断作业是否终止的依据是步骤的BatchStatus，而非ExitStatus。ExitStatus只是额外的退出标识，不会直接影响作业的执行流程。

以下是具体的解决方法：

方法一：在组件中抛出异常（推荐） #

如果你的阅读器、处理器或写入器在执行时遇到错误，直接抛出异常，Spring Batch会自动将步骤标记为失败，进而终止整个作业。

比如在处理器中：

public class WebTaxonomyItemProcessor implements ItemProcessor<WebTaxonomy, WebTaxonomy> {
    // ... 其他代码
    @Override
    public WebTaxonomy process(WebTaxonomy item) throws Exception {
        // 自定义失败条件
        if (item.getWebsiteName() == null) {
            throw new IllegalArgumentException("网站名称不能为空"); // 抛出异常触发步骤失败
        }
        // ... 正常处理逻辑
        return item;
    }
}

这种方式是Spring Batch的默认行为，无需额外配置监听器即可实现步骤失败时终止作业。

方法二：修改监听器，标记步骤为失败状态 #

如果你需要通过监听器来判断步骤是否失败，需要在afterStep方法中同时设置步骤的BatchStatus为FAILED，而不仅仅返回ExitStatus.FAILED：

import org.springframework.batch.core.BatchStatus;
import org.springframework.batch.core.ExitStatus;
import org.springframework.batch.core.StepExecution;
import org.springframework.batch.core.StepExecutionListener;

public class StepResultListener implements StepExecutionListener {
    @Override
    public void beforeStep(StepExecution stepExecution) {
        System.out.println("Called beforeStep().");
    }

    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {
        System.out.println("Called afterStep().");
        String exitCode = stepExecution.getExitStatus().getExitCode();
        if (exitCode.equals("FAILED")){
            stepExecution.setStatus(BatchStatus.FAILED); // 关键：标记步骤为失败状态
            stepExecution.setExitStatus(ExitStatus.FAILED);
            return ExitStatus.FAILED;
        }
        return ExitStatus.COMPLETED;
    }
}

修改后，当步骤的ExitStatus为FAILED时，监听器会将步骤的运行状态设置为失败，作业会随之终止。

方法三：配置作业的容错策略（可选） #

如果需要更精细的控制，可以通过StepBuilder配置容错策略，例如设置不允许跳过异常，确保任何异常都直接导致步骤失败：

@Bean
public Step stepOne(ObjectMapper mapper, IdProvider webIdProvider) {
    return stepBuilderFactory.get("stepOne")
            .<WebTaxonomy, WebTaxonomy> chunk(10)
            .reader(readerWeb())
            .processor(processorWeb(mapper, webIdProvider))
            .writer(writerWeb(mapper))
            .faultTolerant()
            .skipPolicy((throwable, skipCount) -> false) // 不允许跳过任何异常
            .listener(new StepResultListener())
            .build();
}

这种方式会强制所有异常都触发步骤失败，进而终止作业。

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