Activiti7 开发快速入门【2024版】

embedded/2024/9/19 18:36:57/ 标签: jbpm, workflow, java, springboot, Activiti

记录开发最核心的部分,理论结合业务实操减少废话,从未接触工作流快速带入开发。假设你是后端的同学学过JAVA和流程图,则可以继续向后看,否则先把基础课程书准备好先翻翻。

为什么要工作流

比起直接使用状态字段,工作流有以下几个好处:

  1. 直观管理:可以直接通过维护流程图设计来实现状态流转。流程变化可直接维护BMP流程图发布来实现变更
  2. 复杂流程:会签、序签、指定时间半数以上通过等等
  3. 低代码:基于表单的审批数据模式性很强,可以比较方便的实现低代码,高效开发

其它理由不用多说,光这3项的场景就有充分使用的理由。如果模式非常简单,还是状态字段来的直接。

从流程图说起

我们知道,一个流程图包括开始状态、结束状态、任务节点、流程条件。嗯,看起来像这样

对应Activiti的概念:

实例:开始一个任务后,则产生一个流程实例,即ProcessInstance

任务:当走到一个任务节点时,则产生任务,任务有单个和多个两种模式,多个任务有顺序和并行模式 

执行:通常一个任务节点会产生一个执行,但是并行节点或分支任务会产生多个执行,一个进行中的任务对应一个执行,每个执行可以有多个子执行(多个任务节点时)。这里的执行,相当于有多少个“待办任务”在进行。当对应的任务完成时,执行表的对应记录也会被删除

变量:流程的数据容器,在整个流转过程中。变量分为两种,一种是实例级别的变量,另一种是执行级别的变量。对应task.setVariable和execution.setVariable,区别是execution variable只在当前的执行节点有效,而task variable是针对任务的变量。

变量生命周期:对于task和execution,都有setVariable和setLocalVariable两种。变量的setVariable设置的值针对整个流程实例生命周期有效,而setLocalVariable设置的值针对当前任务节点有效。可以理解为始终使用还是一次性使用(针对网关使用一次后作废)。

边界事件:定时、信号等事件,在事件网关时,可以根据事件来定义。实现时间或信号特性的约束,常见的场景例如客服1小时处理不完投诉则交给主管处理。

约束条件与网关

以前面的流程图为例,超过3天和不超过3天为根据约束条件产生的两种不同的操作任务。在Activiti7里用网关(gateway)来表示。网关有表达式(SPEL)、脚本和Java类3中处理。常用的为表达式模式。当前一个任务完成(complete)时,根据表达式不同走向不同的节点

网关有4种类型:

排他网关(Exclusive Gateway)

会按照给定的条件,产生一个任务实例

蛋疼理论:如果多个分支条件都满足,或者一个分支都不满足,怎么办?
如果都满足,流程会按照id值升序,处理第一条分支(先定义的分支id通常值较小,但不绝对)
如果都不满足,则会抛出异常

并行网关(ParallelGateway)

会按照给定的条件,产生多个任务实例。并行网关可以并行作业,提高业务流程速度。

包容网关(Inclusive Gateway)

相当于排他和并行的综合体 ,同时执行时可以指定条件,例如某些需要补充材料的情况

事件网关(Event Gateway)

用于根据事件的触发选择分支路径。当指定的事件触发时,流程会选择对应的分支执行。

多实例与子执行

有那么一种业务,流程图可能表示为多个人参与同一个活动。例如你可能想到的流程图:

像这种活动,在BPM里,可以作为单个任务节点来实现。叫做多实例任务。

我们可以通过节点的MultiInstance来指定多实例,当指定多实例时,需要设置Collection的参数来决定进入任务时产生多少个子执行。Collection是一组java.util.Collection接口的数据。进入任务时,将产生一个对应的主执行,和多个子执行,这些子任务将分别指派给Collection的每一个人员。

对应的业务场景通常有会签和序签。序签用的较少,这里主要讲会签。

会签模式

会员的模式主要有:

按数量通过:达到一定数量的通过表决后,会签通过。
按比例通过:达到一定比例的通过表决后,会签通过。
一票否决:只要有一个表决是否定的,会签否决。
一票通过:只要有一个表决通过的,会签通过。

