Activiti7工作流引擎:基础篇 自动生成表结构

Posted vbirdbest

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Activiti7工作流引擎:基础篇 自动生成表结构相关的知识,希望对你有一定的参考价值。

当你的才华撑不起你的野心的时候,你就必须静下心来学习。

Acitiviti7工作流框架就是提供了几个Service来操作几张表,作为一个框架自然已经为我们提供好了表结构,我们只需要配置数据库表处理策略databaseSchemaUpdate=true当表不存在时自动生成即可。

一:自动生成表结构

1.1 pom.xml

新建一个基础的maven工程(不需要springboot工程),引入Activiti相关依赖、数据库、日志相关依赖。

<properties>
  <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  <maven.compiler.source>1.8</maven.compiler.source>
  <maven.compiler.target>1.8</maven.compiler.target>

  <slf4j.version>1.6.6</slf4j.version>
  <log4j.version>1.2.12</log4j.version>
  <activiti.version>7.0.0.SR1</activiti.version>
</properties>

<dependencies>
  <dependency>
    <groupId>org.activiti</groupId>
    <artifactId>activiti-engine</artifactId>
    <version>$activiti.version</version>
  </dependency>

  <!-- bpmn 模型处理 -->
  <dependency>
    <groupId>org.activiti</groupId>
    <artifactId>activiti-bpmn-model</artifactId>
    <version>$activiti.version</version>
  </dependency>
  <!-- bpmn 转换 -->
  <dependency>
    <groupId>org.activiti</groupId>
    <artifactId>activiti-bpmn-converter</artifactId>
    <version>$activiti.version</version>
  </dependency>
  <!-- bpmn json数据转换 -->
  <dependency>
    <groupId>org.activiti</groupId>
    <artifactId>activiti-json-converter</artifactId>
    <version>$activiti.version</version>
  </dependency>
  <!-- bpmn 布局 -->
  <dependency>
    <groupId>org.activiti</groupId>
    <artifactId>activiti-bpmn-layout</artifactId>
    <version>$activiti.version</version>
  </dependency>
   <dependency>
      <groupId>org.activiti.cloud</groupId>
      <artifactId>activiti-cloud-services-api</artifactId>
      <version>$activiti.version</version>
  </dependency>
  <dependency>
    <groupId>org.activiti</groupId>
    <artifactId>activiti-spring</artifactId>
    <version>$activiti.version</version>
  </dependency>
  <!-- activiti 云支持 -->
 

  <!-- mysql驱动 -->
  <dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.40</version>
  </dependency>
  <!-- mybatis -->
  <dependency>
    <groupId>org.mybatis</groupId>
    <artifactId>mybatis</artifactId>
    <version>3.4.5</version>
  </dependency>
  <!-- 链接池 -->
 <dependency>
       <groupId>com.alibaba</groupId>
       <artifactId>druid</artifactId>
       <version>1.1.23</version>
 </dependency>

  <dependency>
    <groupId>junit</groupId>
    <artifactId>junit</artifactId>
    <version>4.12</version>
  </dependency>
  <!-- log start -->
  <dependency>
    <groupId>log4j</groupId>
    <artifactId>log4j</artifactId>
    <version>$log4j.version</version>
  </dependency>
  <dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-api</artifactId>
    <version>$slf4j.version</version>
  </dependency>
  <dependency>
    <groupId>org.slf4j</groupId>
    <artifactId>slf4j-log4j12</artifactId>
    <version>$slf4j.version</version>
  </dependency>
</dependencies>

1.2 resources/log4j.properties

log4j.rootCategory=debug, CONSOLE, LOGFILE
log4j.logger.org.apache.axis.enterprise=FATAL, CONSOLE

log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=%dISO8601 %-6r[%15.15t] %-5p %30.30c %x - %m\\n

