我有一个作业(= JobA),可以读取和处理输入文件-该作业是使用读取器,写入器,多个处理器,侦听器和异常处理程序定义的,而我不想更改该作业定义,主要是出于向后兼容的原因
我想实现另一个作业(= JobB),该作业以一定的标准和顺序从目录中读取文件,然后发送要由JobA处理的文件
我正在研究[MultiResourceItemReader] [1]
[1]:http : //docs.spring.io/spring-batch/apidocs/org/springframework/batch/item/file/MultiResourceItemReader.html “ MultiResourceItemReader”,但我看不到如何将对JobA的调用合并进入这个
可能吗?
考虑使用第二个工作包装现有的工作,并在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创建的文件列表,所有这些都已处理。