我们可以在Task的MultiInstance配置多实例的信息。可以配置的有:

模式参数

顺序(sequential ):执行顺序,必选项。true:多实例顺序执行。false:多实例并行。
并行(parallel):多个实例会同时并行发放给处理人

loop cardinality:循环基数(实例数量),可选项。可填整数,表示会签的人数。
Collection:集合,可选项。会签人数的集合list,与loop cardinality二选一。
Element variable:元素变量。选择Collection时必选,为collection集合每次遍历的元素。
Completion condition:完成条件,可选项。

完成条件

会签配置关键就是Completion condition,可以填写一个UEL(类似SPEL)。在流程流转时,对于多实例节点,会内置下面几个参数:

nrOfInstances:创建的实例总数,在进入任务节点时则设置好,一般等于Collection的数量
nrOfActiveInstances:当前活动的实例数,针对顺序类型的多实例,该变量值等于1;对于并行的类型,进入任务时为Collection数量,每完成一个执行,则活动任务数减1。
nrOfCompletedInstances:已执行实例数。每完成一个执行,则加1。
loopCounter:表示多实例流程循环的下标,顺序执行时记录执行顺序。

条件实现

理解上面的内容这样实现的方式就很明确了:

假设我们为会签设置了2个投票池(说白了就是变量)approveCount和denyCount。操作时,每点击"同意"或"拒绝"(先不考虑弃权情况)则变量+1

1)按数量通过:2人通过则通过#{approveCount > 2}
2)按比例通过:常见的过半数同意则通过 #{agreeCount/nrOfInstance > 0.5}
3)一票否决:#{denyCount== 1}
4)一票通过:#{approveCount== 1}

序签:较少使用。需要每个人员逐一完成任务。

抢单与代办

接下来讲两个常见业务场景,第一个是抢单。抢单的需求为我们可以将任务指定给一个处理小组,处理小组某个人点击“开始处理”后,其它人将无法再点击处理按钮或点击处理按钮提示已被抢单。

核心业务实现:

1)任务的CandidateUser属性可以指定一组处理人员,Task的Candidata Users属性可以通过SPEL指定一个列表。当指派列表后,任务流转到节点时所有的Candidata Users都会收到一个代办任务。

2)操作员点击开始处理时,通过taskService.setAssignee(taskId, assignee);指派给某个人员,指派后,其它操作员将再无法看到这个任务

3)当其他操作员点击操作时,需要检查操作列表,如果已经被指派给非当前操作员 ,需要返回前端提醒用户该任务已指派。否则直接使用Activity引擎来处理指派,将会导致任务重新分配(和后面讲的代办逻辑一样)

代办的模式和抢单的一样,当某任务已经指定给某个操作员后。可以通过setAssignee实现操作的重新指派。从而实现代办指派。当然这只是流程级别的操作,对于业务的具体流转记录,我们还时得借助日志的实现。

Activiti之历史记录

对于工作流业务,仅有流程状态支撑显然不够。我们还需要对历史数据进行查询和展示。Activiti提供了一组历史记录表,以ACT_HI_开头,记录了流程信息、流程任务信息、以及流程的变量信息。能够满足一些常见的业务场景需求,例如:

审批历史

在审批的过程,我们通常需要添加批示信息。一个流程的审批历史类似:

张三:提交请假申请
组长:同意请假 
经理:同意请假
人事:请假申请处理完毕

如果不借助额外的数据表,我们可以使用流程变量。定义为一个String数组或者JSON,每经过一个处理节点添加一行记录。流程进行或完成时,将该记录拿出来展示,该信息记录在表act_hi_taskinst

注意如果使用流程实例变量记录审批过程JSON,需要留意String变量大小的限制(4000字符),以免在审批过程中超过大小。以每个节点审批信息256字符为例,我们可以推算最少大概15个节点审批信息填满会导致审批记录满。

流转节点

在任务记录表act_hi_taskinst里,记录了流程产生的任务以及经过的节点,以及对于流程图文件的任务节点的KEY。这样我们可以通过act_hi_taskinst,在BPMN流程定义图上绘制详细的节点流转标记进行展示

理论了很多,下一步来点干货实操

环境搭建

