Spring Batch如何在item reader对应文件不存在时跳过整个步骤

一、设置Reader为非strict模式 #

Spring Batch内置的文件读取器（比如FlatFileItemReader、MultiResourceItemReader等）都自带strict属性，默认值为true（严格模式），文件不存在时会直接抛出初始化异常终止作业。
将属性设置为false即可关闭严格模式，文件不存在时Reader会直接返回null，不会抛出异常，步骤会正常执行完成但不会处理任何数据。
配置示例：

• Java 配置：

@Bean
public FlatFileItemReader<YourData> inputReader() {
    FlatFileItemReader<YourData> reader = new FlatFileItemReader<>();
    reader.setResource(new FileSystemResource("/path/to/your/file.csv"));
    // 关闭严格模式
    reader.setStrict(false);
    // 其他reader配置省略
    return reader;
}

• XML 配置：

<bean id="inputReader" class="org.springframework.batch.item.file.FlatFileItemReader">
    <property name="resource" value="file:/path/to/your/file.csv"/>
    <property name="strict" value="false"/>
    <!-- 其他配置省略 -->
</bean>

注意：该方案仅会跳过数据处理逻辑，步骤本身还是会触发执行（包括步骤监听器、上下文初始化等逻辑），如果需要完全不执行整个步骤，请使用第二种方案。

二、前置校验文件存在性，直接跳过整个步骤 #

可以通过流程决策器或者步骤监听器的方式，在步骤执行前判断文件是否存在，不存在时直接跳过整个步骤，不会触发Reader、Processor、Writer的任何逻辑。

实现方式1：使用JobExecutionDecider流程决策器 #

1. 自定义文件存在性决策器：

public class FileExistsDecider implements JobExecutionDecider {
    @Value("${input.file.path}")
    private Resource inputFile;

    @Override
    public FlowExecutionStatus decide(JobExecution jobExecution, StepExecution stepExecution) {
        try {
            if (inputFile.exists() && inputFile.isReadable()) {
                return new FlowExecutionStatus("FILE_EXISTS");
            }
        } catch (IOException e) {
            // 异常场景可按需调整逻辑
        }
        return new FlowExecutionStatus("FILE_NOT_EXISTS");
    }
}

2. 在Job配置中加入分支判断：

@Bean
public Job dataImportJob(Step fileProcessStep, FileExistsDecider fileExistsDecider) {
    return jobBuilderFactory.get("dataImportJob")
            .start(fileExistsDecider)
                // 文件存在时执行处理步骤
                .on("FILE_EXISTS").to(fileProcessStep)
                // 文件不存在时直接结束作业，也可配置跳转到其他后续步骤
                .on("FILE_NOT_EXISTS").end()
            .end()
            .build();
}

实现方式2：使用StepExecutionListener步骤监听器 #

如果不想调整Job的流程结构，可以给目标步骤添加前置监听器，文件不存在时直接标记步骤为跳过状态：

1. 自定义步骤监听器：

@Component
public class FileExistsCheckListener implements StepExecutionListener {
    @Value("${input.file.path}")
    private Resource inputFile;

    @Override
    public void beforeStep(StepExecution stepExecution) {
        try {
            if (!inputFile.exists() || !inputFile.isReadable()) {
                // 标记步骤为已跳过，不会执行后续的Reader等逻辑
                stepExecution.setStatus(BatchStatus.SKIPPED);
                stepExecution.setExitStatus(ExitStatus.COMPLETED);
            }
        } catch (IOException e) {
            stepExecution.setStatus(BatchStatus.FAILED);
            stepExecution.addFailureException(e);
        }
    }

    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {
        return stepExecution.getExitStatus();
    }
}

2. 给目标步骤绑定监听器：

@Bean
public Step fileProcessStep(FlatFileItemReader<YourData> reader, 
                            ItemProcessor<YourData, YourData> processor, 
                            ItemWriter<YourData> writer, 
                            FileExistsCheckListener listener) {
    return stepBuilderFactory.get("fileProcessStep")
            .<YourData, YourData>chunk(100)
            .reader(reader)
            .processor(processor)
            .writer(writer)
            .listener(listener)
            .build();
}

内容的提问来源于stack exchange，提问作者Prathviraj Singh Chouhan