深入理解activiti並行閘道器
阿新 • • 發佈:2019-01-23
有一段時間沒有更新博文了,因為最近一直在寫專案,沒有太多的時間練習資料結構和演算法,所以今天呢我和大家分享一下最近在專案中總結的一個比較重要的應用-activiti並行閘道器,如果我們經常開發的是一些管理系統,呢麼可能activiti對你來說還有點陌生,但不可否認在基於業務流程的一些專案中activiti扮演的角色已是相當重要啦,所以還是建議大家還是花費一定的時間學習一下activiti的相關知識。因為內容比較多因此這裡我只是跟大家分享一下經典的並行閘道器應用,當然其他內容我們也應該是需要了解學習的,推薦一個視訊教程應該算是搞教學的還不錯的(視訊連結:https://pan.baidu.com/s/1c2oIW4S#list/path=%2F),人稱峰哥哈哈,我就是根據他的視訊進行學習並且也有了明顯的進步~
所謂排他閘道器 顧名思義 執行到該閘道器,會有多條線路同時並行執行,當都執行完才繼續執行後面的,如下圖:
右側 ParallelGateway就是並行閘道器哈...
我們修改後的業務是學生請假審批提交,班長和班主任審批,當他們都審批完 才最終讓校長審批。測試程式碼如下:
大家可以測試一下,所謂的activiti並行閘道器有沒有覺得很簡單呢,雖然不難但是對於我們開發人員卻是需要熟練掌握且理解的,所以努力哈,戒驕戒躁!package com.gaoxue.gateway; import java.util.List; import org.activiti.engine.ProcessEngine; import org.activiti.engine.ProcessEngines; import org.activiti.engine.repository.Deployment; import org.activiti.engine.runtime.ProcessInstance; import org.activiti.engine.task.Task; import org.junit.Test; public class ParallelGatewayTest { /** * 獲取預設流程引擎例項,會自動讀取activiti.cfg.xml檔案 */ private ProcessEngine processEngine=ProcessEngines.getDefaultProcessEngine(); /** * 部署流程定義 */ @Test public void deploy(){ Deployment deployment=processEngine.getRepositoryService() // 獲取部署相關Service .createDeployment() // 建立部署 .addClasspathResource("diagrams/StudentLeaveProcess4.bpmn") // 載入資原始檔 .addClasspathResource("diagrams/StudentLeaveProcess4.png") // 載入資原始檔 .name("學生請假流程") // 流程名稱 .deploy(); // 部署 System.out.println("流程部署ID:"+deployment.getId()); System.out.println("流程部署Name:"+deployment.getName()); } /** * 啟動流程例項 */ @Test public void start(){ ProcessInstance pi=processEngine.getRuntimeService() // 執行時Service .startProcessInstanceByKey("studentLevaeProcess"); // 流程定義表的KEY欄位值 System.out.println("流程例項ID:"+pi.getId()); System.out.println("流程定義ID:"+pi.getProcessDefinitionId()); } /** * 檢視任務 */ @Test public void findTask(){ List<Task> taskList=processEngine.getTaskService() // 任務相關Service .createTaskQuery() // 建立任務查詢 .taskAssignee("xxx") // 指定某個人 .list(); for(Task task:taskList){ System.out.println("任務ID:"+task.getId()); System.out.println("任務名稱:"+task.getName()); System.out.println("任務建立時間:"+task.getCreateTime()); System.out.println("任務委派人:"+task.getAssignee()); System.out.println("流程例項ID:"+task.getProcessInstanceId()); } } /** * 完成任務 */ @Test public void completeTask(){ processEngine.getTaskService() // 任務相關Service .complete("xxxxxx"); } }