（7）Flowable网关

素颜马尾好姑娘i 2024-03-24 16:12 114阅读 0赞

参考：https://tkjohn.github.io/flowable-userguide/\#bpmnGateways

网关（gateway）用于控制执行的流向。

### 排他网关 ###

排他网关（exclusive gateway）（也叫*异或网关 XOR gateway*，或者更专业的，*基于数据的排他网关 exclusive data-based gateway*），用于对流程中的**决策**建模。当执行到达这个网关时，会按照所有出口顺序流定义的顺序对它们进行计算。选择第一个条件计算为true的顺序流（当没有设置条件时，认为顺序流为*true*）继续流程。

**请注意这里出口顺序流的含义与BPMN 2.0中的一般情况不一样。一般情况下，会选择所有条件计算为true的顺序流，并行执行。而使用排他网关时，只会选择一条顺序流。当多条顺序流的条件都计算为true时，会且仅会选择在XML中最先定义的顺序流继续流程。如果没有可选的顺序流，会抛出异常。**

排他网关用内部带有’X’图标的标准网关（菱形）表示，'X’图标代表*异或*的含义。请注意内部没有图标的网关默认为排他网关。BPMN 2.0规范不允许在同一个流程中混合使用有及没有X的菱形标志。

![在这里插入图片描述][e9b9487eb39f42a99544e94b40ac8da1.png]

例子：

![在这里插入图片描述][3663abba8b844297bb168f76e52b5d42.png]

这里当num=3的时候，没有可以选的顺序流，会抛出异常。

![在这里插入图片描述][66824109575e497da68fd2a6e4e41b5e.png]

此时任务没有结束，此时可以修改这个变量为4。

再进行执行任务，任务正常往下走。

前面我们可以直接在连接线上定义条件，那为什么还要有排他网关呢?直接在线上的情况，如果条件都不满足，流程就结束了，是异常结束

/**
         * 部署流程
         */
        @Test
        public void TestDeployment() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RepositoryService repositoryService = processEngine.getRepositoryService();
            Deployment deployment  = repositoryService.createDeployment()
                    .addClasspathResource("请假流程-排他网关.bpmn20.xml")
                    .name("请假流程-排他网关")
                    .deploy();
    
            System.out.println("deployment.getId()" + deployment.getId());
            System.out.println("deployment.getName()" + deployment.getName());
        }
    
        /**
         * 启动流程实例
         */
        @Test
        public void TestDeploymentRun() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RuntimeService runtimeService = processEngine.getRuntimeService();
            // 流程变量
            Map<String, Object> variables = new HashMap<String, Object>();
            variables.put("num", 3);
            // 启动流程实例
            runtimeService.startProcessInstanceById("holiday-exclusive:1:120004", variables);
        }
    
        /**
         * 完成任务
         */
        @Test
        public void TestCompleteTask() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            Task task = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-exclusive:1:120004")
                    .taskAssignee("zhangsan")
                    .singleResult();
    
            if(task != null){
        
                // 完成任务
                taskService.complete(task.getId());
                System.out.println("完成任务成功");
            }
        }
    
        /**
         * 修改变量
         */
        @Test
        public void TestUpdateVariables() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RuntimeService runtimeService = processEngine.getRuntimeService();
            // 流程变量
            Map<String, Object> variables = new HashMap<String, Object>();
            variables.put("num", 4);
            runtimeService.setVariables("132501", variables);
        }

### 并行网关 ###

网关也可以建模流程中的并行执行。在流程模型中引入并行的最简单的网关，就是**并行网关（parallel gateway）**。它可以将执行\*分支（fork）*为多条路径，也可以*合并（join）\*多条入口路径的执行。

并行网关的功能取决于其入口与出口顺序流：

*  \*\*分支：\*\*所有的出口顺序流都并行执行，为每一条顺序流创建一个并行执行。
 *  \*\*合并：\*\*所有到达并行网关的并行执行都会在网关处等待，直到每一条入口顺序流都到达了有个执行。然后流程经过该合并网关继续。

请注意，如果并行网关同时具有多条入口与出口顺序流，可以**同时具有分支与合并的行为**。在这种情况下，网关首先合并所有入口顺序流，然后分裂为多条并行执行路径。