springboot+Activiti7为例,开始环境搭建。

Activiti依赖的支持有:

  • spring:提供了一组starter,启动后可以通过对应的Bean完成流程处理
  • spring-security:activiti7.X默认整合了springsecurity,使用sa-token或Shiro等其他权限控制需要剥离对spring-security的依赖,否则会报错。对springsecurity的依赖主要包含群组权限的部分,我们不需要完全可以剥离它
  • mybatis:数据存储层使用的是mybatis来进行控制

Activiti最新的版本

如果从sonatype公共的仓库去拿,仅能拿到4年前的版本7.1.0.M6。你可能满脑袋的问号:Activiti开源死掉了吗?不再支持了吗?

如果你去Activiti官网,会发现Activiti仍旧有维护,甚至发展到8.0版本。无法获得是因为我们没有配置Activiti官网仓库。以gradle为例,我们只需要添加这个仓库即可

    maven { url 'https://artifacts.alfresco.com/nexus/content/repositories/activiti-releases' } // activiti最新版仓库

然后我们可以使用最新版本了,为了避免表结构出现不兼容,还是选择7.X的最新版本:

implementation("org.activiti:activiti-spring-boot-starter:7.11.0")
implementation("org.activiti:activiti-core-dependencies:7.11.0")

升级注意

JDK版本依赖:Activiti自身仓库的版本都是使用JDK11编译,如果是使用JDK1.8编译会出现报错。解决办法1是升级JDK到11,2是重新使用JDK1.8编译整个Activity源(比较麻烦)。我选择的是升级到JDK11

剥离springsecurity依赖

剥离springsecurity依赖主要是方式是禁用Activiti里与springsecurity相关的starter

YAML配置的方式:
 

java">spring:autoconfigure:exclude:- org.activiti.spring.boot.ActivitiMethodSecurityAutoConfiguration- org.activiti.core.common.spring.identity.config.ActivitiSpringIdentityAutoConfiguration

代码配置方式:

java">@SpringBootApplication(exclude = {ActivitiMethodSecurityAutoConfiguration.class, ActivitiSpringIdentityAutoConfiguration.class}
)

然后启动你会发现,还会有Bean UserGroupManager报错,这个Bean是依赖spring security的群组功能。不使用群组的话,我们可以直接new个匿名类让spring装配不报错。

我的ActivitiConfiguration如下

java">package org.ccframe.app;import org.activiti.api.runtime.shared.identity.UserGroupManager;
import org.activiti.spring.SpringProcessEngineConfiguration;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.Resource;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.security.core.userdetails.User;
import org.springframework.security.core.userdetails.UserDetails;
import org.springframework.security.core.userdetails.UserDetailsService;
import org.springframework.security.core.userdetails.UsernameNotFoundException;
import org.springframework.transaction.PlatformTransactionManager;import javax.sql.DataSource;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;@Configuration
public class ActivitiConfiguration {@Autowiredprivate DataSource dataSource;@Autowiredprivate PlatformTransactionManager transactionManager;//通过@Bean注解将SpringProcessEngineConfiguration实例声明为Spring Bean,使其可供其他组件注入和使用@Beanpublic SpringProcessEngineConfiguration springProcessEngineConfiguration() {SpringProcessEngineConfiguration spec = new SpringProcessEngineConfiguration();//设置数据源,将注入的数据源设置到SpringProcessEngineConfiguration实例中spec.setDataSource(this.dataSource);//设置事务管理器将注入的事务管理器设置到SpringProcessEngineConfiguration实例中spec.setTransactionManager(this.transactionManager);//设置数据库模式更新策略 true表示在启动时自动创建或更新Activiti引擎所需的数据库表结构spec.setDatabaseSchemaUpdate("true");Resource[] resources = null;//配置流程部署资源//使用PathMatchingResourcePatternResolver从classpath中的bpmn目录下加载所有以.bpmn为扩展名的文件作为流程定义资源,// 并将它们设置到SpringProcessEngineConfiguration实例中。try {resources = (new PathMatchingResourcePatternResolver()).getResources("classpath*:bpmn/*.bpmn");} catch (IOException var4) {var4.printStackTrace();}spec.setDeploymentResources(resources);return spec;}@Beanpublic UserGroupManager userGroupManager(){return new UserGroupManager(){@Overridepublic List<String> getUserGroups(String username) {return new ArrayList<>();}@Overridepublic List<String> getUserRoles(String username) {return new ArrayList<>();}@Overridepublic List<String> getGroups() {return new ArrayList<>();}@Overridepublic List<String> getUsers() {return new ArrayList<>();}};}
}

