Activiti工作流简单入门

Wesley13
• 阅读 643

BPMN 2.0

BPMN最初由业务流程倡议组织(BPMI)定案,现在BPMI并入到OMG(Object Management Group)了,则由OMG建立规范和维护。

BPMN 2.0正式更名为(Business Process Model And Notation)业务流程符号和模型,也有人继续称呼为业务流程建模标记法(Business Process Modeling Notaion),不过无所谓,不管是jBPM、Activiti还是国人开发的FixFlow,都遵循BPMN规范。

Maven配置

JBoss的开源框架都是比较庞大的,不过相对Activiti体积要小一点。下面为配置的依赖项。

<!--Junit-->
<dependency>
    <groupId>junit</groupId>
    <artifactId>junit</artifactId>
    <version>${junit.version}</version>
</dependency>

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

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

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

<!--apache组件-->
...

整合数据库

为什么要整合数据库?如果不整合数据库,我们大可以使用Quartz这些框架来做流程任务。实际上,Work Flow是用于一种长周期的几乎****异步的项目运行环境中,并且我们时刻需要将工作流程的状态记录下来,就是一种既注重结果,又注重过程的事务中,因此,整合数据库很有必要。

下面为配置源数据的XML文件,并且将databaseSchemaUpdate属性配置为drop-create,即在运行前删除原有的数据内容。

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd">

    <bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
        <property name="databaseSchemaUpdate" value="drop-create"/>
        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/db_activiti?useUnicode=true&amp;characterEncoding=utf-8"/>
        <property name="jdbcDriver" value="com.mysql.jdbc.Driver"/>
        <property name="jdbcUsername" value="root"/>
        <property name="jdbcPassword" value="****"/>
        <property name="jobExecutorActivate" value="true"/>
    </bean>
</beans>

默认配置文件名为activiti.cfg.xml,可以在源文件中找到。

另外,如果有必要,请将MySQL设置为区分大小写,即lower_case_table_names = 0。

数据内容会在运行前自动创建,详细表结构内容可参考官网完整信息。

创建工作流文件

由于BPMN规范的作用,一些高级的IDE会自动识别后缀为*.bpmn的文件,不过这些都无所谓,bpmn文件实际上就是XML文件,只是加上了一些图形的标记,如width、height、x和y的坐标,下面为一个招聘面试流程,只包含流程节点,不包含位置标记节点。

<?xml version="1.0" encoding="UTF-8"?>
<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
             xmlns:activiti="http://activiti.org/bpmn"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             targetNamespace="Examples"
             xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL
             http://www.omg.org/spec/BPMN/2.0/20100501/BPMN20.xsd">
    <process id="Interview" name="某公司2012年实习生招聘流程">
        <documentation>招聘工作流程</documentation>
        <startEvent id="start" name="实习生招聘启动"/>
        <userTask id="bishi" name="笔试" activiti:candidateGroups="人力资源部"/>
        <sequenceFlow id="flow1" name="" sourceRef="start" targetRef="bishi"/>
        <userTask id="yimian" name="技术一面" activiti:candidateGroups="技术部"/>
        <sequenceFlow id="flow2" name="" sourceRef="bishi" targetRef="yimian"/>
        <userTask id="ermian" name="技术二面" activiti:candidateGroups="技术部"/>
        <sequenceFlow id="flow3" name="" sourceRef="yimian" targetRef="ermian"/>
        <userTask id="hrmian" name="HR面" activiti:candidateGroups="人力资源部"/>
        <sequenceFlow id="flow4" name="" sourceRef="ermian" targetRef="hrmian"/>
        <userTask id="luyong" name="录用,发放Offer" activiti:candidateGroups="人力资源部"/>
        <sequenceFlow id="flow5" name="" sourceRef="hrmian" targetRef="luyong"/>
        <endEvent id="end" name="实习生招聘结束"/>
        <sequenceFlow id="flow6" name="" sourceRef="luyong" targetRef="end"/>
    </process>

</definitions>

为了便于阅读,一些高级IDE可以转化为图形符号,如下图:

Activiti工作流简单入门

测试运行

有了流程引擎的配置文件和流程文件后,就可以编写代码启动流程引擎并加载该流程文件了。测试清单如下:

