精华内容
下载资源
问答
  • 工作流引擎
    千次阅读
    2021-11-15 15:28:15

    1. 什么是工作流

    1.1 工作流介绍

    工作流(Workflow),就是通过计算机对业务流程自动化执行管理。它主要解决的是“使在多个参与者之间按照某种预定义的规则自动进行传递文档、信息或任务的过程,从而实现某个预期的业务目标,或者促使此目标的实现”。

    1.2 工作流系统

    什么是工作流系统
    具有工作流程功能的软件系统。用于更好的管理业务流程。

    适用行业,各行各业
    比如,消费品行业,制造业,电信服务业,银证险等金融服务业,物流服务业,物业服务业,物业管理,大中型进出口贸易公司,政府事业机构,研究院所及教育服务业等,特别是大的跨国企业和集团公司。

    具体场景,凡是涉及到业务流程的所有场景
    (1) 关键业务流程:订单、报价处理、合同审核、客户电话处理、供应链管理等
    (2) 行政管理类:出差申请、加班申请、请假申请、用车申请、各种办公用品申请、购买申请、日报周报等凡是原来手工流转处理的行政表单。
    (3) 人事管理类:员工培训安排、绩效考评、职位变动处理、员工档案信息管理等。
    (4) 财务相关类:付款请求、应收款处理、日常报销处理、出差报销、预算和计划申请等。
    (5) 客户服务类:客户信息管理、客户投诉、请求处理、售后服务管理等。

    1.3 工作流实现方式

    目前常见的工作流程有两种方式:
    (1)通过状态字段实现流程控制。原始,适合简单流程控制。
    (2)工作流引擎实现流程控制。适用场景更广泛,扩展性更好。

    1.4 工作流实现原理

    Activiti牛批之处在于,它在不改变代码的前提下实现各种业务流程的管理,适用性,扩展性很优秀。

    activiti通过创建流程实例引擎,可以实现不同流程的流转,通过不断读取创建的流程节点实现流程流转。

    2. Activiti7概述

    2.1 Activiti介绍

    Activiti 是一个工作流引擎, activiti 可以将业务系统中复杂的业务流程抽取出来,使用专门的建模语言(BPMN2.0)进行定义,业务系统按照预先定义的流程进行执行,实现了业务系统的业务流程由 activiti 进行管理,减少业务系统由于流程变更进行系统升级改造的工作量,从而提高系统的健壮性,同时也减少了系统开发维护成本。

    当然这里还有一些小故事,Alfresco 软件在 2010 年 5 月 17 日宣布 Activiti 业务流程管理(BPM)开源项目的正式启动, 其首席架构师由业务流程管理 BPM 的专家 Tom Baeyens 担任, Tom Baeyens 就是原来 jbpm 的架构师,而 jbpm 是一个非常有名的工作流引擎,当然 activiti 也是一个工作流引擎。
    官方网站: https://www.activiti.org/

    下边介绍三个名词概念,就不长篇大论了,简单总结下。
    1.1 BPM:BPM(Business Process Management),即业务流程管理。
    1.1 BPM系统:那就是业务流程管理的系统。
    1.1 BPMN,这个比较噢重要,多说两句,具体往下看。
    BPMN(Business Process Model And Notation) - 业务流程模型和符号 是由 BPMI(BusinessProcess Management Initiative)开发的一套标准的业务流程建模符号,使用 BPMN 提供的符号可以创建业务流程。

    总结来说就是用来建模业务流程的标准规则,一个个符号!
    在这里插入图片描述

    2.2 Activiti使用

    一般情况下都是通过创建BPMN进行业务流程建模,两种方式,idea插件或者eclipse插件,通过符号创建流程。
    idea安装bpmn插件
    在 IDEA 的 File 菜单中找到子菜单”Settings”,后面我们再选择左侧的“plugins”菜单,如下图所示
    在这里插入图片描述在这里插入图片描述

    3. Activiti环境配置

    3.1 创建数据库

    CREATE DATABASE activiti DEFAULT CHARACTER SET utf8;
    

    3.2 初始化数据库表:

    1. 创建Maven工程
      在这里插入图片描述
    2. 加入依赖
    <?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.activiti.demo</groupId>
        <artifactId>activiti_demo</artifactId>
        <version>1.0-SNAPSHOT</version>
    
        <!-- 定义统一版本 -->
        <properties>
            <slf4j.version>1.6.6</slf4j.version>
            <log4j.version>1.2.12</log4j.version>
        </properties>
    
        <dependencies>
            <!-- 引入依赖activiti -->
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-engine</artifactId>
                <version>7.0.0.Beta1</version>
            </dependency>
    
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-spring</artifactId>
                <version>7.0.0.Beta1</version>
            </dependency>
    
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-bpmn-model</artifactId>
                <version>7.0.0.Beta1</version>
            </dependency>
    
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-bpmn-converter</artifactId>
                <version>7.0.0.Beta1</version>
            </dependency>
    
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-json-converter</artifactId>
                <version>7.0.0.Beta1</version>
            </dependency>
    
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-bpmn-layout</artifactId>
                <version>7.0.0.Beta1</version>
            </dependency>
    
            <dependency>
                <groupId>org.activiti.cloud</groupId>
                <artifactId>activiti-cloud-services-api</artifactId>
                <version>7.0.0.Beta1</version>
            </dependency>
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.40</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>
            <!-- log end -->
    
            <dependency>
                <groupId>org.mybatis</groupId>
                <artifactId>mybatis</artifactId>
                <version>3.4.5</version>
            </dependency>
    
            <dependency>
                <groupId>commons-dbcp</groupId>
                <artifactId>commons-dbcp</artifactId>
                <version>1.4</version>
            </dependency>
    
        </dependencies>
    
        <repositories>
            <repository>
                <id>alfresco</id>
                <name>Activiti Releases</name>
                <url>https://artifacts.alfresco.com/nexus/content/repositories/activiti-releases/</url>
                <releases>
                    <enabled>true</enabled>
                </releases>
            </repository>
        </repositories>
    
    </project>
    
    1. 配置日志
    # Set root category priority to INFO and its only appender to CONSOLE.
    #log4j.rootCategory=INFO, CONSOLE            debug   info   warn error fatal
    log4j.rootCategory=debug, CONSOLE, LOGFILE
    
    # Set the enterprise logger category to FATAL and its only appender to CONSOLE.
    log4j.logger.org.apache.axis.enterprise=FATAL, CONSOLE
    
    # CONSOLE is set to be a ConsoleAppender using a PatternLayout.
    log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
    log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
    log4j.appender.CONSOLE.layout.ConversionPattern=%d{ISO8601} %-6r [%15.15t] %-5p %30.30c %x - %m\n
    
    # LOGFILE is set to be a File appender using a PatternLayout.
    log4j.appender.LOGFILE=org.apache.log4j.FileAppender
    log4j.appender.LOGFILE.File=d:/axis.log
    log4j.appender.LOGFILE.Append=true
    log4j.appender.LOGFILE.layout=org.apache.log4j.PatternLayout
    log4j.appender.LOGFILE.layout.ConversionPattern=%d{ISO8601} %-6r [%15.15t] %-5p %30.30c %x - %m\n
    
    
    
    1. 配置activity.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">
    
        <!--数据源配置dbcp-->
        <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
            <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="123456"/>
        </bean>
        <!--activiti单独运行的ProcessEngine配置对象(processEngineConfiguration),使用单独启动方式
            默认情况下:bean的id=processEngineConfiguration
        -->
    
        <bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
            <!--代表数据源-->
            <property name="dataSource" ref="dataSource"></property>
    
            <!--
             关于 processEngineConfiguration 中的 databaseSchemaUpdate 参数, 通过此参数设计 activiti
                数据表的处理策略,参数如下:
                false(默认):检查数据库表的版本和依赖库的版本, 如果版本不匹配就抛出异常。
                true: 构建流程引擎时,执行检查,如果需要就执行更新。 如果表不存在,就创建。
                create-drop: 构建流程引擎时创建数据库表, 关闭流程引擎时删除这些表。
                drop-create:先删除表再创建表。
                create: 构建流程引擎时创建数据库表, 关闭流程引擎时不删除这些表。
             -->
    
            <!--代表是否生成表结构-->
            <property name="databaseSchemaUpdate" value="true"/>
    
        </bean>
    </beans>
    
    1. 编写代码
    
    /**
     * Activiti初始化25张表
     * 执行的是activiti-engine-7.0.0.Beta1.jar包下对应不同内置好的sql语句
     * org\activiti\db\drop\activiti.db2.drop.engine.sql
     *
     * @author zrj
     * @date 2020/12/29
     * @since V1.0
     **/
    public class ActivitiInit {
    
        /**
         * 方式一
         */
        @Test
        public void GenActivitiTables() {
    
            // 1.创建ProcessEngineConfiguration对象。第一个参数:配置文件名称;第二个参数:processEngineConfiguration的bean的id
            ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource( "activiti.cfg.xml", "processEngineConfiguration" );
            // 2.创建ProcessEngine对象
            ProcessEngine processEngine = processEngineConfiguration.buildProcessEngine();
            // 3.输出processEngine对象
            System.out.println( processEngine );
    
        }
    
        /**
         * 方式二
         */
        @Test
        public void GenActivitiTables2() {
            //条件:1.activiti配置文件名称:activiti.cfg.xml   2.bean的id="processEngineConfiguration"
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            System.out.println( processEngine );
        }
    }
    

    3.3 创建数据库表

    执行上边的代码。

    3.4 数据库表命名规则

    在这里插入图片描述

    Activiti 的表都以 ACT_开头。 第二部分是表示表的用途的两个字母标识。 用途也和服务的 API 对应。
    
    ACT_RE_*: 'RE'表示 repository。这个前缀的表包含了流程定义和流程静态资源 (图片,规则,等等)。
    ACT_RU_*: 'RU'表示 runtime。 这些运行时的表,包含流程实例,任务,变量,异步任务,等运行中的数据。 Activiti 只在流程实例执行过程中保存这些数据, 在流程结束时就会删除这些记录。 这样运行时表可以一直很小速度很快。
    ACT_HI_*: 'HI'表示 history。 这些表包含历史数据,比如历史流程实例, 变量,任务等等。
    ACT_GE_*: 'GE'表示 general。 通用数据, 用于不同场景下
    

    4. Activiti架构简介

    activiti.cfg.xml
    activiti 的引擎配置文件,包括: ProcessEngineConfiguration 的定义、数据源定义、事务管理器等,此文件其实就是一个 spring 配置文件,下面是一个基本的配置只配置了 ProcessEngineConfiguration和数据源。

    ProcessEngineConfiguration
    流程引擎的配置类,通过 ProcessEngineConfiguration 可以创建工作流引擎 ProceccEngine,常用的两种方法。

    ProcessEngine
    工作流引擎,相当于一个门面接口,通过 ProcessEngineConfiguration 创建 processEngine,通过ProcessEngine 创建各个 service 接口。

    Service
    通过 ProcessEngine 创建 Service, Service 是工作流引擎提供用于进行工作流部署、执行、管理的服务接口。

    在这里插入图片描述

    5. Activiti入门案例

    5.1 流程定义

    什么是流程定义
    流程定义是线下按照 bpmn2.0 标准去描述 业务流程,通常使用 activiti-explorer(web 控制台)或 activiti-eclipse-designer 插件对业务流程进行建模,这两种方式都遵循 bpmn2.0 标准。本教程使用activiti-eclipse-designer 插件完成流程建模。使用 designer 设计器绘制流程,会生成两个文件: .bpmn和.png

    创建bpmn文件
    Palette(画板)

    在 eclipse 或 idea 中安装 activiti-designer 插件即可使用,画板中包括以下结点:
    Connection—连接
    Event---事件
    Task---任务
    Gateway---网关
    Container—容器
    Boundary event—边界事件
    Intermediate event- -中间事件
    流程图设计完毕保存生成.bpmn 文件
    

    idea创建bpmn
    在这里插入图片描述在这里插入图片描述
    生成png图片
    第一步:将 holiday.bpmn 文件改为扩展名 xml 的文件名称: holiday.xml
    第二步: 在 holiday.xml 文件上面,点右键并选择 Diagrams 菜单,再选择 Show BPMN2.0 Designe
    在这里插入图片描述
    第三步: 打开后的效果图如下:
    在这里插入图片描述
    打开如下窗口,注意填写文件名及扩展名,选择好保存图片的位置:
    在这里插入图片描述第五步:中文乱码的解决
    1.打开 IDEA 安装路径,找到如下的安装目录
    在这里插入图片描述
    根据自己所安装的版本来决定,我使用的是 64 位的 idea,所以在 idea64.exe.vmoptions 文件的最后
    一行追加一条命令: -Dfile.encoding=UTF-8
    如下所示
    在这里插入图片描述一定注意,不要有空格,否则重启 IDEA 时会打不开,然后 重启 IDEA,把原来的 png 图片删掉,再重新生成,即可解决乱码问题

    5.2 部署流程

    什么是流程部署
    将线下定义的流程部署到 activiti 数据库中,这就是流程定义部署,通过调用 activiti 的 api 将流程定义的 bpmn 和 png 两个文件一个一个添加部署到 activiti 中,也可以将两个文件打成 zip 包进行部署。

    单个文件部署方式
    分别将 bpmn 文件和 png 图片文件部署
    压缩包部署方式

    /**
     * 流程定义的部署
     * activiti表有哪些?
     * act_re_deployment  部署信息
     * act_re_procdef     流程定义的一些信息
     * act_ge_bytearray   流程定义的bpmn文件及png文件
     *
     * @author zrj
     * @date 2020/12/29
     * @since V1.0
     **/
    public class ActivitiDeployment {
    
        /**
         * 方式一
         * 分别将 bpmn 文件和 png 图片文件部署
         */
        @Test
        public void activitiDeploymentTest() {
            //1.创建ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    
            //2.得到RepositoryService实例
            RepositoryService repositoryService = processEngine.getRepositoryService();
    
            //3.进行部署
            Deployment deployment = repositoryService.createDeployment()
                    .addClasspathResource( "diagram/holiday.bpmn" )
                    .addClasspathResource( "diagram/holiday.png" )
                    .name( "请假申请单流程" )
                    .deploy();
    
            //4.输出部署的一些信息
            System.out.println( deployment.getName() );
            System.out.println( deployment.getId() );
        }
    
        /**
         * 方式二
         * 将 holiday.bpmn 和 holiday.png 压缩成 zip 包
         */
        @Test
        public void activitiDeploymentTest2() {
            //1.创建ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    
            //2.得到RepositoryService实例
            RepositoryService repositoryService = processEngine.getRepositoryService();
    
            //3.转化出ZipInputStream流对象
            InputStream is = ActivitiDeployment.class.getClassLoader().getResourceAsStream( "diagram/holidayBPMN.zip" );
    
            //将 inputstream流转化为ZipInputStream流
            ZipInputStream zipInputStream = new ZipInputStream( is );
    
            //3.进行部署
            Deployment deployment = repositoryService.createDeployment()
                    .addZipInputStream( zipInputStream )
                    .name( "请假申请单流程" )
                    .deploy();
    
            //4.输出部署的一些信息
            System.out.println( deployment.getName() );
            System.out.println( deployment.getId() );
        }
    
    }
    

    操作数据表

     -- activiti表有哪些?
     -- 部署信息
    select * from act_re_deployment ;
     
    -- 流程定义的一些信息
    select * from act_re_procdef;
     
     -- 流程定义的bpmn文件及png文件
    select * from act_ge_bytearray;
    

    5.3 启动流程

    
    /**
     * 启动流程实例:
     * 前提是先已经完成流程定义的部署工作
     * 背后影响的表:
     * act_hi_actinst     已完成的活动信息
     * act_hi_identitylink   参与者信息
     * act_hi_procinst   流程实例
     * act_hi_taskinst   任务实例
     * act_ru_execution   执行表
     * act_ru_identitylink   参与者信息
     * act_ru_task  任务
     *
     * @author zrj
     * @date 2020/12/29
     * @since V1.0
     **/
    public class ActivitiStartInstance {
        public static void main(String[] args) {
            //1.得到ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    
            //2.得到RunService对象
            RuntimeService runtimeService = processEngine.getRuntimeService();
    
            //3.创建流程实例  流程定义的key需要知道 holiday
            ProcessInstance processInstance = runtimeService.startProcessInstanceByKey( "holiday" );
    
            //4.输出实例的相关信息
            System.out.println( "流程部署ID" + processInstance.getDeploymentId() );
            System.out.println( "流程定义ID" + processInstance.getProcessDefinitionId() );
            System.out.println( "流程实例ID" + processInstance.getId() );
            System.out.println( "活动ID" + processInstance.getActivityId() );
    
        }
    }
    

    5.4 流程定义查询

    
    /**
     * 流程定义查询
     *
     * @author zrj
     * @date 2020/12/29
     * @since V1.0
     **/
    public class QueryProceccDefinition {
    
        @Test
        public void queryProceccDefinition() {
            // 流程定义key
            String processDefinitionKey = "holiday";
            //1.得到ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    
            // 获取repositoryService
            RepositoryService repositoryService = processEngine.getRepositoryService();
            // 查询流程定义
            ProcessDefinitionQuery processDefinitionQuery = repositoryService.createProcessDefinitionQuery();
            //遍历查询结果
            List<ProcessDefinition> list = processDefinitionQuery
                    .processDefinitionKey( processDefinitionKey )
                    .orderByProcessDefinitionVersion().desc().list();
    
            for (ProcessDefinition processDefinition : list) {
                System.out.println( "------------------------" );
                System.out.println( " 流 程 部 署 id : " + processDefinition.getDeploymentId() );
                System.out.println( "流程定义id: " + processDefinition.getId() );
                System.out.println( "流程定义名称: " + processDefinition.getName() );
                System.out.println( "流程定义key: " + processDefinition.getKey() );
                System.out.println( "流程定义版本: " + processDefinition.getVersion() );
            }
        }
    }
    

    5.5 流程定义删除

       /**
         * 删除指定流程id的流程
         */
        public void deleteDeployment() {
            // 流程部署id
            String deploymentId = "8801";
            //1.得到ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
    
            // 通过流程引擎获取repositoryService
            RepositoryService repositoryService = processEngine.getRepositoryService();
            //删除流程定义, 如果该流程定义已有流程实例启动则删除时出错
            repositoryService.deleteDeployment( deploymentId );
            //设置true 级联删除流程定义,即使该流程有流程实例启动也可以删除,设
            //置为false非级别删除方式,如果流程
            repositoryService.deleteDeployment( deploymentId, true );
        }
    

    5.6 流程定义资源查询

       /**
         * 获取资源
         */
        @Test
        public void getProcessResources() throws IOException {
            // 流程定义id
            String processDefinitionId = "";
            //1.得到ProcessEngine对象
            ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
            // 获取repositoryService
            RepositoryService repositoryService = processEngine.getRepositoryService();
            // 流程定义对象
            ProcessDefinition processDefinition = repositoryService
                    .createProcessDefinitionQuery()
                    .processDefinitionId( processDefinitionId ).singleResult();
            //获取bpmn
            String resource_bpmn = processDefinition.getResourceName();
            //获取png
            String resource_png = processDefinition.getDiagramResourceName();
            // 资源信息
            System.out.println( "bpmn: " + resource_bpmn );
            System.out.println( "png: " + resource_png );
            File file_png = new File( "d:/purchasingflow01.png" );
            File file_bpmn = new File( "d:/purchasingflow01.bpmn" );
            // 输出bpmn
            InputStream resourceAsStream = null;
            resourceAsStream = repositoryService.getResourceAsStream( processDefinition.getDeploymentId(), resource_bpmn );
            FileOutputStream fileOutputStream = new FileOutputStream( file_bpmn );
            byte[] b = new byte[1024];
            int len = -1;
            while ((len = resourceAsStream.read( b, 0, 1024 )) != -1) {
                fileOutputStream.write( b, 0, len );
            }
            // 输出图片
            resourceAsStream = repositoryService.getResourceAsStream( processDefinition.getDeploymentId(), resource_png );
            fileOutputStream = new FileOutputStream( file_png );
            // byte[] b = new byte[1024];
            // int len = -1;
            while ((len = resourceAsStream.read( b, 0, 1024 )) != -1) {
                fileOutputStream.write( b, 0, len );
            }
        }
    
    更多相关内容
  • 在第一家公司工作的时候主要任务就是开发OA系统,当然基本都是有工作流的支持,不过当时使用的工作流引擎是公司一些牛人开发的(据说是用一个开源的引擎修改的),名称叫CoreFlow;功能相对Activiti来说比较弱,但是...
  • 文章针对"工作流管理联盟"(简称WFMC)定义的工作流参考模型,设计并实现了一种基于Java的工作流引擎,并给出了该引擎的构建、核心类图以及核心调度算法。
  • 目前工作流引擎技术是越来越流行了,甚至我们的许多终端客户在对应用系统的选型时都会问到是否包含工作流的问题。事实上工作流的概念已经在软件行业里深入人心,甚至连微软等大型软件企业都开始掺和进来。可是在不同...
  • 早期的工作流应用系统都是集中式的,即由一个工作流引擎去完成整个流程实例的执行。随着计算机和网络技术的发展更加迅速和成熟,特别是Internet应用日益普及的情况下,现代企业和政府的信息资源越来越表现出一种异构...
  • 工作流引擎

    2017-12-14 10:03:48
    本文档简单介绍了工作流引擎的概念和一些技术特点,对比了当前主流的流程引擎之间的区别。
  • easyui实现的Activiti工作流引擎web版流程设计器 跨浏览器流程设计器 打开文件 processDesigner\wf\designer\index.html 即可预览
  • flow, 在 go ( golang ) 中,一个小型的开源工作流引擎 状态flow 正逐步向发布,但还无法使用 ! flowflow 是一个小型开源的( Apache 2 -licensed ) 工作流引擎,它在。什么是 flow作为工作流引擎,flow 打算帮助...
  • 课程设计asp.net基于工作流引擎的系统框架设计开发(源代码+论文)源代码下载源代码下载 课程设计asp.net基于工作流引擎的系统框架设计开发(源代码+论文)源代码下载源代码下载 课程设计asp.net基于工作流引擎的系统...
  • Activiti7工作流引擎教学视频 springboot-activiti是一个SpringBoot集成activiti实现在创建、部署流程、复制流程、删除流程以及流程规则配置,实现工单流程工作流流转和业务处理
  • EOS工作流引擎工作原理.pdf
  • 文章目录为什么使用工作流引擎?不使用工作流存在以下问题工作流优缺点什么是工作流引擎尝试自己构建工作流引擎有哪些选型方案呢基于bpmn标准进行流程定义国产自定义如何使用SnakerFlow工作流以请假流程来看下数据库...

    为什么使用工作流引擎?

    反证法,如果不使用工作流引擎,请假流程举例,从头开始开发流程的业务逻辑:(来看看会出现哪些问题?使用工作流能解决哪些问题?又会带来什么问题?

    • 一、业务流程梳理

      • 员工发起请假单
      • 组长审批
      • 请假天数小于等于2天
        • 结束
      • 请假天数大于2天
        • 总经理审批
        • 结束

      流程定义可能是hardcoding或者存储在某张表

    • 二、每个节点都要记录当前操作人和判断下个节点

      • 员工发起请假单 (记录谁发起的以及判断下个节点)

        • 员工填写请假单并提交
          • 存入leave表,创建人,创建时间
          • 存入transfer状态流转表, userId nextUserId等 驱动到下一个节点
            • nextUserId根据上面的流程定义获取
      • 组长审批 (记录谁发起的以及判断下个节点)

        • 同意或者拒绝
          • 存入transfer状态流转表, userId nextUserId等 驱动到下一个节点
            • nextUserId根据上面的流程定义获取
      • 请假天数小于等于2天 (记录谁发起的以及判断下个节点)

        • if(day<=2)
          • 结束
      • 请假天数大于2天 (记录谁发起的以及判断下个节点)

        • if(day>2)
          • 总经理审批 (记录谁发起的以及判断下个节点)
          • 结束

    如果再来个用车流程报销流程等,那么你的项目将无法维护

    不使用工作流存在以下问题

    • 流程设计没有可视化

    • 流程没有版本管理,热部署等

    • 每个活动的流转都需要硬性判断下一步活动节点及其操作人

    • 每次操作都需要维护业务数据和流程的相关数据

    • 缺乏数据管理、流程监控等功能

    工作流优缺点

    对上面共性问题进行抽象,抽象,抽象,可以得出下面的视图。

    业务流程进行了抽象分离降低耦合

    优点

    • 具有可视化的流程设计工具
    • 业务数据和流程数据的分离,可以进行更专注的性能优化,业务划分
    • 内置API能很好的完成常见的功能场景
    • 具有完善的流程监控体系
    • 具备大量的自定义扩展接口

    缺点

    • 需要额外的学习成本

    什么是工作流引擎

    所谓工作流引擎是指workflow作为应用系统的一部分,并为之提供对各应用系统有决定作用的根据角色、分工和条件的不同决定信息传递路由、内容等级等核心解决方案。工作流引擎包括流程的节点管理、流向管理、流程样例管理等重要功能。(来自百科)

    尝试自己构建工作流引擎

    以下内容取自:https://www.cnblogs.com/duck-and-duck/p/14436373.html

    并进行了部分修改。

    第1天

    我查了一天啥是工作流,然后做出了如下版本:

    img

    • 按顺序添加任意个审批人组成一个链表,最后加一个结束节点
    • 记录当前审批人,当审批完后,审批人向后移动一位
    • 当审批人对应结束节点时,流程结束

    每个节点执行人是hardcoding的

    第二天

    发现部分业务需要支持会签节点

    我又查了一天啥是会签节点,发现会签节点就是一个大节点,里面有很多审批人,当这个大节点里的所有人都审批通过后,才能进入下一个节点。

    翻了原来的链表式设计:

    img

    第三天

    发现部分业务需要支持条件节点

    要根据表单的内容确定下一步进入哪个分支。

    第四天

    审批人多加两种类型,比如可以从表单中选择下一个审批人,还有根据发起人不同选择不同的审批人。

    第五天

    需要满足xxx需求,卒。。。

    看来实现一个工作流引擎还是蛮难的,那有什么可选的轮子吗

    有哪些选型方案呢

    工作流整体流程如下:

    建模(事前)运行 (事中)管理 (事后)监控(全生命周期)
    流程设计engine驱动数据管理流程监控

    基于bpmn标准进行流程定义

    什么是BPMN

    BPMN 是 Business Process Modeling Notation 的简称,即业务流程建模与标注。BPMN 定义了一个业务流程图,这个流程图被设计用于创建业务流程操作的图形化模型 。 而一个业务流程模型( Business Process Model ),指一个由图形对象( graphical objects )组成的网状图,图形对象包括活动(activities) 和用于定义这些活动执行顺序的流程控制器( flow controls )。

    代表实现产品如下:

    • JBPM

    • Activiti

    • Flowable

    国产自定义

    • snaker
    • jflow

    如何使用SnakerFlow工作流

    仅列出常见功能场景实现,具体介绍和详情文档参见:Spring Boot 集成SnakerFlow流程引擎,简介、功能列表、详细解读、扩展点分析

    ☎️ ☎️ ☎️ 已开源基于SnakerFlow轻量级工作流引擎的脚手架项目 easy-admin

    详情参见:终于写了个开源项目,easy-admin 为打造一款简单、轻量级的后台管理系统脚手架

    以请假流程来看下数据库中数据流转情况

    相关源码已开源

    ☎️ ☎️ ☎️ 已开源基于SnakerFlow轻量级工作流引擎的脚手架项目 easy-admin

    详情参见:终于写了个开源项目,easy-admin 为打造一款简单、轻量级的后台管理系统脚手架

    初始状态

    wf_process

    员工发起请假申请

    args.put("user1", StpUtil.getLoginIdAsString());
    args.put("user2", "yang");
    args.put("user3", "zhang");
    Object day = args.get("day");
    if (day != null) {
        args.put("day", Integer.valueOf((String) day));
    }b
    snakerEngineFacets.startAndExecute(name, version, StpUtil.getLoginIdAsString(), args);
    

    员工laker发起一个请假单,请假3

    laker的待办列表为空,已办列表如下:

    yang的待办列表如下:

    当前监控流程图

    wf_order

    wf_task

    wf_task_actor

    wf_hist_order

    wf_hist_task

    wf_hist_task_actor

    常见功能

    流程标题

    我们经常希望待办任务列表有一列是流程实例的名称,即标题,例如,我们希望流程的标题是:张三 - 2019-12-04 16:40:20的请假申请 ,通常会采用一个命名规则:发起人+发起时间+流程模型名称把它作为流程的标题。这时候就希望启动流程实例时可以设置流程实例的名称。

    args.put(SnakerEngine.ID, "张三 - 2019-12-04 16:40:20的请假申请");
    snakerEngineFacets.startAndExecute(name, version, StpUtil.getLoginIdAsString(), args);
    

    发起申请

    args.put(SnakerEngine.ID, "张三 - 2019-12-04 16:40:20的请假申请");
    snakerEngineFacets.startAndExecute(name, version, StpUtil.getLoginIdAsString(), args);
    

    我的发起

    QueryFilter filter = new QueryFilter();
    filter.setOperator(operator);
    filter.orderBy("create_Time").order(DESC);
    snakerEngineFacets.getEngine().query().getHistoryOrders(page, filter);
    

    我的待办

    Page<WorkItem> page = new Page<>(30);
    snakerEngineFacets.getEngine().query().getWorkItems(page,
            new QueryFilter().setOperator(operator));
    

    我的已办

    Page<WorkItem> page = new Page<>(30);
    snakerEngineFacets.getEngine().query().getHistoryWorkItems(page,
            new QueryFilter().setOperator(operator));
    

    催办

    List<Task> tasks = snakerEngineFacets.getEngine().query().getActiveTasks(new QueryFilter().setOrderId(orderId));
    根据这个task跟指定人发消息
    

    转办

    转办任务(换当前办理人,或者叫变更当前办理人)

    snakerEngineFacets.transferMajor(taskId, operator, nextOperators);
    

    驳回

    驳回/退回上一步/退回至(即退回到历史某一个节点)

    snakerEngineFacets.executeAndJump(taskId, operator, args, nodeName);
    

    撤回

    根据历史任务id,撤回由该历史任务派发的所有活动任务,如果无活动任务,则不允许撤回

    snakerEngineFacets.getEngine().task().withdrawTask(taskId, operator);
    

    抄送

    实例的抄送类似于邮箱里面的抄送功能,一般用于将该流程实例抄送给领导查阅。

    新增表wf_cc_order根据实例id、创建人、抄送人创建抄送记录engine.order().createCCOrder(String orderId, String creator, String... actorIds)更新状态用于更新抄送记录为已经阅读engine.order().updateCCStatus(String orderId, String... actorIds)    
    

    加签

    加签(增加另一人或多人的审批)

    engine.task().addTaskActor(String taskId, 1, String... actorIds)
    

    会签

    会签(通常用于审批后给相关的人签字确认,以获得工作上的协调。)

    snaker的会签目前相对比较简单,仅仅是根据任务节点的performType属性值确定是否产生多个相同任务。

    performType的值有两种,分别是ANYALL

    ANY多个参与者时,任何一个完成任务即继续流转 (或签

    ALL多个参与者时,所有都需要完成任务才能继续流转

    会签只需要在流程定义时,将任务节点的属性performType值设置为ALL即可,当调用api时传递多个参与者时,则自动派发与参与者数量相同的任务。会签任务必须等待所有参与者完成后,才继续流转

    或签

    同上

    ☎️ ☎️ ☎️ 已开源基于SnakerFlow轻量级工作流引擎的脚手架项目 easy-admin

    详情参见:终于写了个开源项目,easy-admin 为打造一款简单、轻量级的后台管理系统脚手架

    展开全文
  • Java自己开发的一个工作流引擎例子

    热门讨论 2015-05-09 00:15:20
    最近项目中需要使用到工作流,然后上网搜到一个大神用Javascript写的一个工作流,感觉写的很屌。...我觉得代码很有学习参考价值,所以上传到这里,希望对大家有些帮助,里面附上html文件是Javascript写的工作流引擎
  • 在java下有很多优秀的开源工作流可以选择比如activit5、jpbm4等,在.net下却几乎找不到令人满意的工作流引擎可用。当然不是说.net下没有开源的只是有些国产开源的但看了代码后就一点兴趣都没有了,且不说代码质量...
  • 02工作流引擎数据库设计.pdf
  • 工作流引擎源代码

    2014-08-16 16:30:40
    无堵塞工作流引擎,高效,附带仿制微软的消息泵,用于对象之间解耦
  • 工作流引擎(WorkflowEngine).pdf
  • Java开源工作流引擎.pdf
  • 工作流引擎笔记

    2019-03-23 01:36:42
    NULL 博文链接:https://lipeixiaoyu.iteye.com/blog/1067138
  • 一种基于OSWorkflow工作流引擎的工作流监控技术,仇璐,,目前工作流监控技术存在的问题是:流程监控得到的流程图与实际业务流程有一定差距,针对存在的这个问题,本文提出了一种基于OSWork
  • JAVA工作流引擎的开发和设计.pdf
  • 工作流引擎功能概要(OA系统).pdf
  • asp.net基于工作流引擎的系统框架设计开发(源代码+论文).zip
  • 基于前后端分离项目引入activiti工作流引擎,某些配置信息需根据自己项目情况修改
  • ProcessMaker是一个运行于客户/服务端的商业进程(BPM)和工作流管理软件。它适用于中小型企业。 功能和特点 ◆ 关图形化界面可以进行拖拽操作 ◆ 基于XML的编辑器可以自定义流程的Web窗体 ◆ 通过导入/导出可以很...
  • 工作流引擎+流程产品介绍(开发、实施) 说明书。介绍工作流以及问题解决
  • 驰骋工作流引擎流程是国内开源流程引擎。深受企事业单位信赖。

空空如也

空空如也

1 2 3 4 5 ... 20
收藏数 255,797
精华内容 102,318
关键字:

工作流引擎