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