**与其他网关类型有一个重要区别：并行网关不计算条件。如果连接到并行网关的顺序流上定义了条件，会直接忽略该条件。**

并行网关，用内部带有’加号’图标的网关（菱形）表示，代表\*与（AND）\*的含义。

![在这里插入图片描述][f68a03ca1ca24b319e8021c920ceba04.png]

例子：

![在这里插入图片描述][e039233738b94b6a940dfe6a100210fa.png]

在创建请假单之后，到并行网关的时候，任务里边有了两个任务，在执行里边有了两个执行，也就是说一个流程实例有了两个执行实例。

![在这里插入图片描述][b38c4a87bb8e403d9bbcaa248d5bc4ef.png]

![在这里插入图片描述][689b8d9543f44998833fbd1affeef720.png]

在技术经理审批之后，任务表里边的对应的它的任务没有了。

在项目经理也审批之后，任务表里边的对应的它的任务也没有了。此时任务表里边看不到这个流程的任务了，执行表里边也看不到这个流程的执行了。

因为我们设置的num=3，所以此时流程已经结束了。

/**
         * 部署流程
         */
        @Test
        public void TestDeployment() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RepositoryService repositoryService = processEngine.getRepositoryService();
            Deployment deployment  = repositoryService.createDeployment()
                    .addClasspathResource("请假流程-并行网关.bpmn20.xml")
                    .name("请假流程-并行网关")
                    .deploy();
    
            System.out.println("deployment.getId()" + deployment.getId());
            System.out.println("deployment.getName()" + deployment.getName());
        }
    
        /**
         * 启动流程实例
         */
        @Test
        public void TestDeploymentRun() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RuntimeService runtimeService = processEngine.getRuntimeService();
            // 流程变量
            Map<String, Object> variables = new HashMap<String, Object>();
            variables.put("num", 3);
            // 启动流程实例
            runtimeService.startProcessInstanceById("holiday-parallel:1:140004", variables);
        }
    
        /**
         * 完成任务
         */
        @Test
        public void TestCompleteTask() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            Task task = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-parallel:1:140004")
                    .taskAssignee("lisi")
                    .singleResult();
    
            if(task != null){
        
                // 完成任务
                taskService.complete(task.getId());
                System.out.println("完成任务成功");
            }
        }

### 包容网关 ###

\*\*包容网关（inclusive gateway）\*\*看做排他网关与并行网关的组合。与排他网关一样，可以在包容网关的出口顺序流上定义条件，包容网关会计算条件。然而主要的区别是，包容网关与并行网关一样，可以同时选择多于一条出口顺序流。

包容网关的功能取决于其入口与出口顺序流：

*  \*\*分支：\*\*流程会计算所有出口顺序流的条件。对于每一条计算为true的顺序流，流程都会创建一个并行执行。
 *  \*\*合并：\*\*所有到达包容网关的并行执行，都会在网关处等待。直到每一条具有流程标志（process token）的入口顺序流，都有一个执行到达。这是与并行网关的重要区别。换句话说，包容网关只会等待可以被执行的入口顺序流。在合并后，流程穿过合并并行网关继续。

请注意，如果包容网关同时具有多条入口与出口顺序流，可以**同时具有分支与合并的行为**。在这种情况下，网关首先合并所有具有流程标志的入口顺序流，然后为每一个条件计算为true的出口顺序流分裂出并行执行路径。

> 包容网关的汇聚行为比并行网关更复杂。所有到达包容网关的并行执行，都会在网关等待，直到所有“可以到达”包容网关的执行都“到达”包容网关。 判断方法为：计算当前流程实例中的所有执行，检查从其位置是否有一条到达包容网关的路径（忽略顺序流上的任何条件）。如果存在这样的执行（可到达但尚未到达），则不会触发包容网关的汇聚行为。

包容网关，用内部带有’圆圈’图标的网关（菱形）表示。

![在这里插入图片描述][0af5b82ba3a449dea129808e13482a47.png]

例子：

![在这里插入图片描述][2a56a5c4ffa9428db9d6b238fbe210b6.png]

在启动流程实例的时候，变量num=5。

创建请假单之后，会走项目经理审批、人事审批这两个任务。

