close

今天小編為大家帶來的是社區作者江南一點雨的文章,讓我們來體驗一把 Flowable 三種常見網關。前言Flowable 中網關類型其實也不少,常見的主要有三種類型,分別是:排他網關

並行網關
包容網關

這三個裡邊最常用的當然就是排他網關了,今天松哥就來和小夥伴們聊一聊這三種網關,一起來體驗一把這三種網關各自的特徵。


1. 排他網關

首先就是排他網關了,這個也叫互斥網關,長得像下圖這樣:

排他網關可以有 N 個入口,但是只有一個有效出口。

松哥舉一個例子:

假設我有一個請假流程,請假 1 天,組長審批,請假小於 3 天,項目經理審批,請假大於 3 天,總監審批,據此,我們可以繪製如下流程圖:

在這個流程圖中,當流程從排他網關出來的時候,我們設置一個變量,根據變量的值,來決定下一個走哪一個 Task,例如組長審批,我們做如下配置:

這個流條件表示當 days 這個變量的值小於等於 1 的時候,就會進入到組長審批這個 Task。

按照類似的方式,我們來設置經理審批:

最後,總監審批的條件如下:

最終,我們來看下這個流程對應的 XML 文件,如下:

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

可以看到,在 sequenceFlow 標籤中,有一個 conditionExpression 標籤,這個標籤的內容就是具體的條件了。

現在,我們部署一下這個流程,然後按照如下方式來啟動:

@Testvoidtest01(){Map<String,Object>variables=newHashMap<>();variables.put("days",3);ProcessInstancepi=runtimeService.startProcessInstanceByKey("demo01",variables);logger.info("id:{},activityId:{}",pi.getId(),pi.getActivityId());}

注意,這個啟動的時候,傳入一個 days 變量,系統將來會根據這個變量來決定這個流程要走到哪一個 Task。流程啟動成功之後,我們去觀察ACT_RU_TASK表,就可以看到流程的執行是否和我們所預想的一致。

2. 並行網關

並行網關,從名字上大概也能看出來,這種網關一般用在並行任務上,並行網關如下圖:

並行網關一般是成對出現的,一個出現的並行網關用來分流,第二個出現的並行網關用來聚合。

我畫一個簡單的並行網關的例子,如下圖:

小夥伴們看到,這是一個簡化的生產筆記本的流程圖,當屏幕和鍵盤都生產好之後,再進行組裝,整個流程圖中存在兩個並行網關(成對出現)。

在這個流程圖中,連接線上是不需要設置條件的(不同於拍他網關),這裡即使你設置了條件,這個條件也是不會生效的。

我們來看下這個並行網關流程圖對應的 XML 文件,如下:

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

現在我們把這個流程部署並啟動。

流程啟動成功之後,我們發現在 ACT_RU_TASK 表中有兩個需要執行的 Task,如下圖:

這兩個 Task,如果只執行掉其中一個,那麼還剩下另外一個 Task,如果兩個都執行了,那麼你就會看到一個新的 Task,如下圖(兩個並行任務執行完成後,進入到下一個任務):

好啦,這就是並行網關。

3. 包容網關包容網關,有時候也叫相容網關、兼容網關等,如下圖:

包容誰呢?包容排他網關和並行網關。也就是說,這種包容網關可以根據實際條件轉為排他網關或者並行網關。

舉個栗子:

假如說報銷金額大於 500,zhangsan 審批,報銷金額大於 1000,則需要 zhangsan 和 lisi 同時審批,且 zhangsan 和 lisi 審批無先後順序。

據此,我繪製如下流程圖:

在報銷金額大於 500 上設置如下條件:

大於 1000 上設置如下條件:

接下來我們來部署好這個流程。

部署好之後,我們首先來啟動流程,第一次啟動的時候,我們設置報銷金額為 666,如下:

@Testvoidtest01(){Map<String,Object>variables=newHashMap<>();variables.put("money",666);ProcessInstancepi=runtimeService.startProcessInstanceByKey("demo01",variables);logger.info("id:{},activityId:{}",pi.getId(),pi.getActivityId());}

流程啟動之後,我們在ACT_RU_TASK表中可以看到,該 zhangsan 審批了,如下:

zhangsan 審批之後,就是 wangwu 審批了,我就不演示了。

假設我們啟動流程的時候,報銷金額為 2000,如下:

@Testvoidtest01(){Map<String,Object>variables=newHashMap<>();variables.put("money",2000);ProcessInstancepi=runtimeService.startProcessInstanceByKey("demo01",variables);logger.info("id:{},activityId:{}",pi.getId(),pi.getActivityId());}

那麼此時你就會看到,在ACT_RU_TASK表中,出現了兩條記錄,分別是 zhangsan 審批和 lisi 審批,此時這兩個審批就是一個並行任務了:

接下來就按並行任務的模式來,這兩個人都審批了,才會進入到 wangwu 審批。

這就是兼容網關的特點,即根據實際情況,會變成排他網關或者並行網關。

好啦,三種常見的網關就和小夥伴們分享完啦,感興趣的小夥伴趕緊試一試吧~

點擊左下角閱讀原文,到SegmentFault 思否社區和文章作者展開更多互動和交流,「公眾號後台「回復「入群」即可加入我們的技術交流群,收穫更多的技術文章~

-END -

arrow
arrow
    全站熱搜
    創作者介紹
    創作者 鑽石舞台 的頭像
    鑽石舞台

    鑽石舞台

    鑽石舞台 發表在 痞客邦 留言(0) 人氣()