SpringBoot整合Activiti工作流框架的使用

SpringBoot整合Activiti工作流框架的使用

目录Activiti介绍SpringBoot整合使用starter不使用starter使用Activiti

Activiti 介绍

Activiti是一个开源的工作流引擎，它实现了BPMN 2.0规范，可以发布设计好的流程定义，并通过api进行流程调度。Activiti 作为一个遵从 Apache 许可的工作流和业务流程管理开源平台，其核心是基于 java 的超快速、超稳定的 BPMN2.0 流程引擎，强调流程服务的可嵌入性和可扩展性，同时更加强调面向业务人员。简单来说activiti是一个业务流程管理引擎，会沿着设计者设计好的流程，一步一步的执行下去，直到终点。

SpringBoot 整合

配置

activiti会框架会创建一系列的表，所以要配置相关数据库的信息，需要注意的是，在url中，添加了针对数据库的条件，其中最后一条nullCatalogMeansCurrent=true非常重要，至于有什么用就不概述了，但是没有这条语句的话就无法自动创建对应的二十八张表。

server:

port: 8014

spring:

application:

name: workflow

datasource:

name: mysqlDatasource

url: jdbc:mysql://localhost:3306/core?useUnicode=true&nullCatalogMeansCurrent=true

username: root

password: root

driver-class-name: com.mysql.jdbc.Driver

type: com.alibaba.druid.pool.DruidDataSource

# 监控统计拦截的filters，如果启用log4j记得添加依赖

filters: stat,wall

# activiti

activiti:

#每次应用启动不检查Activiti数据表是否存在及版本号是否匹配，提升应用启动速度

database-schema-update: true

#在项目单独作为一个引擎，本身不部署流程的时候，如果resources目录没有“processes”目录，启动项目报错–找不到processes目录。需要在配置文件中添加以下内容：

check-process-definitions: false

process-definition-location-prefix: classpath:/processes/

process-definition-location-suffixes:

-**.bpmn

-**.bpmn20.xml

#保存历史数据级别设置为full最高级别，便于历史数据的追溯

history-level: full

# activiti 安全访问

security:

basic:

enabled: true

user:

name: root

password: root

版本问题

注意 SpringBoot 和 Activiti 的版本问题springboot2.0不能与activiti6.0.0直接集成使用，因为activiti6.0.0出来的时候springboot2.0还没有出来，activiti6.0.0 支持springboot1.2.6以上，2.0.0以下的版本。

使用 starter

依赖

这个版本满足高版本的springboot，直接使用就行

org.activiti

activiti-spring-boot-starter

<version>7.1.0.M3.1

需要注意的是，这里的依赖版本，需要对应数据库中act_ge_property表中schema.version版本信息，所以一般不建议在创建完表之后修改依赖信息

启动项目成功后自动创建表

需要在配置文件中加上 activiti-security的配置

# activiti 安全访问

security:

basic:

enabled: true

user:

name: root

password: root

不使用 starter

依赖

org.activiti

activiti-spring

6.0.0

配置代码

@Configuration

public class ActivitiConfig {

private static final Logger logger = LoggerFactory.getLogger(ActivitiConfig.class);

/**

* 配置分为以下几步骤

* 1. 创建ActivitiConfig

* 2. 使用ActivitiConfig创建ProcessEngineFactoryBean

* 3. 使用ProcessEngineFactoryBean创建ProcessEngine对象

* 4. 使用ProcessEngine对象创建需要的服务对象

*/

private final DataSource dataSource;

private final PlatformTransactionManager platformTransactionManager;

@Autowired

public ActivitiConfig(DataSource dataSource, PlatformTransactionManager transactionManager) {

this.dataSource = dataSource;

platformTransactionManager = transactionManager;

}

/*

* 1. 创建配置文件，也就是提供一些配置信息，这样就可以自定义自己的创建信息了

* 需要一些参数，1. 数据源。2. 事务管理器。

* 这里还加入了自动扫描process包下的bpmn(流程定义文件)的设置，这样就可以省去了部署

* */

@Bean

public SpringProcessEngineConfiguration springProcessEngineConfiguration() {

SpringProcessEngineConfiguration spec = new SpringProcessEngineConfiguration();

spec.setDataSource(dataSource);

spec.setTransactionManager(platformTransactionManager);

spec.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_TRUE);

Resource[] resources = null;

// 启动自动部署流程

try {

resources = new PathMatchingResourcePatternResolver().getResources("classpath*:processes/*.*.xml");

} catch (IOException e) {

logger.error("Error Occur:", e);

}

spec.setDeploymentResources(resources);

return spec;

}

@Bean

public ProcessEngineFactoryBean processEngine() {

ProcessEngineFactoryBean engineFactoryBean = new ProcessEngineFactoryBean();

engineFactoryBean.setProcessEngineConfiguration(springProcessEngineConfiguration());

return engineFactoryBean;

}

@Bean

public RepositoryService repositoryService() throws Exception {

return Objects.requireNonNull(processEngine().getObject()).getRepositoryService();

}

@Bean

public RuntimeService runtimeService() throws Exception {

return Objects.requireNonNull(processEngine().getObject()).getRuntimeService();

}

@Bean

public TaskService taskService() throws Exception {

return Objects.requireNonNull(processEngine().getObject()).getTaskService();

}

@Bean

public HistoryService historyService() throws Exception {

return Objects.requireNonNull(processEngine().getObject()).getHistoryService();

}

}

在resources中创建process文件夹，文件夹的路径和名字需要和ActivitiConfig中的配置保持一致启动springBoot项目即可创建完成

使用 Activiti

Idea 安装 Activiti BPMN visualizer 插件

编写测试 bpmn.xml

xmlns:xsd="http://w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn"

xmlns:bpmndi="http://omg.org/spec/BPMN/20100524/DI"

xmlns:omgdc="http://omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://omg.org/spec/DD/20100524/DI"

typeLanguage="http://w3.org/2001/XMLSchema" expressionLanguage="http://w3.org/1999/XPath"

targetNamespace="http://activiti.org/processdef">

</sequenceFlow>

xmlns:xsd="http://w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn"

xmlns:bpmndi="http://omg.org/spec/BPMN/20100524/DI"

xmlns:omgdc="http://omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://omg.org/spec/DD/20100524/DI"

typeLanguage="http://w3.org/2001/XMLSchema" expressionLanguage="http://w3.org/1999/XPath"

targetNamespace="http://activiti.org/processdef">

</sequenceFlow>

编写测试代码

测试代码

@RequestMapping("/test")

@RestController

public class ActivitiTestController {

private static final Logger logger = LoggerFactory.getLogger(ActivitiTestController.class);

@Autowired

RuntimeService runtimeService;

@Autowired

private TaskService taskService;

@RequestMapping("/test1")

public void test1() {

logger.info("Start.........");

ProcessInstance pi = runtimeService.startProcessInstanceByKey("test");

logger.info("流程启动成功，流程id:{}", pi.getId());

}

@RequestMapping("/test2")

public void test2() {

String userId = "root";

List resultTask = taskService.createTaskQuery().processDefinitionKey("test").taskCandidateOrAssigned(userId).list();

logger.info("任务列表：{}", resultTask);

}

}

…简单配置到此结束

完整配置代码见 ：https://gitee.com/Marlon_Brando/onlineshop_back/tree/develop/os_workflow

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。