log4j.appender.LOGFILE=org.apache.log4j.FileAppender
log4j.appender.LOGFILE.File=./activiti.log
log4j.appender.LOGFILE.Append=true
log4j.appender.LOGFILE.layout=org.apache.log4j.PatternLayout
log4j.appender.LOGFILE.layout.ConversionPattern=%dISO8601 %-6r[%15.15t] %-5p %30.30c %x - %m\\n

1.3 resources/activiti.cfg.xml

配置数据源。

<?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">
    <!-- 默认id对应的值为processEngineConfiguration -->
    <bean id="processEngineConfiguration"
          class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
        <property name="dataSource" ref="dataSource" />
        <!-- activiti数据库表处理策略:true表示数据库中已经存在相应的表,那么直接使用,如果不存在,那么会创建 -->
        <property name="databaseSchemaUpdate" value="true"/>
    </bean>

    <!-- 这里可以使用 链接池-->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
        <property name="url" value="jdbc:mysql://localhost:3306/activiti" />
        <property name="username" value="root" />
        <property name="password" value="root123" />
        <property name="maxActive" value="3" />
        <property name="maxIdle" value="1" />
    </bean>
</beans>

1.4 创建数据库

DROP DATABASE activiti;
CREATE DATABASE activiti DEFAULT CHARACTER SET utf8;

1.5 生成表结构

@Test
public void testCreateDBTable() 
	// getDefaultProcessEngine()会读取activiti.cfg.xml拿到一个ProcessEngineConfiguration对象,进而获取一个工作流引擎实例ProcessEngine
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    System.out.println(processEngine);

  • org/activiti/db/create/activiti.mysql.create.engine.sql
  • org/activiti/db/create/activiti.mysql.create.history.sql

注意:开发环境一般配置databaseSchemaUpdate=true,生产环境一般都配置为false。

注意:使用ProcessEngines.getDefaultProcessEngine()获取默认的流程引擎时activiti.cfg.xml中的bean配置id只能是processEngineConfiguration不能修改成别的,class也只能配置成StandaloneProcessEngineConfiguration

二:数据库表


Activiti 的表都以ACT_ 作为前缀,第二部分是表示表的用途的两个字母标识,用途也和服务的 API 对应,一共25张表,但不是所有表都需要了解,我们只需要了解最长用的表即可。

  • ACT_RE :'RE’表示 repository 仓库、资源,这个前缀的表包含了流程定义act_re_procdef和流程静态资源act_re_bytearray (.bpmn和.png文件)。
  • ACT_RU:'RU’表示 runtime 运行时,这些运行时的表包含流程实例execution,任务task,变量variable,异步任务job等运行中的数据。 Activiti 只在流程实例执行过程中保存这些数据, 在流程结束时就会删除这些记录,这样运行时表的数据量会非常少,数据库操作会非常快。
  • ACT_HI:'HI’表示 history 历史,这些表包含历史数据,比如历史流程实例, 变量,任务等等。
  • ACT_GE : GE 表示 general,通用数据, 用于保存一下属性配置。
表分类表名解释
通用数据
ACT_GE_BYTEARRAY流程资源文件.bpmn、.png
ACT_GE_PROPERTY系统相关属性
流程定义表
ACT_RE_PROCDEF已部署的流程定义,一般.bpmn文件对应一条数据
ACT_RE_DEPLOYMENT部署信息
ACT_RE_MODEL
运行实例表
ACT_RU_EXECUTION运行时流程执行实例
ACT_RU_TASK运行时任务
ACT_RU_IDENTITYLINK运行时节点任务参与人
ACT_RU_VARIABLE运行时变量表
流程历史记录
ACT_HI_PROCINST历史的流程实例
ACT_HI_TASKINST历史的任务实例
ACT_HI_VARINST历史的流程运行中的变量表
ACT_HI_IDENTITYLINK历史的流程运行过程中任务参与人
ACT_HI_ACTINST历史的流程实例
ACT_HI_COMMENT历史意见

三:Service类

