@

• 1. 流程定義定時(shí)激活
• 2. 流程實(shí)例定時(shí)掛起
• 3. 定時(shí)任務(wù)執(zhí)行過(guò)程

今天我們來(lái)聊一聊 Flowable 中的定時(shí)器。

1. 流程定義定時(shí)激活

在之前松哥給小伙伴們介紹流程定義的時(shí)候，流程都是定義好之后立馬就激活了，其實(shí)在流程定義的這個(gè)過(guò)程中，我們還可以設(shè)置一個(gè)激活時(shí)間，也就是流程定義好之后，并不會(huì)立馬激活（不激活就不能據(jù)此流程定義創(chuàng)建新流程），而是在延遲某一個(gè)固定時(shí)間之后，才會(huì)激活，代碼如下：

@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)) 表示流程在延遲一分鐘之后，才激活。

此時(shí)，我們啟動(dòng)項(xiàng)目，然后調(diào)用該接口部署一個(gè)流程，部署完成之后，如果立馬調(diào)用流程啟動(dòng)方法去啟動(dòng)流程，就會(huì)拋出如下異常：

[外鏈圖片轉(zhuǎn)存中…(img-xSdTE0BE-1668358373729)]

可以看到，這里也說(shuō)的很明確了，這個(gè)流程定義目前是一個(gè)掛起的狀態(tài)，無(wú)法啟動(dòng)。

這個(gè)時(shí)候，我們?nèi)ゲ榭?ACT_RU_TIMER_JOB 表，就會(huì)發(fā)現(xiàn)該表中多了一條定時(shí)任務(wù)執(zhí)行計(jì)劃：

[外鏈圖片轉(zhuǎn)存中…(img-d73ZciiZ-1668358373730)]

該表有一個(gè) DUEDATE_ 字段，這個(gè)字段描述了這個(gè)定時(shí)任務(wù)執(zhí)行的具體時(shí)間，在到達(dá)時(shí)間后，定時(shí)任務(wù)會(huì)自動(dòng)執(zhí)行，將 ACT_RE_PROCDEF 表中，流程的狀態(tài)字段 SUSPENSION_STATE_ 由 2 改為 1。

2. 流程實(shí)例定時(shí)掛起

除了流程定義可以定時(shí)掛起外，流程實(shí)例也可以定時(shí)掛起。方式如下：

@AutowiredRepositoryService repositoryService;@Testvoid test23() { repositoryService.suspendProcessDefinitionByKey("UserTaskDemo", true, new Date(System.currentTimeMillis() 120 * 1000));}

這個(gè)執(zhí)行完成后，也會(huì)在 ACT_RU_TIMER_JOB 表中添加一條定時(shí)任務(wù)，在兩分鐘之后，會(huì)自動(dòng)掛起這個(gè)流程定義以及與之相對(duì)應(yīng)的流程。實(shí)際上就是將對(duì)應(yīng)表中的 SUSPENSION_STATE_ 字段值由 1 改為 2。

3. 定時(shí)任務(wù)執(zhí)行過(guò)程

前面兩個(gè)小節(jié)，松哥都和大家提到，ACT_RU_TIMER_JOB 表中會(huì)保存定時(shí)任務(wù)信息，時(shí)間到了就會(huì)自動(dòng)執(zhí)行。

但是小伙伴們注意，定時(shí)任務(wù)每次執(zhí)行的時(shí)候，其實(shí)并不是去 ACT_RU_TIMER_JOB 表中查詢數(shù)據(jù)，而是去 ACT_RU_JOB 表中查詢數(shù)據(jù)并執(zhí)行。

當(dāng)定時(shí)的時(shí)間到了后，F(xiàn)lowable 會(huì)自動(dòng)將數(shù)據(jù)從 ACT_RU_TIMER_JOB 表中移動(dòng)到 ACT_RU_JOB 表中，然后定時(shí)器查詢到 ACT_RU_JOB 表中的數(shù)據(jù)之后，就立馬自動(dòng)執(zhí)行了。大致上就是這樣一個(gè)流程。

我給大家手動(dòng)演示一個(gè)。

我現(xiàn)在的流程定義和流程實(shí)例都掛起了，我想要在 4 分鐘之后，將之全部啟動(dòng)，代碼如下：

@Testvoid test24() { repositoryService.activateProcessDefinitionByKey("UserTaskDemo", true, new Date(System.currentTimeMillis() 240 * 1000));}

當(dāng)這行代碼執(zhí)行之后，4 分鐘之后，流程定義和流程實(shí)例就全部都啟動(dòng)了。但是我現(xiàn)在忽然就不想等四分鐘了，我想立馬執(zhí)行，那么我們可以去 ACT_RU_TIMER_JOB 表中找到這個(gè)定時(shí)任務(wù)的 ID，然后執(zhí)行如下代碼：

@AutowiredManagementService managementService;@Testvoid test25() { managementService.moveTimerToExecutableJob("b7e9501d-5075-11ed-9706-acde48001122");}

這個(gè)代碼表示將 ID 為 b7e9501d-5075-11ed-9706-acde48001122 的記錄由 ACT_RU_TIMER_JOB 表移動(dòng)到 ACT_RU_JOB 表中，移動(dòng)完成后，這個(gè)任務(wù)就會(huì)被立馬執(zhí)行。

當(dāng)一個(gè)定時(shí)任務(wù)開啟了，還能不能取消呢？當(dāng)然可以！我們將這個(gè)定時(shí)任務(wù)放到私信隊(duì)列表即可，私信隊(duì)列表是 ACT_RU_DEADLETTER_JOB，具體操作方式如下：

@Testvoid test27() { managementService.moveJobToDeadLetterJob("6b95dc62-5081-11ed-a00f-acde48001122");}

上面這個(gè)方法執(zhí)行的參數(shù)是 ACT_RU_TIMER_JOB 表中的任務(wù) ID，執(zhí)行完成后，ACT_RU_TIMER_JOB 表中對(duì)應(yīng)的記錄就會(huì)被移動(dòng)到 ACT_RU_DEADLETTER_JOB 表中，所以定時(shí)任務(wù)就不會(huì)被執(zhí)行了。

對(duì)于已經(jīng)移動(dòng)到私信隊(duì)列的定時(shí)任務(wù)，也可以再通過(guò)如下方法移動(dòng)回 ACT_RU_JOB 表中被立馬執(zhí)行（即使時(shí)間沒到也會(huì)立馬執(zhí)行），如下：

@Testvoid test26() { managementService.moveDeadLetterJobToExecutableJob("6b95dc62-5081-11ed-a00f-acde48001122", 10);}

參數(shù)就是任務(wù) ID。

好啦，幾個(gè)簡(jiǎn)單的例子和小伙伴們分享了下 Flowable 中定時(shí)器的玩法，感興趣的小伙伴可以去試試?yán)病?/span>