Spring Boot Activiti 整合工作流引擎开发

程序员文章站 2024-03-23 17:33:46

...

为了深入得学习activiti，从头开始，这次用spring boot作为项目框架，来一步一步搭建一个activiti流程管理程序。作文以记之。

什么是activiti？

Activiti is battle-tested Business Process Management (BPM).
Activiti是一个身经百战的业务流程管理引擎。

不是某卓的活动。

为什么要用工作流引擎？

简单来说，就是为了统一管理流程业务。
想想看，如果要设计一个流程的程序，通常需要在数据库中存各种状态值，比如一个订单程序，要标记订单是未付款、已付款、已出库等等状态，而这些各种各样的状态参杂在程序中，逻辑自然就变得复杂了。
而将这些状态对应流程里的一个个步骤，交由流程引擎去管理，这样不仅简化了业务逻辑代码，而且，还有很强的扩展性。我可以修改我的流程，我可以添加一些步骤而不用改我的数据库表结构，不用改我的业务逻辑。

在spring boot中使用activiti api

spring boot的初始配置请参考：
http://www.jianshu.com/p/3ec727e987a8

依赖：

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

        <dependency>
            <groupId>org.activiti</groupId>
            <artifactId>activiti-spring</artifactId>
            <version>${activiti.version}</version>
        </dependency>

activiti相关配置：

/**
 * Created by liuruijie on 2017/2/20.
 * activiti工作流配置
 */
@Configuration
public class Cfg_Activiti extends Cfg_EnvProvider{

    //流程配置，与spring整合采用SpringProcessEngineConfiguration这个实现
    @Bean
    public ProcessEngineConfiguration processEngineConfiguration(DataSource dataSource, PlatformTransactionManager transactionManager){
        SpringProcessEngineConfiguration processEngineConfiguration = new SpringProcessEngineConfiguration();
        processEngineConfiguration.setDataSource(dataSource);
        processEngineConfiguration.setDatabaseSchemaUpdate("true");
        processEngineConfiguration.setDatabaseType("mysql");

        processEngineConfiguration.setTransactionManager(transactionManager);

        return processEngineConfiguration;
    }

    //流程引擎，与spring整合使用factoryBean
    @Bean
    public ProcessEngineFactoryBean processEngine(ProcessEngineConfiguration processEngineConfiguration){
        ProcessEngineFactoryBean processEngineFactoryBean = new ProcessEngineFactoryBean();
        processEngineFactoryBean.setProcessEngineConfiguration((ProcessEngineConfigurationImpl) processEngineConfiguration);
        return processEngineFactoryBean;
    }

    //八大接口
    @Bean
    public RepositoryService repositoryService(ProcessEngine processEngine){
        return processEngine.getRepositoryService();
    }

    @Bean
    public RuntimeService runtimeService(ProcessEngine processEngine){
        return processEngine.getRuntimeService();
    }

    @Bean
    public TaskService taskService(ProcessEngine processEngine){
        return processEngine.getTaskService();
    }

    @Bean
    public HistoryService historyService(ProcessEngine processEngine){
        return processEngine.getHistoryService();
    }

    @Bean
    public FormService formService(ProcessEngine processEngine){
        return processEngine.getFormService();
    }

    @Bean
    public IdentityService identityService(ProcessEngine processEngine){
        return processEngine.getIdentityService();
    }

    @Bean
    public ManagementService managementService(ProcessEngine processEngine){
        return processEngine.getManagementService();
    }

    @Bean
    public DynamicBpmnService dynamicBpmnService(ProcessEngine processEngine){
        return processEngine.getDynamicBpmnService();
    }

    //八大接口 end
}

配置主要由两大部分：
一个是ProcessEngineConfiguration，这个是activiti基础参数的配置，如：数据源什么的。
还有一个是activiti的八个service接口，这是使用activiti的关键，每个接口都有不同的职责。而这些接口需要通过ProcessEngine来获取，activiti为了和spring整合提供了ProcessEngineFactroyBean，可通过它来获取ProcessEngin。

RepositoryService:提供与流程定义相关的方法，可查询模型(model)、流程定义(process definition)、流程部署(deployment)。
RuntimeService:提供流程执行时相关的方法，可查询流程实例(process insatnce)、执行实例(execution)，可开启流程实例。
TaskService:提供任务相关的方法，可进行查询、指派、完成任务等操作。
HistoriyService:提供历史记录相关的方法，可查询历史任务(historic task instance)，历史流程实例(historic process instance)等。
FormService:提供表单相关的方法，一个用户任务可对应一个formkey，可通过formkey查找表单，提供表单的获取等方法。
IdentityService:提供用户权限认证相关的方法，可查询用户、组等信息，可设置当前用户。
ManagementService:与引擎配置相关，可获取引擎数据库信息，并且可以执行自定义的命令(command)。
DynamicBpmnService:提供动态获取，以及动态修改流程定义的方法。

配置好了这些，activiti的基本配置就完成了，现在就可以在程序中通过注入来得到各种service的实例。

