Spring Batch FlatFileItemReader在未来步骤中提供文件名

Question

所以我正在构建一个使用Spring Batch的批处理过程。我定义了一个有几个步骤的作业，第一个是Tasklet的实现，它是一个文件观察者，并检查目录中是否有与特定文件掩码匹配的任何文件。一旦找到该文件，我们就继续执行该过程的下一步。最初，这是Tasklet的另一个实现，我们循环遍历文件和每个记录，以批处理加载到Oracle。这花费了太长时间。我发现使用FlatFileItemReader和JdbcBatchItemWriter实际上要快1000倍。无论如何，我的问题是在使用FlatFileItemReader时，我必须定义我的资源并在创建Bean时提供FileSystemResouce。我真的想在我的第一步完成后提供该文件名，因为我需要运行一个文件观察者并弄清楚我们想要处理的文件名是什么。有没有办法实现这一点？

@Bean
public FlatFileItemReader<PartnerRelationship> partnerRelationshipReader() throws ParseException {
    FlatFileItemReader<PartnerRelationship> reader = new FlatFileItemReader<>();
    reader.setResource(new FileSystemResource("/path/to/my/file/file_20210714.dat"));
    reader.setBufferedReaderFactory(new CustomFileReaderFactory());
    reader.setStrict(false);
    reader.setLineMapper(new DefaultLineMapper<PartnerRelationship>() {{
        setLineTokenizer(new FixedLengthTokenizer() {{
            setNames(Constants.partnerRelationshipFields);
            setColumns(Constants.partnerRelationshipIndeces);
        }});
        setFieldSetMapper(new PartnerRelationshipFieldSetMapper());
    }});
    return reader;
}

Answer 1

您可以将资源传递到jobExecutionContext：

ExecutionContext jobExecutionContext = stepExecution.getJobExecution().getExecutionContext();
jobExecutionContext.put("resource", res);

如果您设置bean stepScope，则可以检索它：

@Bean
@StepScope
public FlatFileItemReader<PartnerRelationship> partnerRelationshipReader(@Value #{jobExecutionContext['resource']} Resource res) throws ParseException {
    FlatFileItemReader<PartnerRelationship> reader = new FlatFileItemReader<>();
    reader.setResource(res);
    reader.setBufferedReaderFactory(new CustomFileReaderFactory());
    reader.setStrict(false);
    reader.setLineMapper(new DefaultLineMapper<PartnerRelationship>() {{
        setLineTokenizer(new FixedLengthTokenizer() {{
            setNames(Constants.partnerRelationshipFields);
            setColumns(Constants.partnerRelationshipIndeces);
        }});
        setFieldSetMapper(new PartnerRelationshipFieldSetMapper());
    }});
    return reader;
}