體驗(yàn)一把 Flowable 三種常見(jiàn)網(wǎng)關(guān)

作者：江南一點(diǎn)雨 2022-10-25 15:25:22

開(kāi)發(fā) 前端

今天松哥就來(lái)和小伙伴們聊一聊這三種網(wǎng)關(guān)，一起來(lái)體驗(yàn)一把這三種網(wǎng)關(guān)各自的特征。

Flowable 中網(wǎng)關(guān)類型其實(shí)也不少，常見(jiàn)的主要有三種類型，分別是：

排他網(wǎng)關(guān)
并行網(wǎng)關(guān)
包容網(wǎng)關(guān)

這三個(gè)里邊最常用的當(dāng)然就是排他網(wǎng)關(guān)了，今天松哥就來(lái)和小伙伴們聊一聊這三種網(wǎng)關(guān)，一起來(lái)體驗(yàn)一把這三種網(wǎng)關(guān)各自的特征。

1. 排他網(wǎng)關(guān)

首先就是排他網(wǎng)關(guān)了，這個(gè)也叫互斥網(wǎng)關(guān)，長(zhǎng)得像下圖這樣：

排他網(wǎng)關(guān)可以有 N 個(gè)入口，但是只有一個(gè)有效出口。

松哥舉一個(gè)例子：

假設(shè)我有一個(gè)請(qǐng)假流程，請(qǐng)假 1 天，組長(zhǎng)審批，請(qǐng)假小于 3 天，項(xiàng)目經(jīng)理審批，請(qǐng)假大于 3 天，總監(jiān)審批，據(jù)此，我們可以繪制如下流程圖：

在這個(gè)流程圖中，當(dāng)流程從排他網(wǎng)關(guān)出來(lái)的時(shí)候，我們?cè)O(shè)置一個(gè)變量，根據(jù)變量的值，來(lái)決定下一個(gè)走哪一個(gè) Task，例如組長(zhǎng)審批，我們做如下配置：

這個(gè)流條件表示當(dāng) days 這個(gè)變量的值小于等于 1 的時(shí)候，就會(huì)進(jìn)入到組長(zhǎng)審批這個(gè) Task。

按照類似的方式，我們來(lái)設(shè)置經(jīng)理審批：

最后，總監(jiān)審批的條件如下：

最終，我們來(lái)看下這個(gè)流程對(duì)應(yīng)的 XML 文件，如下：

<process id="demo01" name="測(cè)試流程" isExecutable="true">
    <documentation>測(cè)試流程</documentation>
    <startEvent id="startEvent1" flowable:formFieldValidation="true"></startEvent>
    <exclusiveGateway id="sid-C4E389D6-C507-4B8E-8469-2288AA5B44A5"></exclusiveGateway>
    <sequenceFlow id="sid-DF97CC8B-3AD5-447D-AE67-1082CAB7B189" sourceRef="startEvent1" targetRef="sid-C4E389D6-C507-4B8E-8469-2288AA5B44A5"></sequenceFlow>
    <userTask id="sid-B4CD08AF-52B5-44F2-AC45-B2F5E154A5F0" name="組長(zhǎng)審批" flowable:formFieldValidation="true"></userTask>
    <userTask id="sid-07B7951C-4E76-4639-989C-407C610C5BA8" name="經(jīng)理審批" flowable:formFieldValidation="true"></userTask>
    <userTask id="sid-1A81B40F-D8D4-4158-B0B9-26DB8FB7DD2E" name="總監(jiān)審批" flowable:formFieldValidation="true"></userTask>
    <endEvent id="sid-0F56FE56-1A8C-4B47-8F0D-196700DDF7B8"></endEvent>
    <sequenceFlow id="sid-E4B4B580-F078-4BB9-B5D3-966E80737C4C" sourceRef="sid-B4CD08AF-52B5-44F2-AC45-B2F5E154A5F0" targetRef="sid-0F56FE56-1A8C-4B47-8F0D-196700DDF7B8"></sequenceFlow>
    <endEvent id="sid-F05670CB-A8F4-44A3-B53D-46CFB6F65581"></endEvent>
    <sequenceFlow id="sid-3EC62E5D-ACDA-480E-93B4-C24D8F6E9042" sourceRef="sid-07B7951C-4E76-4639-989C-407C610C5BA8" targetRef="sid-F05670CB-A8F4-44A3-B53D-46CFB6F65581"></sequenceFlow>
    <endEvent id="sid-52711414-1769-4EC3-9AE5-6BA426123095"></endEvent>
    <sequenceFlow id="sid-C81500B2-D1EA-429F-8402-A3D8C8CA0E29" sourceRef="sid-1A81B40F-D8D4-4158-B0B9-26DB8FB7DD2E" targetRef="sid-52711414-1769-4EC3-9AE5-6BA426123095"></sequenceFlow>
    <sequenceFlow id="sid-807C7B79-4AFA-4525-847F-4D0FE1C0F0F3" name="小于1天" sourceRef="sid-C4E389D6-C507-4B8E-8469-2288AA5B44A5" targetRef="sid-B4CD08AF-52B5-44F2-AC45-B2F5E154A5F0">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${days<=1}]]></conditionExpression>
    </sequenceFlow>
    <sequenceFlow id="sid-3D3DF742-BF47-4536-9EE9-747CD284A1BA" name="1-3天" sourceRef="sid-C4E389D6-C507-4B8E-8469-2288AA5B44A5" targetRef="sid-07B7951C-4E76-4639-989C-407C610C5BA8">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${days>1 && days<=3}]]></conditionExpression>
    </sequenceFlow>
    <sequenceFlow id="sid-2AD41E43-AFEC-47A1-B8D1-0B4299434BF8" name="大于3天" sourceRef="sid-C4E389D6-C507-4B8E-8469-2288AA5B44A5" targetRef="sid-1A81B40F-D8D4-4158-B0B9-26DB8FB7DD2E">
      <conditionExpression xsi:type="tFormalExpression"><![CDATA[${days>3}]]></conditionExpression>
    </sequenceFlow>
  </process>

