Activiti7学习笔记

小灰灰 2024-03-17 09:46 59阅读 0赞

## Activiti7学习 ##

### 工作流相关概念 ###

#### 工作流 ####

工作流(Workflow)，就是通过计算机对业务流程自动化执行管理。它主要解决的是“使在多个参与者之间按照某种预定义的规则自动进行传递文档、信息或任务的过程，从而实现某个预期的业务目标，或者促使此目标的实现”。

#### BPM ####

BPM（Business Process Management），即业务流程管理，是一种以规范化的构造端到端的卓越业务流程为中心，以持续的提高组织业务绩效为目的系统化方法，常见商业管理教育如EMBA、MBA等均将 BPM 包含在内。

#### BPM软件 ####

BPM 软件就是根据企业中业务环境的变化，推进人与人之间、人与系统之间以及系统与系统之  
间的整合及调整的经营方法与解决方案的 IT 工具。 通常以 Internet 方式实现信息传递、数据同步、业务监控和企业业务流程的持续升级优化，从而实现跨应用、跨部门、跨合作伙伴与客户的企业运作。通过 BPM 软件对企业内部及外部的业务流程的整个生命周期进行建模、自动化、管理监控和优化，使企业成本降低，利润得以大幅提升。BPM 软件在企业中应用领域广泛，凡是有业务流程的地方都可以 BPM 软件进行管理，比如企业人事办公管理、采购流程管理、公文审批流程管理、财务管理等。

#### BPMN ####

BPMN（Business Process Model And Notation）- 业务流程模型和符号 是由 BPMI（Business  
Process Management Initiative）开发的一套标准的业务流程建模符号，使用 BPMN 提供的符号可以创建业务流程。 2004 年 5 月发布了 BPMN1.0 规范.BPMI 于 2005 年 9 月并入 OMG（The ObjectManagement Group 对象管理组织)组织。OMG 于 2011 年 1 月发布 BPMN2.0 的最终版本。

BPMN 是目前被各 BPM 厂商广泛接受的 BPM 标准。Activiti 就是使用 BPMN 2.0 进行流程建  
模、流程执行管理，它包括很多的建模符号，具体可以参考下面的文章：  
[BPMN（业务流程建模符号）入门到掌握，这一篇就够了][BPMN]

[全新BPMN常用图形标识一览表][BPMN 1]

#### Activiti7介绍 ####

Alfresco 软件在 2010 年 5 月 17 日宣布 Activiti 业务流程管理（BPM）开源项目的正式启动，其  
首席架构师由业务流程管理 BPM 的专家 Tom Baeyens 担任，Tom Baeyens 就是原来 jbpm 的架构师，而 jbpm 是一个非常有名的工作流引擎，当然 activiti 也是一个工作流引擎。

Activiti 是一个工作流引擎， activiti 可以将业务系统中复杂的业务流程抽取出来，使用专门的  
建模语言（BPMN2.0）进行定义，业务系统按照预先定义的流程进行执行，实现了业务系统的业务流程由 activiti 进行管理，减少业务系统由于流程变更进行系统升级改造的工作量，从而提高系统的健壮性，同时也减少了系统开发维护成本。

官方网站：https://www.activiti.org/

### Activiti7使用 ###

#### 怎么使用Activiti ####

1.  部署Activiti
    
     *  Activiti 是一个工作流引擎（其实就是一堆 jar 包 API），业务系统使用 activiti 来对系统的业务流程进行自动化管理，为了方便业务系统访问(操作)activiti 的接口或功能，通常将activiti 环境与业务系统的环境集成在一起。
2.  流程定义
    
     *  使用 activiti 流程建模工具(activity-designer)定义业务流程(.bpmn 文件) 。.bpmn 文件就是业务流程定义文件，通过 xml 定义业务流程。
3.  流程定义部署
    
     *  向 activiti 部署业务流程定义（.bpmn 文件）。使用 activiti 提供的 api 向 activiti 中部署.bpmn 文件（一般情况还需要一块儿部署业务流程的图片.png）。
4.  启动一个流程实例（ProcessInstance）
    
     *  启动一个流程实例表示开始一次业务流程的运行，比如员工请假流程部署完成，如果张三要请假就可以启动一个流程实例，如果李四要请假也启动一个流程实例，两个流程的执行互相不影响，就好比定义一个 java 类，实例化两个对象一样，部署的流程就好比 java 类，启动一个流程实例就好比 new 一个 java 对象。
