創(chuàng)建流程定義

1. 添加maven依賴包

<dependencies>
  <dependency>
    <groupId>org.flowable</groupId>
    <artifactId>flowable-engine</artifactId>
    <version>6.4.1</version>
  </dependency>
  <dependency>
    <groupId>com.h2database</groupId>
    <artifactId>h2</artifactId>
    <version>1.3.176</version>
  </dependency>
</dependencies>

• Flowable流程引擎凰狞，它允許我們創(chuàng)建ProcessEngine對象并訪問Flowable API
• 數(shù)據(jù)庫作為Flowable引擎需要一個數(shù)據(jù)庫來存儲執(zhí)行和歷史數(shù)據(jù)婴谱，同時運行流程實例

2. Flowable在內(nèi)部使用SLF4J作為其日志框架

部署流程定義

1. Flowable引擎期望以BPMN2.0格式定義流程

   • 從流程定義中戴差，可以啟動許多流程實例
     
     image
     
     （1）每個步驟（活動）都有一個id屬性惧互，在XML文件中為其提供唯一標識符
     （2）活動之間由一個序列流連接
     （3）離開網(wǎng)關（帶X的菱形）的序列流兩者都具有以表達式形式定義的條件
     • 批準的變量稱為過程變量

2. 將流程定義部署到引擎

• 流程引擎將XML文件存儲在數(shù)據(jù)庫中定续，因此可以需要時檢索它
• 流程定義被解析為內(nèi)部可執(zhí)行對象模型帐偎，以便可以中啟動流程實例

RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deployment = repositoryService.createDeployment()
  .addClasspathResource("holiday-request.bpmn20.xml")
  .deploy();

• API查詢引擎

ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
  .deploymentId(deployment.getId())
  .singleResult();
System.out.println("Found process definition : " + processDefinition.getName());

啟動流程實例

<process id="holidayRequest" name="Holiday Request" isExecutable="true">

RuntimeService runtimeService = processEngine.getRuntimeService();
Map<String, Object> variables = new HashMap<String, Object>();
variables.put("employee", employee);
variables.put("nrOfHolidays", nrOfHolidays);
variables.put("description", description);
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("holidayRequest", variables);

• 啟動流程實例堕伪，將創(chuàng)建執(zhí)行并將其放入start事件中
• 執(zhí)行用戶任務行為，此行為將在數(shù)據(jù)庫中創(chuàng)建一個任務诈皿，以便查詢

后續(xù)流程分析

1. 數(shù)據(jù)庫事務在保證數(shù)據(jù)一致性和解決并發(fā)問題方面起著至關重要的作用

• 默認情況下林束，所有的內(nèi)容都是同步的，并且是同一個事務的一部分

2. 查看任務列表

• 檢查存儲為流程變量的流程實例數(shù)據(jù) ---> 決定對任務執(zhí)行的操作
• 為用戶任務配置分配：
  id="approveTask" 的userTask標簽增加lowable:candidateGroups="managers"
  id="holidayApprovedTask"增加flowable:assignee="${employee}"
• 獲取實際的任務列表稽亏，通過TaskService創(chuàng)建TaskQuery

  TaskService taskService = processEngine.getTaskService();
  List<Task> tasks = taskService.createTaskQuery().taskCandidateGroup("managers").list();
  System.out.println("You have " + tasks.size() + " tasks:");
  for (int i=0; i<tasks.size(); i++) {
      System.out.println((i+1) + ") " + tasks.get(i).getName());
  }
  

• 使用任務標識符壶冒，可以獲取特定的流程實例變量

int taskIndex = Integer.valueOf(scanner.nextLine());
Task task = tasks.get(taskIndex - 1);
//對比查看啟動流程實例的參數(shù)
Map<String, Object> processVariables = taskService.getVariables(task.getId());
System.out.println(processVariables.get("employee") + " wants " +
    processVariables.get("nrOfHolidays") + " of holidays. Do you approve this?");

• 用戶提交表單，然后將表單中的數(shù)據(jù)作為流程變量傳遞

boolean approved = scanner.nextLine().toLowerCase().equals("y");
variables = new HashMap<String, Object>();
variables.put("approved", approved);
taskService.complete(task.getId(), variables);

該任務現(xiàn)在已完成截歉，并且基于批準的過程變量選擇離開專用網(wǎng)關的兩個路徑之一

3. 編寫JavaDelegate

• 問題：沒有實現(xiàn)在批準請求時執(zhí)行的自動邏輯胖腾。在BPMN 2.0 XML中是一項服務任務

<serviceTask id="externalSystemCall" name="Enter holidays in external system"
    flowable:class="org.flowable.CallExternalSystemDelegate"/>

創(chuàng)建類org.flowable.CallExternalSystemDelegate實現(xiàn)JavaDelegate接口并實現(xiàn)execute方法

4. 使用歷史數(shù)據(jù)

• Flowable會自動存儲所有流程實例的審計數(shù)據(jù)或歷史數(shù)據(jù)

HistoryService historyService = processEngine.getHistoryService();
List<HistoricActivityInstance> activities =
  historyService.createHistoricActivityInstanceQuery()
   .processInstanceId(processInstance.getId())
   .finished()
   .orderByHistoricActivityInstanceEndTime().asc()
   .list();
for (HistoricActivityInstance activity : activities) {
  System.out.println(activity.getActivityId() + " took "
    + activity.getDurationInMillis() + " milliseconds");
}

演示代碼的地址：https://github.com/yehuali/holidayRequest

主要參考Flowable的官方文檔：https://www.flowable.org