service名称service作用
RepositoryServiceactiviti的资源管理类,一般用于操作act_re表,部署
RuntimeServiceactiviti的流程运行管理类,一般用于启动流程实例
TaskServiceactiviti的任务管理类,一般用于查询任务设置变量设置任务负责人拾取任务解决任务添加审批意见完成任务
HistoryServiceactiviti的历史管理类,常用于一些查询操作。
ManagerServiceactiviti的引擎管理类,一般使用不到。
IdentityService FormServiceactiviti6中有,activiti7中已经移除。

3.1 RepositoryService

资源管理类,用于对ACT_RE_DEPLOYMENT(资源部署表)、ACT_RE_PROCDEF(资源流程定义表)和ACT_GE_BYTEARRAY(资源文件表.bpmn、.png文件)的CRUD操作。

// 将流程定义文件insert到数据库中
// 同一个.bpmn文件允许部署多次,每次部署version_字段都+1
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deploy = repositoryService.createDeployment()
        .addClasspathResource("bpmn/xxx.bpmn")
        .name("请假流程")
        .deploy();
// 删除部署        
repositoryService.deleteDeployment(deploymentId, true);

// 查询流程定义
List<ProcessDefinition> processDefinitionList = repositoryService.createProcessDefinitionQuery()
        .processDefinitionKey(KEY)
        .list();

// 挂起流程定义
repositoryService.suspendProcessDefinitionById(processDefinitionId);

// 激活流程定义
repositoryService.activateProcessDefinitionById(processDefinitionId);

3.2 RuntimeService

流程运行管理类。可以从这个服务类中获取很多关于正在运行的流程执行相关的信息。

// 启动流程实例,开始发起一个申请请求
ProcessInstance processInstance = processEngine.getRuntimeService()
                .startProcessInstanceByKey(KEY);

3.3 TaskService

任务管理类。可以从这个类中获取任务的信息。

// 查询某个流程下的某个负责人待办的任务
Task task = processEngine.getTaskService()
                .createTaskQuery()
                .processDefinitionKey(KEY)
                .taskAssignee("张三")
                .singleResult();
// 设置变量                
taskService.setVariables(taskId, variables);
taskService.setVariable(taskId, variableName, value);

// 归还任务,将任务负责人设置为null
taskService.setAssignee(task.getId(), null);

// 任务交接,将自己的任务交给给候选人中的其它人
taskService.setAssignee(task.getId(), OtherAssignee);

// 拾取任务,将自己设为任务的负责人
taskService.claim(task.getId(), currentUserId);

// 解决任务
taskService.resolveTask(taskId, variables);

// 添加审批意见
taskService.addComment(taskId, processInstanceId, "同意")

// 审核通过任务,任务进入下一个节点
taskService.complete(task.getId());

3.4 HistoryService

历史管理类,常用来查询历史流程实例、历史活动、历史任务表等。

// 查询某个流程定义下的所有历史活动实例
List<HistoricActivityInstance> activityInstanceList = processEngine.getHistoryService()
                .createHistoricActivityInstanceQuery()
                .processDefinitionId("offwork:1:3")
                .list();

3.5 ManagementService

引擎管理类,提供了对 Activiti 流程引擎的管理和维护功能,这些功能不在工作流驱动的应用程序中使用,主要用于Activiti 系统的日常维护。

要想熟练掌握工作流就必须充分理解这25张表和这几个Service类。Activiti就是使用这几个Service类来操作者25张表而已。

以上是关于Activiti7工作流引擎:基础篇 自动生成表结构的主要内容,如果未能解决你的问题,请参考以下文章

Activiti7工作流引擎:基础篇 常用操作

Activiti7工作流引擎:基础篇 Annotation

Activiti7工作流引擎:基础篇 Annotation

Activiti7工作流引擎:基础篇 Hello World

Activiti7工作流引擎:基础篇 网关Gateway

Activiti7工作流引擎:基础篇 流程变量