Activiti6.0教程(2) - 初始化表, 部署流程, 启动流程, 创建的表介绍

上一篇博客介绍了怎么定义一个流程图, 这一篇来介绍一下项目中用的话, 怎么部署流程, 启动流程, 以及表的介绍

创建项目

创建一个maven项目即可, 目前只先做测试, 引入以下依赖

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

<dependency>
  <groupId>mysql</groupId>
  <artifactId>mysql-connector-java</artifactId>
  <version>5.1.47</version>
</dependency>

<!-- 这个是数据源的依赖, 如果你不用数据源, 可以不用引入这个的 -->
<dependency>
  <groupId>com.mchange</groupId>
  <artifactId>c3p0</artifactId>
  <version>0.9.5.4</version>
</dependency>

<dependency>
  <groupId>junit</groupId>
  <artifactId>junit</artifactId>
  <version>4.12</version>
</dependency>

初始化

@Test
public void createTable() {
  // 创建一个数据源
  DriverManagerDataSource dataSource = new DriverManagerDataSource();
  dataSource.setDriverClass("com.mysql.jdbc.Driver");
  dataSource.setJdbcUrl("jdbc:mysql:///activiti-demo?useSSL=false&characterEncoding=utf8&serverTimezone=GMT%2B8");
  dataSource.setUser("root");
  dataSource.setPassword("");

  // 创建流程引擎配置
  ProcessEngineConfiguration configuration = ProcessEngineConfiguration
      .createStandaloneInMemProcessEngineConfiguration();
  // 设置数据源
  //    configuration.setDataSource(dataSource);
  // 如果不使用数据源, 可以通过配置连接信息来连接数据库
  configuration.setJdbcDriver("com.mysql.jdbc.Driver");
  configuration.setJdbcUrl("jdbc:mysql:///activiti-demo?useSSL=false&characterEncoding=utf8&serverTimezone=GMT%2B8");
  configuration.setJdbcUsername("root");
  configuration.setJdbcPassword("");

  // 设置创建表的一个规则,有三种
  // DB_SCHEMA_UPDATE_FALSE = "false" 如果数据库里没有acti相关的表, 也不会创建
  // DB_SCHEMA_UPDATE_CREATE_DROP = "create-drop" 不管数据库里有没acti的相关表, 都会先删除旧表再创建新表, 不推荐在生产中使用
  // DB_SCHEMA_UPDATE_TRUE = "true" 如果数据库里没有acti相关的表, 会自动创建
  // 仔细看看, 是不是有些类似于hibernate里的ddl-auto :)
  configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_CREATE_DROP);

  // 构建流程引擎, 这一步就会创建好表, 但基本上表内都是空的, 因为还没有部署, 再没有流程实例
  ProcessEngine processEngine = configuration.buildProcessEngine();
  // 可以获取流程引擎的一些信息, 不过这个东西没啥用..
  System.out.println(processEngine.getName());
}

原链接文： https://tomoya92.github.io/2019/04/24/activiti-deploy-start-table/

注释写的很清楚了, 在配置流程引擎的时候可以指定数据源, 这就要借助一些第三方的包了, 不过也可以在 ProcessEngineConfiguration 里自己配置连接信息, 就不用要数据源了, 效果是一样的

表介绍

数据库里生成的表有如下这些

关于上面异步的设计描述可以查看官方文档 https://www.activiti.org/userguide/#async_executor_design

从上面表名的前缀应该可以看出来

• ACT_GE 通用类
• ACT_HI 历史记录类
• ACT_ID 用户信息类
• ACT_RE 流程实例类
• ACT_RU 运行时类

Activiti API

在启动流程之间先介绍一下activiti中的几大Service, 这些对象都是从流程引擎里获取的

