Spring Batch中复制文件后，后续步骤如何访问多文件资源？

看起来你已经用Tasklet完成了文件迁移，但后续步骤读取资源时踩了坑——大概率是读取器在Tasklet复制文件之前就完成了初始化，导致找不到文件，同时也需要明确后续步骤怎么精准获取这些多文件。下面给你几个实用的方案：

方案1：通过JobExecutionContext传递文件列表 #

这种方式最直接，Tasklet复制完文件后，把所有成功复制的文件路径存到Job上下文里，后续步骤直接从上下文拿列表处理。

步骤1：在Tasklet中保存文件路径到JobExecutionContext #

@Component
public class FileCopyTasklet implements Tasklet {

    @Override
    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
        // 你的文件复制逻辑：从源端迁移到本地目标路径
        Path targetDir = Paths.get("/your/local/target/path");
        List<File> copiedFiles = new ArrayList<>();
        // 这里完成文件复制操作，同时收集所有复制后的文件
        // ... 具体复制代码 ...

        // 将文件路径列表存入Job上下文，供后续步骤读取
        JobExecution jobExecution = chunkContext.getStepContext().getStepExecution().getJobExecution();
        ExecutionContext jobContext = jobExecution.getExecutionContext();
        jobContext.put("copiedFilePaths", copiedFiles.stream().map(File::getAbsolutePath).collect(Collectors.toList()));

        return RepeatStatus.FINISHED;
    }
}

步骤2：后续步骤的ItemReader读取上下文里的文件列表 #

你可以自定义一个ItemReader，或者用MultiResourceItemReader结合上下文的路径列表：

@Component
@StepScope
public class CustomMultiFileReader implements ItemReader<String> {

    private MultiResourceItemReader<String> delegate;

    @Autowired
    public CustomMultiFileReader(ResourcePatternResolver resourcePatternResolver, StepExecution stepExecution) throws IOException {
        // 从Job上下文取出之前存的文件路径列表
        List<String> filePaths = (List<String>) stepExecution.getJobExecution().getExecutionContext().get("copiedFilePaths");
        // 把路径转为Spring Resource对象
        Resource[] resources = filePaths.stream()
                .map(path -> resourcePatternResolver.getResource("file:" + path))
                .toArray(Resource[]::new);

        // 配置MultiResourceItemReader作为代理，处理多文件读取
        delegate = new MultiResourceItemReader<>();
        delegate.setResources(resources);
        // 设置具体的单行读取器，比如FlatFileItemReader
        FlatFileItemReader<String> fileReader = new FlatFileItemReader<>();
        fileReader.setLineMapper((line, lineNumber) -> line); // 示例：直接读取每行文本
        delegate.setDelegate(fileReader);
        delegate.afterPropertiesSet();
    }

    @Override
    public String read() throws Exception {
        return delegate.read();
    }
}

方案2：直接用MultiResourceItemReader读取目标目录（推荐） #

如果你的目标目录里只有Tasklet复制过来的文件，也可以直接让MultiResourceItemReader扫描目标目录，但要解决读取器提前初始化的核心问题。

关键：延迟读取器初始化 #

默认情况下，Spring Bean会在容器启动时初始化，这时候Tasklet还没复制文件，读取器扫描目录会找不到文件导致初始化失败。解决办法：

1. 给读取器加上@StepScope注解，确保它在Step执行时才初始化（此时Tasklet已经完成文件复制）
2. 配置MultiResourceItemReader扫描目标路径

示例配置：

@Configuration
public class BatchConfig {

    @Bean
    @StepScope
    public MultiResourceItemReader<String> multiResourceItemReader() {
        MultiResourceItemReader<String> reader = new MultiResourceItemReader<>();
        // 扫描目标目录下的所有文件，比如指定后缀的.txt文件
        reader.setResources(new PathMatchingResourcePatternResolver().getResources("file:/your/local/target/path/*.txt"));
        // 设置具体的单行读取器
        FlatFileItemReader<String> delegateReader = new FlatFileItemReader<>();
        delegateReader.setLineMapper((line, lineNumber) -> line);
        reader.setDelegate(delegateReader);
        return reader;
    }

    // Job配置：确保文件复制Step在文件处理Step之前执行
    @Bean
    public Job fileProcessingJob(JobBuilderFactory jobBuilderFactory, Step fileCopyStep, Step fileProcessStep) {
        return jobBuilderFactory.get("fileProcessingJob")
                .start(fileCopyStep)
                .next(fileProcessStep)
                .build();
    }

    @Bean
    public Step fileCopyStep(StepBuilderFactory stepBuilderFactory, FileCopyTasklet fileCopyTasklet) {
        return stepBuilderFactory.get("fileCopyStep")
                .tasklet(fileCopyTasklet)
                .build();
    }

    @Bean
    public Step fileProcessStep(StepBuilderFactory stepBuilderFactory, MultiResourceItemReader<String> reader) {
        return stepBuilderFactory.get("fileProcessStep")
                .<String, String>chunk(10)
                .reader(reader)
                // 配置你的Processor和Writer逻辑
                .processor(item -> item.toUpperCase())
                .writer(items -> items.forEach(System.out::println))
                .build();
    }
}

解决读取器初始化失败的核心要点 #

你遇到的读取器初始化失败，几乎可以肯定是读取器初始化时机早于Tasklet的文件复制操作。除了上面的@StepScope延迟初始化，还有两个补充方案：

• 给读取器Bean设置lazy-init = true，让它在第一次被使用时才初始化
• 用StepExecutionListener，在beforeStep阶段动态设置读取器的资源（比如从Job上下文拿文件列表）

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