Activiti7笔记（四）Activiti进阶，什么是网关，网关种类分为什么，网关的案例实现

一写代码就开心

发布于 2022-05-09 10:13:02

1.3K0

发布于 2022-05-09 10:13:02

文章被收录于专栏：java和python

1网关作用是什么

网关用来控制流程的流向

1.1 排他网关ExclusiveGateway

只有一个分支可以使用

1.1.1 什么是排他网关：

排他网关，用来在流程中实现决策。当流程执行到这个网关，所有分支都会判断条件是否为true，如果为true则执行该分支，

注意：排他网关只会选择一个为true的分支执行。如果有两个分支条件都为true，排他网关会选择id值较小的一条分支去执行。

为什么要用排他网关？ 不用排他网关也可以实现分支，如：在连线的condition条件上设置分支条件。

在连线设置condition条件的缺点：如果条件都不满足，流程就结束了(是异常结束)。

如果使用排他网关决定分支的走向，如下：

如果从网关出去的线所有条件都不满足则系统抛出异常。

org.activiti.engine.ActivitiException: No outgoing sequence flow of the exclusive gateway 'exclusivegateway1' could be selected for continuing the process
   at org.activiti.engine.impl.bpmn.behavior.ExclusiveGatewayActivityBehavior.leave(ExclusiveGatewayActivityBehavior.java:85)

总结：虽然可以直接在连线上面进行判断条件，但是如果不使用排他网关，当条件都
为false的时候，直接结束流程了；

如果使用了排他网关，当条件都为false，那么会抛出错误，这样使用者就会知道了
哪个地方出错

1.1.2 流程定义

排他网关图标，红框内：

1.1.3 测试

在部门经理审核后，走排他网关，从排他网关出来的分支有两条，一条是判断出差天数是否大于3天，另一条是判断出差天数是否小于等于3天。

设置分支条件时，如果所有分支条件都不是true，报错：

org.activiti.engine.ActivitiException: No outgoing sequence flow of the exclusive gateway 'exclusivegateway1' could be selected for continuing the process

       at org.activiti.engine.impl.bpmn.behavior.ExclusiveGatewayActivityBehavior.leave(ExclusiveGatewayActivityBehavior.java:85)

1.2 并行网关ParallelGateway

1.2.1 什么是并行网关

并行网关允许将流程分成多条分支，也可以把多条分支汇聚到一起，并行网关的功能是基于进入和外出顺序流的：

l fork分支：

并行后的所有外出顺序流，为每个顺序流都创建一个并发分支。

l join汇聚：

所有到达并行网关，在此等待的进入分支，直到所有进入顺序流的分支都到达以后，流程就会通过汇聚网关。

注意，如果同一个并行网关有多个进入和多个外出顺序流，它就同时具有分支和汇聚功能。这时，网关会先汇聚所有进入的顺序流，然后再切分成多个并行分支。

与其他网关的主要区别是，并行网关不会解析条件。 即使顺序流中定义了条件，也会被忽略。

总结：并行网关的线上面，写上条件也没有用，在并行网关的后面分支都要执行完成之后，才会走下一个任务，不然，只要有一个分支没有完成，后面的任务就不会走

说明：

技术经理和项目经理是两个execution分支，在act_ru_execution表有两条记录分别是技术经理和项目经理，act_ru_execution还有一条记录表示该流程实例。

待技术经理和项目经理任务全部完成，在汇聚点汇聚，通过parallelGateway并行网关。

并行网关在业务应用中常用于会签任务，会签任务即多个参与者共同办理的任务。

1.2.3 流程定义

并行网关图标，红框内：

1.2.3 并行网关案例

我们首先创建一个流程，然后执行代码，将我们画的流程图部署到数据库

以上是画好的bump的文件，然后执行代码，进行部署到数据库

执行完成以上的代码，数据库里面就已经保存了

然后启动流程实例，就是执行一个代码，相当于创建一个申请单

    /**
     * 启动流程实例,相当于申请提交申请单,并且要设置流程变量
     */
    @Test
    public void testStartProcess(){
//        1、创建ProcessEngine
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//        2、获取RunTimeService
        RuntimeService runtimeService = processEngine.getRuntimeService();
//        流程定义key
        String key = "paraller";
//        创建变量集合
        Map<String, Object> map = new HashMap<String, Object>();
//        创建出差pojo对象
        Evection evection = new Evection();
        evection.setNum(4d);
//定义流程变量，把出差的pojo对象放入map里面
        map.put("evection",evection);
//        3、根据流程定义Id启动流程
        ProcessInstance processInstance = runtimeService
                .startProcessInstanceByKey(key,map);

//        输出内容
        System.out.println("流程定义id：" + processInstance.getProcessDefinitionId());
        System.out.println("流程实例id：" + processInstance.getId());
        System.out.println("当前活动Id：" + processInstance.getActivityId());
//
//        流程定义id：myJtxx:1:4
//        流程实例id：2501
//        当前活动Id：null
    }

以上就是创建一个申请单了，

从数据库可以看到，当前的流程实例，只有tom正在执行，我们现在对tom进行完成

    /**
     * 测试完成个人任务
     */
    @Test
    public void completTask(){
        String key ="paraller";
        String assingee = "tom";
//        获取引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//        获取操作任务的服务 TaskService
        TaskService taskService = processEngine.getTaskService();
//        完成任务,参数：流程实例id,完成zhangsan的任务
//        根据用户查询是否有任务
        Task task = taskService.createTaskQuery()
                .processDefinitionKey(key)
                .taskAssignee(assingee)//这个是当前改谁执行了
                .singleResult();
        if(task != null){
            taskService.complete(task.getId());
            System.out.println("流程实例id="+task.getProcessInstanceId());
            System.out.println("任务Id="+task.getId());
            System.out.println("任务负责人="+task.getAssignee());
            System.out.println("任务名称="+task.getName());
        }
    }

tom 一走完，这个正在执行的任务就变为并行网关后面的两个分支了，数据库里面就有两个了