5.  用户查询待办任务(Task)
    
     *  因为现在系统的业务流程已经交给 activiti 管理，通过 activiti 就可以查询当前流程执行到哪了，当前用户需要办理什么任务了，这些 activiti帮我们管理了，而不像上边需要我们在 sql语句中的where条件中指定当前查询的状态值是多少。
6.  用户办理任务
    
     *  用户查询待办任务后，就可以办理某个任务，如果这个任务办理完成还需要其它用户办理，比如采购单创建后由部门经理审核，这个过程也是由 activiti 帮我们完成了，不需要我们在代码中硬编码指定下一个任务办理人了。
7.  流程结束
    
     *  当任务办理完成没有下一个任务/结点了，这个流程实例就完成了。

#### Activiti环境搭建 ####

##### 下载Activiti Designer 流程设计器 #####

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

##### 依赖 #####

<dependencies>
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-engine</artifactId>
                <version>7.1.0.M2</version>
            </dependency>
            
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-spring</artifactId>
                <version>7.1.0.M2</version>
            </dependency>
    
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-bpmn-model</artifactId>
                <version>7.1.0.M2</version>
            </dependency>
    
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-bpmn-converter</artifactId>
                <version>7.1.0.M2</version>
            </dependency>
    
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-json-converter</artifactId>
                <version>7.1.0.M2</version>
            </dependency>
    
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-bpmn-layout</artifactId>
                <version>7.1.0.M2</version>
            </dependency>
    
            <dependency>
                <groupId>org.activiti.cloud</groupId>
                <artifactId>activiti-cloud-services-api</artifactId>
                <version>7.1.0.M2</version>
            </dependency>
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>8.0.20</version>
            </dependency>
    
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.12</version>
            </dependency>
        </dependencies>
        
        <repositories>
            <repository>
                <id>alfresco</id>
                <name>Activiti Releases</name>
                <url>https://artifacts.alfresco.com/nexus/content/repositories/activiti-releases/</url>
                <releases>
                    <enabled>true</enabled>
                </releases>
            </repository>
        </repositories>

配置文件

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:context="http://www.springframework.org/schema/context"
           xmlns:tx="http://www.springframework.org/schema/tx"
           xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
    						http://www.springframework.org/schema/contex http://www.springframework.org/schema/context/spring-context.xsd
    						http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">
    
        
        <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
            <property name="driverClassName" value="com.mysql.jdbc.Driver" />
            <property name="url" value="jdbc:mysql://localhost:3306/activiti?useSSL=false&useUnicode=true&characterEncoding=utf8&serverTimezone=Asia/Shanghai" />
            <property name="username" value="root" />
            <property name="password" value="root" />
        </bean>
    
        
        <bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
            
            <property name="dataSource" ref="dataSource"></property>
            
            <property name="databaseSchemaUpdate" value="true"/>
        </bean>
    </beans>

log4j日志配置

# Set root category priority to INFO and its only appender to CONSOLE.
    #log4j.rootCategory=INFO, CONSOLE            debug   info   warn error fatal
    log4j.rootCategory=debug, CONSOLE, LOGFILE
    
    # Set the enterprise logger category to FATAL and its only appender to CONSOLE.
    log4j.logger.org.apache.axis.enterprise=FATAL, CONSOLE
    
    # CONSOLE is set to be a ConsoleAppender using a PatternLayout.
    log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
    log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
    log4j.appender.CONSOLE.layout.ConversionPattern=%d{ISO8601} %-6r [%15.15t] %-5p %30.30c %x - %m\n
    
    # LOGFILE is set to be a File appender using a PatternLayout.
    log4j.appender.LOGFILE=org.apache.log4j.FileAppender
    log4j.appender.LOGFILE.File=d:\axis.log
    log4j.appender.LOGFILE.Append=true
    log4j.appender.LOGFILE.layout=org.apache.log4j.PatternLayout
    log4j.appender.LOGFILE.layout.ConversionPattern=%d{ISO8601} %-6r [%15.15t] %-5p %30.30c %x - %m\n

测试程序

public static void main(String[] args) {
        
            //需要使用ProcessEngine提供的工具类ProcessEngines的getDefaultProcessEngine()方法
            //默认会读取resource下的activiti.cfg.xml文件，创建ProcessEngine时就会创建mysql中的表
            ProcessEngine engine = ProcessEngines.getDefaultProcessEngine();
            System.out.println("engine: " + engine);
            InputStream stream = Test1.class.getClassLoader().getResourceAsStream("activiti.cfg.xml");
            ProcessEngineConfiguration.createProcessEngineConfigurationFromInputStream(stream);
        }