这里只是不使用group的功能,当然你可以使用自己的权限系统来实现group的功能,将group信息对应到自己权限系统的用户列表。


可控流转的实现

<编写中>


http://www.ppmy.cn/embedded/33475.html

相关文章

leetcode47-Permutations II

分析 给定一个可包含重复数字的序列 nums &#xff0c;按任意顺序 返回所有不重复的全排列。 示例 1&#xff1a; 输入&#xff1a;nums [1,1,2] 输出&#xff1a; [[1,1,2], [1,2,1], [2,1,1]] 题目 由于元素是重复的&#xff0c;要求返回不重复的&#xff0c;所以一定会有…

Java项目图片上传至七牛云对象存储

目录 1.购买七牛云对象存储&#xff08;学生能免费试用1年40GB&#xff01;新用户也有优惠&#xff09; 2.新建空间 ​3.查看官方文档&#xff0c;选择相应上传删除等方法&#xff0c;获取对应key和value&#xff0c;以上传为例 4.添加自定义域名 由于近期购买的云服务器挂…

Angular进阶-NVM管理Node.js实现不同版本Angular环境切换

一、NVM介绍 1. NVM简介 Node Version Manager&#xff08;NVM&#xff09;是一个用于管理多个Node.js版本的工具。它允许用户在同一台机器上安装和使用多个Node.js版本&#xff0c;非常适合需要同时进行多个项目的开发者。NVM是开源的&#xff0c;支持MacOS、Windows和Linux…

实习与就业|基于Springboot+vue的实习与就业管理系统(源码+数据库+文档)

实习与就业目录 基于Springbootvue的实习与就业管理系统 一、前言 二、系统设计 三、系统功能设计 管理员登录 就业管理 企业公告信息管理 企业公告类型管理 四、数据库设计 五、核心代码 六、论文参考 七、最新计算机毕设选题推荐 八、源码获取&#xff1a; 博主…

测试开发工具开发 -JMeter 函数二次开发

在JMeter中开发自定义函数是一个常见的需求&#xff0c;允许我们扩展JMeter的功能以适应特定的测试需求。自定义函数可以用来处理数据&#xff0c;生成输出&#xff0c;或者执行特定的运算。通过JMeter函数二次开发可以帮我们解决实际测试过程中造数难的问题 用过JMeter的同学…

操作系统:线程

目录 前言&#xff1a; 1.线程 1.1.初识线程 1.2.“轻量化”进程 1.3.线程与进程 2.线程控制 2.1.pthread原生线程库 2.2.线程控制的接口 2.2.1.线程创建 2.2.线程退出|线程等待|线程分离|线程取消 2.3.pthread库的原理 2.4.语言和pthread库的关系 2.5.线程局部…

java下乡扶贫志愿者招募管理系统springboot-vue

计算机技术在现代管理中的应用&#xff0c;使计算机成为人们应用现代技术的重要工具。能够有效的解决获取信息便捷化、全面化的问题&#xff0c;提高效率。 技术栈 前端&#xff1a;vue.jsElementUI 开发工具&#xff1a;IDEA 或者eclipse都支持 编程语言: java 框架&#xff1…

Node.js 的 fs 模块分析及其应用

fs 模块&#xff0c;作为 Node.js 平台中的一个核心组件&#xff0c;主要负责处理文件系统相关的操作。该模块提供了一系列用于文件管理的功能&#xff0c;例如文件的读取、写入、更新以及删除等。 应用场景分析 fs 模块的应用范围广泛&#xff0c;下面是一些典型的使用实例&…

定时器编程前配置和控制LED隔一秒亮灭

1.配置定时器 0 工作模式16位计时 2.给初值&#xff0c;定一个10ms出来 3.开始计时

Unity UGUI Image 点击事件忽略空白像素区域