![在这里插入图片描述][9a9a1b451eef459182ef1004bd43a731.png]

在目经理审批、人事审批审批了之后，任务到达总经理审批节点。

![在这里插入图片描述][7d7116b52f3d497486fe348cfcd07213.png]

/**
         * 部署流程
         */
        @Test
        public void TestDeployment() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RepositoryService repositoryService = processEngine.getRepositoryService();
            Deployment deployment  = repositoryService.createDeployment()
                    .addClasspathResource("请假流程-包含网关.bpmn20.xml")
                    .name("请假流程-包含网关")
                    .deploy();
    
            System.out.println("deployment.getId()" + deployment.getId());
            System.out.println("deployment.getName()" + deployment.getName());
        }
    
        /**
         * 启动流程实例
         */
        @Test
        public void TestDeploymentRun() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RuntimeService runtimeService = processEngine.getRuntimeService();
            // 流程变量
            Map<String, Object> variables = new HashMap<String, Object>();
            variables.put("num", 5);
            // 启动流程实例
            runtimeService.startProcessInstanceById("holiday-inclusive:1:155004", variables);
        }
    
        /**
         * 完成任务
         */
        @Test
        public void TestCompleteTask() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            Task task = taskService.createTaskQuery()
                    // .processInstanceId("82501") //根据流程实例编号查找
                    .processDefinitionId("holiday-inclusive:1:155004")
                    .taskAssignee("i1")
                    .singleResult();
    
            if(task != null){
        
                // 完成任务
                taskService.complete(task.getId());
                System.out.println("完成任务成功");
            }
        }

### 事件网关 ###

基于事件的网关（event-based gateway）提供了根据事件做选择的方式。网关的每一条出口顺序流都需要连接至一个捕获中间事件。当流程执行到达基于事件的网关时，与等待状态类似，网关会暂停执行，并且为每一条出口顺序流创建一个事件订阅。

请注意：基于事件的网关的出口顺序流与一般的顺序流不同。这些顺序流从不实际**执行**。相反，它们用于告知流程引擎：当执行到达一个基于事件的网关时，需要订阅什么事件。有以下限制：

*  一个基于事件的网关，必须有两条或更多的出口顺序流。
 *  基于事件的网关，只能连接至`intermediateCatchEvent（捕获中间事件）`类型的元素（Flowable不支持在基于事件的网关之后连接“接收任务 Receive Task”）。
 *  连接至基于事件的网关的`intermediateCatchEvent`，必须只有一个入口顺序流。

基于事件的网关，用内部带有特殊图标的网关（菱形）表示。

![在这里插入图片描述][6569745dec0a4d45a900a3525214370f.png]

在配置文件中`开启定时任务`，默认是开启的。

flowable:
      #关闭定时任务JOB
      async-executor-activate: false

[e9b9487eb39f42a99544e94b40ac8da1.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/44910f559e93440a9447e702f44f7c33.png
[3663abba8b844297bb168f76e52b5d42.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/9047abb6515f4932a9be0e0f5f7b045a.png
[66824109575e497da68fd2a6e4e41b5e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/a0190ed6fb464dd7a669509ea789bf94.png
[f68a03ca1ca24b319e8021c920ceba04.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/02834189f701457b9b17c5190327ecf5.png
[e039233738b94b6a940dfe6a100210fa.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/dee49b1b54b14710b69da9e2c01a135f.png
[b38c4a87bb8e403d9bbcaa248d5bc4ef.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/0eb770f0477d4a6990feacb086539e44.png
[689b8d9543f44998833fbd1affeef720.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/74d4e0a3cf3b432390b500276a199d74.png
[0af5b82ba3a449dea129808e13482a47.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/9c7c067d194f46fc9c3b0f157b771078.png
[2a56a5c4ffa9428db9d6b238fbe210b6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/9337ebc33f324da796a425c03e17c42b.png
[9a9a1b451eef459182ef1004bd43a731.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/6913b680274048dca62258f49e04c573.png
[7d7116b52f3d497486fe348cfcd07213.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/d0afcbb2f6344850ab74e1f4ea0a979f.png
[6569745dec0a4d45a900a3525214370f.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/24/1667539d078440209f568ef0485895c5.png