运行上面的代码即可在数据库中创建出Activiti的24张表。

#### Activiti中的表 ####

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

Activiti会创建25张表。Activiti的表都以act\_开头，第二部分是表示表的用途的两个字母标识，用途和服务的API对应。

1.  act\_re\_\*：re标识repository，这个前缀的表包含了流程定义和静态资源；  
    ○ deployment：流程部署表，每部署一次会增加一条记录；  
    ○ procdef：流程定义表；
2.  act\_ru\_\*：ru表示Runtime，这些运行时的表，包含流程实例，任务，变量，异步任务等运行中的数据。Activiti只在流程实例执行过程中保存这些数据，在流程结束后会删除这些记录；  
    ○ execution：流程执行的信息；  
    ○ identitylink：流程参与者信息；  
    ○ task：正在执行的任务信息；
3.  act\_hi\_\*：hi表示History，这些表包含历史数据，比如历史流程实例，变量、任务等；  
    ○ actinst：流程实例执行历史  
    ○ identitylink：流程参与者的历史信息  
    ○ procinst：流程实例的历史信息
4.  act\_ge\_\*：ge表示general，通用数据，用于不同场景下。

#### 常用类介绍 ####

##### ProcessEngineConfiguration #####

流程引擎配置类。

#### Activiti入门 ####

##### 流程定义 #####

流程定义是线下按照 bpmn2.0 标准去描述业务流程，通常使用activiti-explorer（web 控制台）  
或插件对业务流程进行建模，这两种方式都遵循 bpmn2.0标准。  
1、创建流程定义文件  
![在这里插入图片描述][65b20d1b685b482f85aa88ddb650e3be.png]  
2、右键选择view文件  
![在这里插入图片描述][87269428f6144de4b0ee9672dedcb15a.png]  
3、在打开的设计器界面中，点击右键，会出现可以使用的图形；

![在这里插入图片描述][c7a8d1359d9d40c7a6d3967411f25431.png]  
4、将流程以图片的形式保存到bpmn目录下。到此就完成了一个流程的定义。  
下图中的id其实就是流程的key，记得设置它。  
![在这里插入图片描述][6a588e3ee0694125862f657d498424dc.png]

##### 部署流程定义 #####

将定义的流程部署到activiti数据库中，这就是流程定义部署，通过调用activiti的api将流程定义的 bpmn和png两个文件一个一个添加部署到activiti中，也可以将两个文件打成 zip 包进行部署。

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RepositoryService repositoryService = processEngine.getRepositoryService();
            Deployment deployment = repositoryService.createDeployment().addClasspathResource("bpmn/dimission.bpmn20.xml")
                    .addClasspathResource("bpmn/dimission.png")
                    .name("离职申请流程")
                    .deploy();
            System.out.println("流程部署id：" + deployment.getId());
            System.out.println("流程部署名称:" + deployment.getName());

SELECT \* FROM act\_re\_deployment：流程定义部署表，记录流程部署信息  
SELECT \* FROM act\_re\_procdef：流程定义表，记录流程定义信息  
SELECT \* FROM act\_ge\_bytearray：资源表  
说明：act\_re\_deployment和act\_re\_procdef一对多关系，一次部署在流程部署表生成一条记录，但一次部署可以部署多个流程定义，每个流程定义在流程定义表生成一条记录。每一个流程定义在act\_ge\_bytearray 会存在两个资源记录，bpmn 和png。  
建议：一次部署一个流程，这样部署表和流程定义表是一对一有关系，方便读取流程部署及流程定  
义信息。  
![在这里插入图片描述][cd97df293ebe4d72a00f63955b4a671c.png]

##### 启动流程实例 #####

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RuntimeService runtimeService = processEngine.getRuntimeService();
            ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("dimission");
    
            System.out.println("流程定义id: " + processInstance.getProcessDefinitionId());
            System.out.println("流程实例id: " + processInstance.getId());
            System.out.println("当活动id: " + processInstance.getActivityId());

可以看到插入了7条数据。  
![在这里插入图片描述][3d52573b659c40939d372689365bdcec.png]

##### 任务查询 #####

流程启动后，各个任务的负责人可以查询自己需要处理的任务；查询出来的都是负责人的待办任务。