我们会遇到图片不是方形的不规则图片。这个时候我们希望只有点击到图像内容本身才算点击&#xff0c;点击空白区域则不算点击。而UGUI对图片的处理是整个图片都会算作点击区域&#xff0c;这样不能满足于我们的使用需求了。 首先我们需要把图片本身的Read/Write 选项打开 然后…

Redis 实战之压缩列表

Redis 实战 - 压缩列表 压缩列表的构成压缩列表节点的构成previous_entry_lengthencodingcontent 连锁更新总结 压缩列表的构成 压缩列表是 Redis 为了节约内存而开发的&#xff0c; 由一系列特殊编码的连续内存块组成的顺序型&#xff08;sequential&#xff09;数据结构。 …

跟我学C++中级篇——const和constexpr的使用

一、从例程介绍 已经不同的篇章里介绍和分析过const及constexpr&#xff0c;特别对于后者&#xff0c;从c11到c14直到c17甚至以后&#xff0c;功能都不断的在完善。那么这么多复杂的应用如何搞清楚呢&#xff1f;下面先从代码看起&#xff1a; #include <iostream>void…

54.HarmonyOS鸿蒙系统 App(ArkTS)tcp socket套接字网络连接收发测试

工程代码https://download.csdn.net/download/txwtech/89258409?spm1001.2014.3001.5501 54.HarmonyOS鸿蒙系统 App(ArkTS)tcp socket套接字网络连接收发测试 import socket from ohos.net.socket; import process from ohos.process; import wifiManager from ohos.wifiMana…

C++中的回溯搜索法(Backtracking)

回溯搜索法&#xff08;Backtracking&#xff09;是一种通过试错的方法来解决问题的策略。在C中&#xff0c;这种方法通常用于解决诸如组合问题、划分问题、排列问题等&#xff0c;尤其在涉及到约束满足问题&#xff08;CSP&#xff0c;Constraint Satisfaction Problem&#x…

vue-html5-editor富文本编辑器抓取网络图片本地化

在vue中使用vue-html5-editor做的文章内容编辑器&#xff0c;至于怎么引用可另行百度&#xff0c;网络上有很多介绍&#xff1b;本文主要介绍如何在复制粘贴的时候跳过跨域限制和禁止外站的图片请求问题。 本文的方法比较笨拙&#xff0c;一起交流学习。 在研究使用vue-html5…

Having和Where的区别

Having和Where都是过滤数据的关键子句 Where是在分组之前过滤数据 SELECT * FROM Employees WHERE department Tech;Having是在分组之后利用聚合函数进行过滤 SELECT department, AVG(salary) AS average_salary FROM Employees GROUP BY department HAVING AVG(salary) >…

django之select_related、prefetch_related

django中的ORM查询,针对复杂的查询,处理使用A.objects.filter(foreign_name__field)进行查询外。还可以使用select_related 和prefetch_related,进行性能的优化 select_related: 将会根据外键关系(注意: 仅限单对单和单对多关系),在执行查询语句的时候通过创建一条包含…

基于高德 API 的自动获取气候数据的 Python 脚本

文章目录 高德申请 Key脚本介绍运行结果示例 源代码&#xff1a; https://github.com/ma0513207162/PyPrecip。pyprecip\reading\read_api.py 路径下。 项目介绍&#xff1a;PyPrecip 是一个专注于气候数据处理的 Python 库&#xff0c;旨在为用户提供方便、高效的气候数据处理…

图神经网络GNN的表达能力

回顾 图卷积神经网络GCN GNN概要 神经网络的表达能力 分类or回归 神经网络的表达能力举例&#xff1a; 深度学习的理论基础和上限 GNN的表达能力 定义&#xff1a;图神经网络的表达能力就是它区分不同图的区分能力 分析常见的GNN的表达能力并设计出表达能力最强的GN…

【MySQL】——用户和权限管理(二)

&#x1f4bb;博主现有专栏&#xff1a; C51单片机&#xff08;STC89C516&#xff09;&#xff0c;c语言&#xff0c;c&#xff0c;离散数学&#xff0c;算法设计与分析&#xff0c;数据结构&#xff0c;Python&#xff0c;Java基础&#xff0c;MySQL&#xff0c;linux&#xf…