zoukankan      html  css  js  c++  java
  • Spring Boot Activiti 整合工作流引擎开发

    为了深入得学习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

    正因为当初对未来做了太多的憧憬,所以对现在的自己尤其失望。生命中曾经有过的所有灿烂,终究都需要用寂寞来偿还。
  • 相关阅读:
    es6作用域
    es6函数的扩展
    input输入框ios上光标与placeholder、value不能对齐居中
    移动端input常用样式
    webpack安装遇到的坑
    错误类型
    滚动超出一定高度后,导航栏吸顶
    表单change()事件
    第二周学习进度
    第一周学习进度
  • 原文地址:https://www.cnblogs.com/candlia/p/11920060.html
Copyright © 2011-2022 走看看