前面我们创建流程时没有指定任务的负责人，可以参考下图指定任务的负责人。**修改流程后需要重新部署启动流程，才能查询到最新的数据。**  
name：任务的名称；Assignee：任务负责人；  
![在这里插入图片描述][bac78e1ef92949c9a815e3f122c84d72.png]  
查询任务代码如下：

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            List<Task> taskList = taskService.createTaskQuery()
                    .taskAssignee("leader") //负责人
                    .processDefinitionKey("dimission") //流程定义key
                    .list();
            for (Task task : taskList) {
        
                System.out.println("任务名称: " + task.getName());
                System.out.println("任务id：" + task.getId());
                System.out.println("任务负责人: " + task.getAssignee());
            }

结果：  
![在这里插入图片描述][a9b767cce2724dc98ae4ea6dd0d2f886.png]

##### 任务处理 #####

前面我们已经查询出了任务，用户可以完成任务。

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            TaskService taskService = processEngine.getTaskService();
            //参数：任务的id
            taskService.complete("32505");

##### 删除流定义 #####

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RepositoryService repositoryService = processEngine.getRepositoryService();
            //参数：流程部署id，每次部署id都会发生变化
            //普通删除：如果该流程定义已有启动的流程实例，则删除时会报错
           repositoryService.deleteDeployment("37501");
           //级联删除：将流程及相关记录全部删除，即使有已启动的流程实例也不会报错
            //repositoryService.deleteDeployment("37501", true);

##### 查询流程定义资源 #####

@Test
        public void queryProcessResource() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            RepositoryService repositoryService = processEngine.getRepositoryService();
            //因为部署过多次，所以ProcessDefinition表中会有多条记录，如果只由一条记录不需要使用list方法，使用singleResult方法
            List<ProcessDefinition> processDefinitions = repositoryService
                    .createProcessDefinitionQuery()
                    .processDefinitionKey("dimission")
                    .list();
    
            for (ProcessDefinition processDefinition : processDefinitions) {
        
                String resourceName = processDefinition.getResourceName();
                String diagramResourceName = processDefinition.getDiagramResourceName();
                System.out.println("resourceName: " + resourceName);
                System.out.println("diagramResourceName: " + diagramResourceName);
            }
        }

##### 查询流程的历史信息 #####

即使流程定义已经删除了，流程执行的历史信息依然保存在 activiti 的act\_hi\_\*相关的表中。所以我们还是可以查询流程执行的历史信息

@Test
        public void queryProcessHistory() {
        
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            HistoryService historyService = processEngine.getHistoryService();
            List<HistoricActivityInstance> activityInstanceList = historyService
                    .createHistoricActivityInstanceQuery()
                    .processInstanceId("42501")
                    .list();
            for (HistoricActivityInstance instance : activityInstanceList) {
        
                System.out.println(" : " + instance.getActivityId());
                System.out.println(" : " + instance.getActivityName());
                System.out.println(" : " + instance.getProcessDefinitionId());
                System.out.println(" : " + instance.getProcessInstanceId());
            }
        }

### 参考 ###

*  [Activiti7视频][Activiti7]

[BPMN]: https://www.zhihu.com/tardis/zm/art/365967273?source_id=1005
[BPMN 1]: https://www.jianshu.com/p/1f80bf211502
[53212b151c8a45039c37bfd5f33e1fe6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/17/e3ae4a12903f4a809970153ecbdea439.png
[3ab93d16fd48435b8bcbf4e058f73fd3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/17/f694583c63494c669d3f423538f74cb1.png
[65b20d1b685b482f85aa88ddb650e3be.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/17/ef6ee2222e60476aaea86c092e0c98b0.png
[87269428f6144de4b0ee9672dedcb15a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/17/f187ae7c121f41dd94c347626103a391.png
[c7a8d1359d9d40c7a6d3967411f25431.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/17/76435b1022bc45ea92c8f813f6291fcb.png
[6a588e3ee0694125862f657d498424dc.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/17/ecfdbdc3e9b141319d2beb3d699d6ce2.png
[cd97df293ebe4d72a00f63955b4a671c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/17/39842f72eb16474f924c7c9cdc071b58.png
[3d52573b659c40939d372689365bdcec.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/17/d2ac87358dd14b8a93b632dbc5431171.png
[bac78e1ef92949c9a815e3f122c84d72.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/17/120e1243f4c449949e32e58aa017e0f5.png
[a9b767cce2724dc98ae4ea6dd0d2f886.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/17/e1e02230c5b8405e9f4f9cb6af83f212.png
[Activiti7]: https://www.bilibili.com/video/BV1H54y167gf/?spm_id_from=333.337.search-card.all.click