在后续步骤 Spring Batch 中访问资源

Question

您好，我的 spring 批处理应用程序中有以下 Tasklet：

public class FileMovingTasklet implements Tasklet, InitializingBean {


    @Value("${positionFile.source-path}")
    private String sourcePath;

    @Value("${positionFile.local-path}")
    private String localDirectory;

    @Value("${positionFile.patternName}")
    private String fileNamePattern;

    @Value("${positionFile.suffix}")
    private String suffix;

    @Override
    public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {

        //***code***

            List<PathResource> resources = FileManager.getInputFileList(sourcePath, fileNamePattern, suffix, fileDate);

            if (!CollectionUtils.isEmpty(resources)) {
                copyFiles(resources, localDirectory);
                log.info("Copied files to local directory...");

            }

        } catch (IOException e) {
            log.error("Position File not found with sourcePatch={}, fileName={}, suffix={}, filedate={}", sourcePath, fileNamePattern, suffix, fileDate);
            throw new TaskletException("Could not move file from source to local " + e);
        }

        return RepeatStatus.FINISHED;
    }

    private void copyFiles(List<PathResource> resources, String localDirectory) {

        for (Resource resource : resources) {

            File source;
            File target;

            try {
                source = resource.getFile();
                target = new File(localDirectory + File.separator + source.getName());

                try {
                    FileCopyUtils.copy(source, target);
                } catch (IOException e) {

                }
            } catch (IOException e) {
            }
        }

    }

}

我正在将一些文件从源移动到本地目的地。本地目的地是我要读取文件并在后续步骤中处理和写入的位置。

我的Job配置如下：

@Configuration
public class BatchConfiguration {

    @Autowired
    private JobBuilderFactory jobBuilderFactory;

    @Autowired
    private StepBuilderFactory stepBuilderFactory;

    @Autowired
    private FileMovingTasklet fileMovingTasklet;

    @Value("${positionFile.local-path}")
    private Resource[] resources;

    @Autowired
    private PriceDao scpDao;

    @Autowired
    public PositionRowReader positionRowReader;


    @Bean
    public MultiResourceItemReader<Pos> multiResourceItemReader() {
        MultiResourceItemReader<Pos> resourceItemReader = new MultiResourceItemReader<>();
        resourceItemReader.setResources(resources);
        resourceItemReader.setDelegate(posRowReader());
        return resourceItemReader;
    }

    @Bean
    public FlatFileItemReader<Pos> posRowReader() {
        return positionRowReader.getReader();
    }


    @Bean
    public ItemProcessor<Pos, Price> posRowProcessor() {
        return new PosRowItemProcessor();
    }


    @Bean
    public JobExecutionListener listener() {
        return new JobCompletionNotificationListener(scpDao);
    }


    @Bean
    public Job import() {
        return jobBuilderFactory.get("import")
                .incrementer(new RunIdIncrementer())
                .listener(listener())
                .start(getPositionFileStep())
                .next(step1())
                .build();
    }


    @Bean
    public Step getPositionFileStep() {
        return stepBuilderFactory.get("getPositionFileStep")
                .tasklet(fileMovingTasklet)
                .build();
    }

    @Bean
    public Step step1() {
        return stepBuilderFactory.get("step1")
                .<Pos, Price>chunk(50)
                .reader(multiResourceItemReader())
                .processor(posRowProcessor())
                .writer(new PriceWriter(scpDao))
                .build();
    }



}

执行step1时读取器初始化失败：

org.springframework.batch.item.ItemStreamException: Failed to initialize the reader

我的本​​地路径属性如下：

positionFile.local-path=C:\\Dev\\workspace\\batch\\src\\main\\resources\\localPath

positionFile.patterName=PositionFile*

我的问题是，从源文件夹复制文件后，如何在 step1 中访问可以是多个文件的资源（文件）。

即使有文件，我的资源大小也是 0：

   @Value("${positionFile.local-path}")
    private String filePath;

    @Value("${positionFile.patternName}")
    private String filePattern;


    @Bean
    @StepScope
    public MultiResourceItemReader<PosRow> multiResourceItemReader() {
        MultiResourceItemReader<PosRow> resourceItemReader = new MultiResourceItemReader<>();
        Resource[] resources = new Resource[0];
        try {
            ClassLoader cl = this.getClass().getClassLoader();
            ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver(cl);
            resources = resolver.getResources("file:" + filePath + File.separator + filePattern + "*");
        } catch (IOException e) {
            log.error("Problem with getting resource files");
        }
        resourceItemReader.setResources(resources);
        resourceItemReader.setDelegate(posRowReader());
        return resourceItemReader;
    }

Answer 1

您需要使用 @StepScope

让您的 MultiResourceItemReader 和 FlatFileItemReader 变得懒惰

    @Bean
    @StepScope
    public MultiResourceItemReader<Pos> multiResourceItemReader() {
            MultiResourceItemReader<Pos> resourceItemReader = new MultiResourceItemReader<>();
            resourceItemReader.setResources(resources);
            resourceItemReader.setDelegate(posRowReader());
            return resourceItemReader;
        }

        @Bean
        @StepScope
        public FlatFileItemReader<Pos> posRowReader() {
            return positionRowReader.getReader();
        }