在春季批处理中从处理器调用另一个作业

Noa*_*ach 2 java spring-batch

我有一个作业(= JobA),可以读取和处理输入文件-该作业是使用读取器,写入器,多个处理器,侦听器和异常处理程序定义的,而我不想更改该作业定义,主要是出于向后兼容的原因

我想实现另一个作业(= JobB),该作业以一定的标准和顺序从目录中读取文件,然后发送要由JobA处理的文件

我正在研究[MultiResourceItemReader] [1]

[1]:http : //docs.spring.io/spring-batch/apidocs/org/springframework/batch/item/file/MultiResourceItemReader.html “ MultiResourceItemReader”,但我看不到如何将对JobA的调用合并进入这个

可能吗?

Hai*_*man 6

考虑使用第二个工作包装现有的工作,并在batch:step元素内使用带有job-parameters-extractor的batch:job元素。

外部作业应包括您的决定器所需文件列表的逻辑。batch:job将使用org.springframework.batch.core.step.job.JobParametersExtractor 接口调用现有的作业和job-parameters-extractor,该接口会将所需的文件路径复制到内部作业。

在我使用上面元素的地方看下面的答案

逻辑上你的工作看起来像

<batch:job id="jobWrapper" incrementer="runIdIncrementer" >
        <batch:step id="createFileList" next="callInternalJob">
            <batch:tasklet ref="fileterRequiredFilesTasklet"/>
        </batch:step>
        <batch:step id="callInternalJob" next="hasMoreFileDecision">
            <batch:job ref="yourJob" job-launcher="jobLauncher"
                job-parameters-extractor="extractCurrentFileParam" />
        </batch:step>
        <batch:decision id="hasMoreFileDecision" decider="hasMoreFileDecider">
            <batch:next on="NEXTFILE" to="callInternalJob" />
            <batch:end  on="COMPLETED" exit-code="COMPLETED" />
        </batch:decision>
    </batch:job>  
Run Code Online (Sandbox Code Playgroud)

fileterRequiredFilesTasklet-创建所需文件列表并将其存储在作业执行上下文中 callInternalJob-调用退出的作业,并通过callInternalJob hasMoreFileDecider传递当前文件进行处理 -将遍历fileterRequiredFilesTasklet util创建的文件列表,所有这些都已处理。