@Test
public void processTests(){
    // 加载配置文件
    ProcessEngine processEngine = ProcessEngineConfiguration.createProcessEngineConfigurationFromResource("activiti.cfg.xml").buildProcessEngine();
    RepositoryService repositoryService = processEngine.getRepositoryService();
    RuntimeService runtimeService = processEngine.getRuntimeService();
    repositoryService.createDeployment().addClasspathResource("Interview.bpmn").deploy();
    String processId = runtimeService.startProcessInstanceByKey("Interview").getId();

    TaskService taskService = processEngine.getTaskService();
    //得到笔试的流程
    System.out.println("\n***************笔试流程开始***************");

    List<Task> tasks = taskService.createTaskQuery().taskCandidateGroup("人力资源部").list();
    for (Task task : tasks) {
        System.out.println("人力资源部的任务:name:"+task.getName()+",id:"+task.getId());
        taskService.claim(task.getId(), "张三");
    }

    System.out.println("张三的任务数量:"+taskService.createTaskQuery().taskAssignee("张三").count());
    tasks = taskService.createTaskQuery().taskAssignee("张三").list();
    for (Task task : tasks) {
        System.out.println("张三的任务:name:"+task.getName()+",id:"+task.getId());
        taskService.complete(task.getId());
    }

    System.out.println("张三的任务数量:"+taskService.createTaskQuery().taskAssignee("张三").count());
    System.out.println("***************笔试流程结束***************");

    System.out.println("\n***************一面流程开始***************");
    tasks = taskService.createTaskQuery().taskCandidateGroup("技术部").list();
    for (Task task : tasks) {
        System.out.println("技术部的任务:name:"+task.getName()+",id:"+task.getId());
        taskService.claim(task.getId(), "李四");
    }

    System.out.println("李四的任务数量:"+taskService.createTaskQuery().taskAssignee("李四").count());
    for (Task task : tasks) {
        System.out.println("李四的任务:name:"+task.getName()+",id:"+task.getId());
        taskService.complete(task.getId());
    }

    System.out.println("李四的任务数量:"+taskService.createTaskQuery().taskAssignee("李四").count());
    System.out.println("***************一面流程结束***************");

    System.out.println("\n***************二面流程开始***************");
    tasks = taskService.createTaskQuery().taskCandidateGroup("技术部").list();
    for (Task task : tasks) {
        System.out.println("技术部的任务:name:"+task.getName()+",id:"+task.getId());
        taskService.claim(task.getId(), "李四");
    }

    System.out.println("李四的任务数量:"+taskService.createTaskQuery().taskAssignee("李四").count());
    for (Task task : tasks) {
        System.out.println("李四的任务:name:"+task.getName()+",id:"+task.getId());
        taskService.complete(task.getId());
    }

    System.out.println("李四的任务数量:"+taskService.createTaskQuery().taskAssignee("李四").count());
    System.out.println("***************二面流程结束***************");

    System.out.println("***************HR面流程开始***************");
    tasks = taskService.createTaskQuery().taskCandidateGroup("人力资源部").list();
    for (Task task : tasks) {
        System.out.println("技术部的任务:name:"+task.getName()+",id:"+task.getId());
        taskService.claim(task.getId(), "李四");
    }

    System.out.println("李四的任务数量:"+taskService.createTaskQuery().taskAssignee("李四").count());
    for (Task task : tasks) {
        System.out.println("李四的任务:name:"+task.getName()+",id:"+task.getId());
        taskService.complete(task.getId());
    }

    System.out.println("李四的任务数量:"+taskService.createTaskQuery().taskAssignee("李四").count());
    System.out.println("***************HR面流程结束***************");

    System.out.println("\n***************录用流程开始***************");
    tasks = taskService.createTaskQuery().taskCandidateGroup("人力资源部").list();
    for (Task task : tasks) {
        System.out.println("技术部的任务:name:"+task.getName()+",id:"+task.getId());
        taskService.claim(task.getId(), "李四");
    }

    System.out.println("李四的任务数量:"+taskService.createTaskQuery().taskAssignee("李四").count());
    for (Task task : tasks) {
        System.out.println("李四的任务:name:"+task.getName()+",id:"+task.getId());
        taskService.complete(task.getId());
    }

    System.out.println("李四的任务数量:"+taskService.createTaskQuery().taskAssignee("李四").count());
    System.out.println("***************录用流程结束***************");

    HistoryService historyService = processEngine.getHistoryService();
    HistoricProcessInstance historicProcessInstance = historyService
            .createHistoricProcessInstanceQuery()
            .processInstanceId(processId).singleResult();
    System.out.println("\n流程结束时间:"+historicProcessInstance.getEndTime());
}

代码清单中使用 ProcessEngines类加载默认的流程配置文件(activiti.cfg.xml),再获取各个服务组件的实例。 RepositoryService主要用于管理流程的资源, RuntimeService主要用于流程运行时的流程管理,TaskService主要用于管理流程任务。最后, HistoricProcessInstance会将工作的流程历史记录下来。

点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
Jacquelyn38 Jacquelyn38
3年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
Wesley13 Wesley13
3年前
Java获得今日零时零分零秒的时间(Date型)
publicDatezeroTime()throwsParseException{    DatetimenewDate();    SimpleDateFormatsimpnewSimpleDateFormat("yyyyMMdd00:00:00");    SimpleDateFormatsimp2newS
Stella981 Stella981
3年前
KVM调整cpu和内存
一.修改kvm虚拟机的配置1、virsheditcentos7找到“memory”和“vcpu”标签,将<namecentos7</name<uuid2220a6d1a36a4fbb8523e078b3dfe795</uuid
Wesley13 Wesley13
3年前
mysql设置时区
mysql设置时区mysql\_query("SETtime\_zone'8:00'")ordie('时区设置失败,请联系管理员!');中国在东8区所以加8方法二:selectcount(user\_id)asdevice,CONVERT\_TZ(FROM\_UNIXTIME(reg\_time),'08:00','0
Wesley13 Wesley13
3年前
00:Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。
Stella981 Stella981
3年前
Django中Admin中的一些参数配置
设置在列表中显示的字段,id为django模型默认的主键list_display('id','name','sex','profession','email','qq','phone','status','create_time')设置在列表可编辑字段list_editable
Wesley13 Wesley13
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
Python进阶者 Python进阶者
10个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这