可以看到，在 sequenceFlow 標(biāo)簽中，有一個(gè) conditionExpression 標(biāo)簽，這個(gè)標(biāo)簽的內(nèi)容就是具體的條件了。

現(xiàn)在，我們部署一下這個(gè)流程，然后按照如下方式來(lái)啟動(dòng)：

@Test
void test01(){
    Map<String, Object> variables = new HashMap<>();
    variables.put("days", 3);
    ProcessInstance pi = runtimeService.startProcessInstanceByKey("demo01", variables);
    logger.info("id:{},activityId:{}", pi.getId(), pi.getActivityId());
}

注意，這個(gè)啟動(dòng)的時(shí)候，傳入一個(gè) days 變量，系統(tǒng)將來(lái)會(huì)根據(jù)這個(gè)變量來(lái)決定這個(gè)流程要走到哪一個(gè) Task。流程啟動(dòng)成功之后，我們?nèi)ビ^察 ACT_RU_TASK 表，就可以看到流程的執(zhí)行是否和我們所預(yù)想的一致。

2. 并行網(wǎng)關(guān)

并行網(wǎng)關(guān)，從名字上大概也能看出來(lái)，這種網(wǎng)關(guān)一般用在并行任務(wù)上，并行網(wǎng)關(guān)如下圖：

并行網(wǎng)關(guān)一般是成對(duì)出現(xiàn)的，一個(gè)出現(xiàn)的并行網(wǎng)關(guān)用來(lái)分流，第二個(gè)出現(xiàn)的并行網(wǎng)關(guān)用來(lái)聚合。

我畫(huà)一個(gè)簡(jiǎn)單的并行網(wǎng)關(guān)的例子，如下圖：

小伙伴們看到，這是一個(gè)簡(jiǎn)化的生產(chǎn)筆記本的流程圖，當(dāng)屏幕和鍵盤都生產(chǎn)好之后，再進(jìn)行組裝，整個(gè)流程圖中存在兩個(gè)并行網(wǎng)關(guān)（成對(duì)出現(xiàn)）。

在這個(gè)流程圖中，連接線上是不需要設(shè)置條件的（不同于拍他網(wǎng)關(guān)），這里即使你設(shè)置了條件，這個(gè)條件也是不會(huì)生效的。

我們來(lái)看下這個(gè)并行網(wǎng)關(guān)流程圖對(duì)應(yīng)的 XML 文件，如下：