一个流程控制中心程序，基本上就是这几个service配合使用来实现的，所以搭好基础环境后，就可以开始编写自己的流程控制中心了。

Activiti 简介

1、类似于OA的一种流式工作任务管理框架。

2、依赖于Activiti BPM引擎和BPMN 2.0

流程设计器的搭建

官网: https://www.activiti.org/

官方流程设计器: https://www.activiti.org/download-links

https://github.com/Activiti/Activiti

开源Lemon OA： http://www.mossle.com/index.do

maven
<dependency>
    <groupId>org.activiti</groupId>
    <artifactId>activiti-spring-boot-starter-basic</artifactId>
    <version>${activiti.version}</version>
</dependency>

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-rest</artifactId>
</dependency>


多数据源配置
package cn.showclear.utio.config;

import cn.showclear.utio.mybatis.DataSources;
import cn.showclear.utio.mybatis.ThreadLocalRountingDataSource;
import org.activiti.spring.SpringAsyncExecutor;
import org.activiti.spring.SpringProcessEngineConfiguration;
import org.activiti.spring.boot.AbstractProcessEngineAutoConfiguration;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.*;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import org.springframework.transaction.PlatformTransactionManager;

import javax.sql.DataSource;
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

/**
 * Created by Yiyuery.
 */
@Configuration
@ComponentScan
@PropertySource(value = {"classpath:/application.properties",
        "file:/C:\\scooper\\utio\\db.properties","file:/icooper/config/utio/db.properties"},
        ignoreResourceNotFound = true)
public class DataSourceConfig extends AbstractProcessEngineAutoConfiguration {

    @Bean
    @ConfigurationProperties(prefix="db.other")
    public DataSource dataSourceaOther() {
        return new DriverManagerDataSource();
    }

    @Primary
    @Bean(name = "dataSource")
    public ThreadLocalRountingDataSource dataSource(){
        ThreadLocalRountingDataSource dataSource = new ThreadLocalRountingDataSource();
        dataSource.setDefaultTargetDataSource(dataSourceUtio());
        Map<Object , Object> dataSourceList = new HashMap();
        dataSourceList.put(DataSources.OTHER,dataSourceaOther());        
        dataSource.setTargetDataSources(dataSourceList);
        return dataSource;
    }

    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.activiti")
    public DataSource dataSourceActiviti() {
        return DataSourceBuilder.create().build();
    }

    @Bean
    public SpringProcessEngineConfiguration springProcessEngineConfiguration(
            PlatformTransactionManager transactionManager,
            SpringAsyncExecutor springAsyncExecutor) throws IOException {

        return baseSpringProcessEngineConfiguration(
                dataSourceActiviti(),
                transactionManager,
                springAsyncExecutor);
    }
}


核心配置文件
/*resources/application.properties*/
spring.jpa.hibernate.ddl-auto=update
spring.jpa.database=MYSQL
spring.datasource.activiti.url=jdbc:mysql://192.168.106.104:3306/DB_SC_ACTIVITI?characterEncoding=UTF-8
spring.datasource.activiti.username=showclear
spring.datasource.activiti.password=showclear
spring.datasource.activiti.driver-class-name=com.mysql.jdbc.Driver

Activiti相关博文

Activiti入门Demo(kft-activiti-demo)

本项目旨在让Activiti初学者可以快速入门，使用工作流里面的请假流程作为Activiti企业实战的Hello World。
简单通过这个实例说明如何结合流程与业务，表单、业务、流程之前如何衔接……
发起这个项目也是目前没有太完整、接近企业真实项目的例子，本项目作为一个补充希望能帮助更多人。
本项目托管在著名的Github，地址：https://github.com/henryyan/kft-activiti-demo 。
参考WIKI：https://github.com/henryyan/kft-activiti-demo/wiki

Activiti中文论坛

为了方便国内Activiti开发者交流，把交流的结果沉淀下来方便新人学习，Activiti中文论坛与2013年5月20日建立。

论坛网址：http://www.activiti-cn.org

上一篇： AJAX请求及JSON数据处理(SpringMVC)

下一篇： python基础函数 eval

Spring Boot Activiti 整合工作流引擎开发

什么是activiti？

为什么要用工作流引擎？

在spring boot中使用activiti api

Activiti相关博文

Activiti入门Demo(kft-activiti-demo)

Activiti中文论坛

Spring Boot Activiti 整合工作流引擎开发

spring boot整合activiti工作流（一）

SpringBoot 系列教程(九十三)：Spring Boot整合Activiti6.0工作流

Spring boot 整合CXF开发web service示例

Spring Boot+Drools规则引擎整合详解

Spring boot 整合CXF开发web service示例

spring boot activiti工作流的搭建与简单使用

Spring Boot整合Elasticsearch实现全文搜索引擎案例解析

RocketMQ最佳实践（三）开发spring-boot-starter-rocketmq实现与spring boot项目的整合

Spring Boot与Kotlin 整合全文搜索引擎Elasticsearch的示例代码