@
- 1. 流程定義定時激活
- 2. 流程實例定時掛起
- 3. 定時任務執(zhí)行過程
今天我們來聊一聊 Flowable 中的定時器。
1. 流程定義定時激活
在之前松哥給小伙伴們介紹流程定義的時候，流程都是定義好之后立馬就激活了，其實在流程定義的這個過程中，我們還可以設置一個激活時間，也就是流程定義好之后，并不會立馬激活（不激活就不能據(jù)此流程定義創(chuàng)建新流程），而是在延遲某一個固定時間之后，才會激活，代碼如下：
@RestControllerpublic class ProcessDeployController { @Autowired RepositoryService repositoryService; @PostMapping("/deploy") public RespBean deploy(MultipartFile file,String tenantId) throws IOException { System.out.println(new Date()); DeploymentBuilder deploymentBuilder = repositoryService.createDeployment() .category("javaboy的工作流分類") .name("javaboy的工作流名稱") .addInputStream("fff.bpmn", file.getInputStream()) .tenantId(tenantId) .activateProcessDefinitionsOn(new Date(System.currentTimeMillis() 1000 * 60)) .key("javaboy的工作流key666"); Deployment deployment = deploymentBuilder .deploy(); return RespBean.ok("部署成功",deployment.getId()); }}
.activateProcessDefinitionsOn(new Date(System.currentTimeMillis() 1000 * 60)) 表示流程在延遲一分鐘之后，才激活。
此時，我們啟動項目，然后調(diào)用該接口部署一個流程，部署完成之后，如果立馬調(diào)用流程啟動方法去啟動流程，就會拋出如下異常：
[外鏈圖片轉(zhuǎn)存中…(img-xSdTE0BE-1668358373729)]
可以看到，這里也說的很明確了，這個流程定義目前是一個掛起的狀態(tài)，無法啟動。
這個時候，我們?nèi)ゲ榭?ACT_RU_TIMER_JOB 表，就會發(fā)現(xiàn)該表中多了一條定時任務執(zhí)行計劃：
[外鏈圖片轉(zhuǎn)存中…(img-d73ZciiZ-1668358373730)]
該表有一個 DUEDATE_ 字段，這個字段描述了這個定時任務執(zhí)行的具體時間，在到達時間后，定時任務會自動執(zhí)行，將 ACT_RE_PROCDEF 表中，流程的狀態(tài)字段 SUSPENSION_STATE_ 由 2 改為 1。
2. 流程實例定時掛起
除了流程定義可以定時掛起外，流程實例也可以定時掛起。方式如下：
@AutowiredRepositoryService repositoryService;@Testvoid test23() { repositoryService.suspendProcessDefinitionByKey("UserTaskDemo", true, new Date(System.currentTimeMillis() 120 * 1000));}
這個執(zhí)行完成后，也會在 ACT_RU_TIMER_JOB 表中添加一條定時任務，在兩分鐘之后，會自動掛起這個流程定義以及與之相對應的流程。實際上就是將對應表中的 SUSPENSION_STATE_ 字段值由 1 改為 2。
3. 定時任務執(zhí)行過程
前面兩個小節(jié)，松哥都和大家提到，ACT_RU_TIMER_JOB 表中會保存定時任務信息，時間到了就會自動執(zhí)行。
但是小伙伴們注意，定時任務每次執(zhí)行的時候，其實并不是去 ACT_RU_TIMER_JOB 表中查詢數(shù)據(jù)，而是去 ACT_RU_JOB 表中查詢數(shù)據(jù)并執(zhí)行。
當定時的時間到了后，F(xiàn)lowable 會自動將數(shù)據(jù)從 ACT_RU_TIMER_JOB 表中移動到 ACT_RU_JOB 表中，然后定時器查詢到 ACT_RU_JOB 表中的數(shù)據(jù)之后，就立馬自動執(zhí)行了。大致上就是這樣一個流程。
我給大家手動演示一個。
我現(xiàn)在的流程定義和流程實例都掛起了，我想要在 4 分鐘之后，將之全部啟動，代碼如下：
@Testvoid test24() { repositoryService.activateProcessDefinitionByKey("UserTaskDemo", true, new Date(System.currentTimeMillis() 240 * 1000));}
當這行代碼執(zhí)行之后，4 分鐘之后，流程定義和流程實例就全部都啟動了。但是我現(xiàn)在忽然就不想等四分鐘了，我想立馬執(zhí)行，那么我們可以去 ACT_RU_TIMER_JOB 表中找到這個定時任務的 ID，然后執(zhí)行如下代碼：
@AutowiredManagementService managementService;@Testvoid test25() { managementService.moveTimerToExecutableJob("b7e9501d-5075-11ed-9706-acde48001122");}
這個代碼表示將 ID 為 b7e9501d-5075-11ed-9706-acde48001122 的記錄由 ACT_RU_TIMER_JOB 表移動到 ACT_RU_JOB 表中，移動完成后，這個任務就會被立馬執(zhí)行。
當一個定時任務開啟了，還能不能取消呢？當然可以！我們將這個定時任務放到私信隊列表即可，私信隊列表是 ACT_RU_DEADLETTER_JOB，具體操作方式如下：
@Testvoid test27() { managementService.moveJobToDeadLetterJob("6b95dc62-5081-11ed-a00f-acde48001122");}
上面這個方法執(zhí)行的參數(shù)是 ACT_RU_TIMER_JOB 表中的任務 ID，執(zhí)行完成后，ACT_RU_TIMER_JOB 表中對應的記錄就會被移動到 ACT_RU_DEADLETTER_JOB 表中，所以定時任務就不會被執(zhí)行了。
對于已經(jīng)移動到私信隊列的定時任務，也可以再通過如下方法移動回 ACT_RU_JOB 表中被立馬執(zhí)行（即使時間沒到也會立馬執(zhí)行），如下：
@Testvoid test26() { managementService.moveDeadLetterJobToExecutableJob("6b95dc62-5081-11ed-a00f-acde48001122", 10);}
參數(shù)就是任務 ID。
好啦，幾個簡單的例子和小伙伴們分享了下 Flowable 中定時器的玩法，感興趣的小伙伴可以去試試啦～
版權(quán)聲明：本文內(nèi)容由互聯(lián)網(wǎng)用戶自發(fā)貢獻，該文觀點僅代表作者本人。本站僅提供信息存儲空間服務，不擁有所有權(quán)，不承擔相關(guān)法律責任。如發(fā)現(xiàn)本站有涉嫌抄襲侵權(quán)/違法違規(guī)的內(nèi)容， 請發(fā)送郵件至 舉報，一經(jīng)查實，本站將立刻刪除。