Flowable中定時器的玩法詳解

2022-11-03 14:02:17

1. 流程定義定時啟用

在之前鬆哥給小夥伴們介紹流程定義的時候，流程都是定義好之後立馬就啟用了，其實在流程定義的這個過程中，我們還可以設定一個啟用時間，也就是流程定義好之後，並不會立馬啟用（不啟用就不能據此流程定義建立新流程），而是在延遲某一個固定時間之後，才會啟用，程式碼如下：

@RestController
public 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)) 表示流程在延遲一分鐘之後，才啟用。

此時，我們啟動專案，然後呼叫該介面部署一個流程，部署完成之後，如果立馬呼叫流程啟動方法去啟動流程，就會丟擲如下異常：

可以看到，這裡也說的很明確了，這個流程定義目前是一個掛起的狀態，無法啟動。

這個時候，我們去檢視 ACT_RU_TIMER_JOB 表，就會發現該表中多了一條定時任務執行計劃：

該表有一個 DUEDATE_ 欄位，這個欄位描述了這個定時任務執行的具體時間，在到達時間後，定時任務會自動執行，將 ACT_RE_PROCDEF 表中，流程的狀態列位 SUSPENSION_STATE_ 由 2 改為 1。

2. 流程範例定時掛起

除了流程定義可以定時掛起外，流程範例也可以定時掛起。方式如下：

@Autowired
RepositoryService repositoryService;
@Test
void test23() {
    repositoryService.suspendProcessDefinitionByKey("UserTaskDemo", true, new Date(System.currentTimeMillis() + 120 * 1000));
}

這個執行完成後，也會在 ACT_RU_TIMER_JOB 表中新增一條定時任務，在兩分鐘之後，會自動掛起這個流程定義以及與之相對應的流程。實際上就是將對應表中的 SUSPENSION_STATE_ 欄位值由 1 改為 2。

3. 定時任務執行過程

前面兩個小節，鬆哥都和大家提到，ACT_RU_TIMER_JOB 表中會儲存定時任務資訊，時間到了就會自動執行。

但是小夥伴們注意，定時任務每次執行的時候，其實並不是去 ACT_RU_TIMER_JOB 表中查詢資料，而是去 ACT_RU_JOB 表中查詢資料並執行。

當定時的時間到了後，Flowable 會自動將資料從 ACT_RU_TIMER_JOB 表中移動到 ACT_RU_JOB 表中，然後定時器查詢到 ACT_RU_JOB 表中的資料之後，就立馬自動執行了。大致上就是這樣一個流程。

我給大家手動演示一個。

我現在的流程定義和流程範例都掛起了，我想要在 4 分鐘之後，將之全部啟動，程式碼如下：

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

當這行程式碼執行之後，4 分鐘之後，流程定義和流程範例就全部都啟動了。但是我現在忽然就不想等四分鐘了，我想立馬執行，那麼我們可以去 ACT_RU_TIMER_JOB 表中找到這個定時任務的 ID，然後執行如下程式碼：

@Autowired
ManagementService managementService;
@Test
void test25() {
    managementService.moveTimerToExecutableJob("b7e9501d-5075-11ed-9706-acde48001122");
}

這個程式碼錶示將 ID 為 b7e9501d-5075-11ed-9706-acde48001122 的記錄由 ACT_RU_TIMER_JOB 表移動到 ACT_RU_JOB 表中，移動完成後，這個任務就會被立馬執行。

當一個定時任務開啟了，還能不能取消呢？當然可以！我們將這個定時任務放到私信佇列表即可，私信佇列表是 ACT_RU_DEADLETTER_JOB，具體操作方式如下：

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

上面這個方法執行的引數是 ACT_RU_TIMER_JOB 表中的任務 ID，執行完成後，ACT_RU_TIMER_JOB 表中對應的記錄就會被移動到 ACT_RU_DEADLETTER_JOB 表中，所以定時任務就不會被執行了。

對於已經移動到私信佇列的定時任務，也可以再通過如下方法移動回 ACT_RU_JOB 表中被立馬執行（即使時間沒到也會立馬執行），如下：

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

引數就是任務 ID。

到此這篇關於Flowable中定時器的玩法詳解的文章就介紹到這了,更多相關Flowable定時器內容請搜尋it145.com以前的文章或繼續瀏覽下面的相關文章希望大家以後多多支援it145.com！

Flowable中定時器的玩法詳解

目錄

1. 流程定義定時啟用

2. 流程範例定時掛起

3. 定時任務執行過程

熱門文章