// 获取流程引擎
private ProcessEngine getProcessEngine() {
  // 创建流程引擎配置
  ProcessEngineConfiguration configuration = ProcessEngineConfiguration
      .createStandaloneInMemProcessEngineConfiguration();
  // 设置数据源
  //    configuration.setDataSource(dataSource);
  // 如果不使用数据源, 可以通过配置连接信息来连接数据库
  configuration.setJdbcDriver("com.mysql.jdbc.Driver");
  configuration.setJdbcUrl("jdbc:mysql:///activiti-demo?useSSL=false&characterEncoding=utf8&serverTimezone=GMT%2B8");
  configuration.setJdbcUsername("root");
  configuration.setJdbcPassword("");

  // 设置创建表的一个规则,有三种
  // DB_SCHEMA_UPDATE_FALSE = "false" 如果数据库里没有acti相关的表, 也不会创建
  // DB_SCHEMA_UPDATE_CREATE_DROP = "create-drop" 不管数据库里有没acti的相关表, 都会先删除旧表再创建新表, 不推荐在生产中使用
  // DB_SCHEMA_UPDATE_TRUE = "true" 如果数据库里没有acti相关的表, 会自动创建
  // 我这是做测试, 就选择每次先删除旧的表再创建新的表的规则了
  // 仔细看看, 是不是有些类似于hibernate里的ddl-auto :)
  configuration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);

  // 构建流程引擎, 这一步就会创建好表, 但基本上表内都是空的, 因为还没有部署, 再没有流程实例
  ProcessEngine processEngine = configuration.buildProcessEngine();
  return processEngine;
}

@Test
public void activitiApi() {
  ProcessEngine processEngine = getProcessEngine();
  RepositoryService repositoryService = processEngine.getRepositoryService();
  FormService formService = processEngine.getFormService();
  HistoryService historyService = processEngine.getHistoryService();
  IdentityService identityService = processEngine.getIdentityService();
  ManagementService managementService = processEngine.getManagementService();
  RuntimeService runtimeService = processEngine.getRuntimeService();
  TaskService taskService = processEngine.getTaskService();
}

原接文链： https://tomoya92.github.io/2019/04/24/activiti-deploy-start-table/

部署流程

这篇博客的流程图用一个简单的, 如下图

每个 UserTask 的受理人都写的死的, 项目中肯定不建议这样用, 后面还会介绍灵活配置受理人的方法

@Test
public void deployProcess() {
  ProcessEngine processEngine = getProcessEngine();
  RepositoryService repositoryService = processEngine.getRepositoryService();
  Deployment deploy = repositoryService.createDeployment()
      // 给流程起一个名字
      .name("请假流程")
      // 添加流程图资源文件
      .addClasspathResource("AskLeave.bpmn")
      // 添加流程图片资源文件
      .addClasspathResource("AskLeave.png")
      // 部署
      .deploy();
  System.out.println("ID: " + deploy.getId());
}

可以看到部署流程的时候用的是 repositoryService , 这货是处理一些通用的功能

启动流程

流程部署好之后,就可以来启动流程了

说明

启动流程时, 此时自身系统的业务就跟流程的业务有交集了, 我在学的时候就有些疑惑, 自己项目里的业务怎么跟流程中的那一堆东西关联起来的呢? 答案就在启动流程这块, 先看启动流程的代码

@Test
public void startProcess() {
  ProcessEngine processEngine = getProcessEngine();
  RuntimeService runtimeService = processEngine.getRuntimeService();
  // 在画流程图的时候,给流程图起的名字
  String processDefinitionKey = "AskLeave";
  // 业务逻辑中的id
  String businessKey = "1";
  ProcessInstance instance = runtimeService.startProcessInstanceByKey(processDefinitionKey, businessKey);
  System.out.println("ID: " + instance.getId());
}

可以看到 startProcessInstanceByKey() 这个方法传了两个参数

Q: 为啥要用 ProcessInstanceByKey 而不用 ID呢?

A: 流程的Key就是流程图的名字,这个可以提前知道, 而且一个流程图定义好之后这个key就不会变了,但id不一样, 流程部署一次就变一次, 如果用id的话, 还要事先查询好

Q: 这里的 businessKey 是什么东西

A: 这个就是把自己项目里的业务跟Activiti的业务关联起来的东西, 举个例子, 请假的表是自己项目里创建的一个表存储的, 当发起流程的时候, 把这个请假的表里的id传给activiti的流程, 这样在流程处理的过程中可以随时去获取这个 businessKey 然后查询出请假的信息

到这里一个流程的创建->部署->启动就算完成了, 至于怎么查询流程中的信息, 受理人完成流程中的任务, 另起一篇博客来介绍, 下一篇博客来说一下在springboot项目中怎么集成 activiti

总结

activiti的使用顺序如下

定义流程图 -> 初始化流程图(创建表) -> 部署流程 -> 启动流程 -> 处理任务 -> 结束任务

明白了这个过程基本上就不会乱了

参考

• https://blog.csdn.net/hj7jay/article/details/51302829
• https://www.activiti.org/userguide/

写博客不易，转载请保留原文链接，谢谢!

原文链接: