本文介紹了在Spring Batch中從處理器調用另一個作業的處理方法,對大家解決問題具有一定的參考價值,需要的朋友們下面隨著小編來一起學習吧!
問題描述
我有一個讀取和處理輸入文件的作業(=作業)-此作業是使用讀取器、編寫器、多個處理器、偵聽器和異常處理程序定義的,我主要出于向后兼容原因不想更改此作業定義
我要實現另一個作業(=Jobb),該作業按照一定的標準和順序從目錄中讀取文件,然后發送要由Joba處理的文件
我正在查看[MultiResourceItemReader][1]
[1]:http://docs.spring.io/spring-batch/apidocs/org/springframework/batch/item/file/MultiResourceItemReader.html”MultiResourceItemReader”,但我不知道如何將對作業的調用合并到此
可以嗎?
推薦答案
考慮用第二個作業包裝正在退出的作業,并在Batch:Step元素中使用帶有Job-Parameters-Extractor的Batch:Job元素。
外部作業應包含所需文件列表的邏輯和決策器。
Batch:JOB將使用org.springframework.batch.core.step.job.JobParametersExtractor接口調用您正在退出的作業和作業參數提取器,該接口將復制所需的
內部作業的文件路徑。
查看以下answer我使用上述元素的位置。
從邏輯上講,您的工作看起來像
<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>
fileterRequiredFilesTasklet-創建所需文件列表并將其存儲在作業執行上下文中
callInternalJob-調用您正在退出的作業,并通過callInternalJob將當前文件傳遞給進程
hasMoreFileDecider-將循環遍歷fileterRequiredFilesTasklet ul創建的文件列表,直到處理完所有文件。
這篇關于在Spring Batch中從處理器調用另一個作業的文章就介紹到這了,希望我們推薦的答案對大家有所幫助,