<process id="demo01" name="測(cè)試流程" isExecutable="true">
  <documentation>測(cè)試流程</documentation>
  <startEvent id="sid-4F7F76BA-526A-4D8C-B45A-02FC1C56CA47" flowable:formFieldValidation="true"></startEvent>
  <sequenceFlow id="sid-11130848-EA1F-458A-A45D-49CBC49428C8" sourceRef="sid-4F7F76BA-526A-4D8C-B45A-02FC1C56CA47" targetRef="sid-6D01D4BE-C475-4270-8745-92752EA2C038"></sequenceFlow>
  <parallelGateway id="sid-6D01D4BE-C475-4270-8745-92752EA2C038"></parallelGateway>
  <userTask id="sid-54DD6BFA-FE6C-4DE7-9038-3DEEAF85002C" name="生產(chǎn)屏幕" flowable:assignee="zhangsan" flowable:formFieldValidation="true">
    <extensionElements>
      <modeler:initiator-can-complete xmlns:modeler="http://flowable.org/modeler"><![CDATA[false]]></modeler:initiator-can-complete>
    </extensionElements>
  </userTask>
  <sequenceFlow id="sid-8DD3383C-45D1-4EAF-9A22-702A5B9D0869" sourceRef="sid-6D01D4BE-C475-4270-8745-92752EA2C038" targetRef="sid-54DD6BFA-FE6C-4DE7-9038-3DEEAF85002C"></sequenceFlow>
  <userTask id="sid-7797ED55-155F-4D17-8EA5-DE40434C421B" name="生產(chǎn)鍵盤" flowable:assignee="lisi" flowable:formFieldValidation="true">
    <extensionElements>
      <modeler:initiator-can-complete xmlns:modeler="http://flowable.org/modeler"><![CDATA[false]]></modeler:initiator-can-complete>
    </extensionElements>
  </userTask>
  <sequenceFlow id="sid-6E992E8B-CF71-411D-B537-42FEDF4F4209" sourceRef="sid-6D01D4BE-C475-4270-8745-92752EA2C038" targetRef="sid-7797ED55-155F-4D17-8EA5-DE40434C421B"></sequenceFlow>
  <sequenceFlow id="sid-8DCA9516-FFED-4781-9ACC-530DC6E63755" sourceRef="sid-7797ED55-155F-4D17-8EA5-DE40434C421B" targetRef="sid-98D3C336-9AD9-4964-9CCB-496C850EE40F"></sequenceFlow>
  <sequenceFlow id="sid-EE80AE42-D021-4B9F-A91E-BD37C512EE65" sourceRef="sid-54DD6BFA-FE6C-4DE7-9038-3DEEAF85002C" targetRef="sid-98D3C336-9AD9-4964-9CCB-496C850EE40F"></sequenceFlow>
  <userTask id="sid-4FFE361A-E2AF-4481-BACF-1E618E8C4A26" name="組裝" flowable:assignee="javaboy" flowable:formFieldValidation="true">
    <extensionElements>
      <modeler:initiator-can-complete xmlns:modeler="http://flowable.org/modeler"><![CDATA[false]]></modeler:initiator-can-complete>
    </extensionElements>
  </userTask>
  <sequenceFlow id="sid-8CABC6E8-E36A-4814-B897-817D4A9F231C" sourceRef="sid-98D3C336-9AD9-4964-9CCB-496C850EE40F" targetRef="sid-4FFE361A-E2AF-4481-BACF-1E618E8C4A26"></sequenceFlow>
  <endEvent id="sid-BF02170B-8138-4867-AE01-E3B29505183D"></endEvent>
  <sequenceFlow id="sid-F72B2A15-913F-436E-8AD7-6A6FB190E197" sourceRef="sid-4FFE361A-E2AF-4481-BACF-1E618E8C4A26" targetRef="sid-BF02170B-8138-4867-AE01-E3B29505183D"></sequenceFlow>
  <parallelGateway id="sid-98D3C336-9AD9-4964-9CCB-496C850EE40F"></parallelGateway>
</process>

現(xiàn)在我們把這個(gè)流程部署并啟動(dòng)。

流程啟動(dòng)成功之后，我們發(fā)現(xiàn)在 ACT_RU_TASK 表中有兩個(gè)需要執(zhí)行的 Task，如下圖：

這兩個(gè) Task，如果只執(zhí)行掉其中一個(gè)，那么還剩下另外一個(gè) Task，如果兩個(gè)都執(zhí)行了，那么你就會(huì)看到一個(gè)新的 Task，如下圖（兩個(gè)并行任務(wù)執(zhí)行完成后，進(jìn)入到下一個(gè)任務(wù)）：

好啦，這就是并行網(wǎng)關(guān)。

3. 包容網(wǎng)關(guān)

包容網(wǎng)關(guān)，有時(shí)候也叫相容網(wǎng)關(guān)、兼容網(wǎng)關(guān)等，如下圖：

包容誰(shuí)呢？包容排他網(wǎng)關(guān)和并行網(wǎng)關(guān)。也就是說(shuō)，這種包容網(wǎng)關(guān)可以根據(jù)實(shí)際條件轉(zhuǎn)為排他網(wǎng)關(guān)或者并行網(wǎng)關(guān)。

舉個(gè)栗子：

假如說(shuō)報(bào)銷金額大于 500，zhangsan 審批，報(bào)銷金額大于 1000，則需要 zhangsan 和 lisi 同時(shí)審批，且 zhangsan 和 lisi 審批無(wú)先后順序。

據(jù)此，我繪制如下流程圖：

在報(bào)銷金額大于 500 上設(shè)置如下條件：

大于 1000 上設(shè)置如下條件：

接下來(lái)我們來(lái)部署好這個(gè)流程。

部署好之后，我們首先來(lái)啟動(dòng)流程，第一次啟動(dòng)的時(shí)候，我們?cè)O(shè)置報(bào)銷金額為 666，如下：

@Test
void test01(){
    Map<String, Object> variables = new HashMap<>();
    variables.put("money", 666);
    ProcessInstance pi = runtimeService.startProcessInstanceByKey("demo01", variables);
    logger.info("id:{},activityId:{}", pi.getId(), pi.getActivityId());
}

流程啟動(dòng)之后，我們?cè)?nbsp;ACT_RU_TASK 表中可以看到，該 zhangsan 審批了，如下：

zhangsan 審批之后，就是 wangwu 審批了，我就不演示了。

假設(shè)我們啟動(dòng)流程的時(shí)候，報(bào)銷金額為 2000，如下：

@Test
void test01(){
    Map<String, Object> variables = new HashMap<>();
    variables.put("money", 2000);
    ProcessInstance pi = runtimeService.startProcessInstanceByKey("demo01", variables);
    logger.info("id:{},activityId:{}", pi.getId(), pi.getActivityId());
}