您好,登錄后才能下訂單哦!
本篇內容主要講解“Spring Batch框架job任務為什么只跑一次”,感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷,實用性強。下面就讓小編來帶大家學習“Spring Batch框架job任務為什么只跑一次”吧!
Spring Batch job任務只跑一次
出現原因
解決方法
job的啟動,停止,放棄
1、啟動一個job
2、停止一個job
3、放棄一個job
4、失敗一個job
5、結束一個job
在一次實際使用spring batch的過程中,在定時任務中,第一次執行Job沒有出現問題,然后再次執行時不會執行job任務;
針對這種異常需要明確Job Instance的概念,Job Instance 是由Job的名稱和執行該job的參數組成的,當執行Job時,會由于參數相同,會認為是同一個Job實例,如果該Job已經執行過,就會報出異常。判斷Job是否執行過的狀態是保存到Job Repository中的。
為了使執行參數不同,可以在參數中添加一個時間戳
JobParametersBuilder builder = new JobParametersBuilder(); builder.addDate("date", new Date());
運行一個批處理任務至少有兩點要求:一個 JobLauncher 和一個用來運行的 job 。它們都包含了相同或是不同的 context 。舉例來說,從命令行來啟動job,會為每一個job初始化一個JVM,因此每個job會有一個自己的 JobLauncher;從web容器的HttpRequest來啟動job,一般只是用一個 JobLauncher 來異步啟動job,http請求會調用這個 JobLauncher 來啟動它們需要的job。
通過web啟動job的例子:
@Controller public class JobLauncherController { @Autowired JobLauncher jobLauncher; @Autowired Job job; @RequestMapping("/jobLauncher.html") public void handle() throws Exception{ jobLauncher.run(job, new JobParameters()); } }
關閉不是立即發生的,因為沒有辦法將一個任務立刻強制停掉,尤其是當任務進行到開發人員自己的代碼段時,框架在此刻是無能為力的,比如某個業務邏輯處理。而一旦控制權還給了框架,它會立刻設置當前 StepExecution 為 BachStatus.STOPPED ,意為停止,然后保存,最后在完成前對JobExecution進行相同的操作。
Set<Long> executions = jobOperator.getRunningExecutions("sampleJob"); jobOperator.stop(executions.iterator().next());
或者在配置文件中實現:
它能夠讓job進行短暫的停留,以便操作員有時間進行其他的操作,stop元素必須配置restart屬性,當該job重新啟動的時候,需要手動觸發,執行step2。
<step id="step1" parent="s1"> <stop on="COMPLETED" restart="step2"/> </step> <step id="step2" parent="s2"/>
一個job的執行過程當執行到FAILED狀態之后,如果它是可重啟的,它將會被重啟。如果任務的執行過程狀態是ABANDONED,那么框架就不會重啟它。ABANDONED狀態也適用于執行步驟,使得它們可以被跳過,即便是在一個可重啟的任務執行之中:如果任務執行過程中碰到在上一次執行失敗后標記為ABANDONED的步驟,將會跳過該步驟直接到下一步(這是由任務流定義和執行步驟的退出碼決定的)。
如果當前的系統進程死掉了(“kill -9”或系統錯誤),job自然也不會運行,但JobRepository是無法偵測到這個錯誤的,因為進程死掉之前沒有對它進行任何通知。你必須手動的告訴它,你知道任務已經失敗了還是說考慮放棄這個任務(設置它的狀態為FAILED或ABANDONED)-這是業務邏輯層的事情,無法做到自動決策。
只有在不可重啟的任務中才需要設置為FAILED狀態,或者你知道重啟后數據還是有效的。Spring Batch Admin中有一系列工具JobService,用以取消正在進行執行的任務。
失敗的job是可以重新啟動的,因為它的狀態是FAILED,如果step2失敗,則返回一個EARLY TERMINATION的返回碼,step3也就不會執行。否則繼續執行step3
<step id="step1" parent="s1" next="step2"> <step id="step2" parent="s2"> <fail on="FAILED" exit-code="EARLY TERMINATION"/> <next on="*" to="step3"/> </step> <step id="step3" parent="s3">
已經結束的job是不能重新啟動的,因為它的狀態是COMPLETED。如果step2失敗了,則step3就不執行了,該job也就COMPLETED,結束了。如果step2成功了,則繼續往下執行step3。
<step id="step1" parent="s1" next="step2"> <step id="step2" parent="s2"> <end on="FAILED"/> <next on="*" to="step3"/> </step> <step id="step3" parent="s3">
到此,相信大家對“Spring Batch框架job任務為什么只跑一次”有了更深的了解,不妨來實際操作一番吧!這里是億速云網站,更多相關內容可以進入相關頻道進行查詢,關注我們,繼續學習!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。