首页 > 工作流 > 工作流Activiti5入门（上）

工作流Activiti5入门（上）

2015年8月2日 发表评论 阅读评论

刚工作的时候曾经用Activiti5，但由于当时介于水平，对Activiti5并没有很深的理解，而且知识也没有形成一个体系，前一段时间偶然发现传智播客公布了一个关于Activiti5的教学视频，自己跟着看了一下，感觉有很多收获，所以打算写几篇博文，整理一下，以供将来如有需要的话可以查阅，今天记下学习的前一部分，称为Activiti5上。

一. Activiti5开发环境搭建和配置

1. 开发环境搭建

Activiti5开发一个工作流系统，首先肯定是要搭建环境的，关于搭建环境老夫窃以为这篇文章：http://www.zhengmenbb.com/archives/98.htm，写的很不错，这篇文章不仅写了怎么搭建环境，还有一个小小的例子，大家可以先看一下，看了这篇文章，我相信大家搭建好环境不是问题，因为就是装一个插件而已，很简单。

2. 配置

现在的任何框架几乎都要和spring相整合，否则几乎可以说是玩不转，所以我们的Activiti5要想流行起来也不能例外，下面我们先看看他们怎么整合的。
spring的整合肯定要引入spring的jar包，这个老夫默认大家都会了，如果不会的话，我相信也不会看到这篇文章，至于Activiti5要引入那些jar文件，可以参考这个

(1). 部分pom文件

1
2
3
4
5
6
7
8
9
10
<dependency>
  <groupId>org.activiti</groupId>
  <artifactId>activiti-engine</artifactId>
  <version>5.11</version>
</dependency>
<dependency>
  <groupId>org.activiti</groupId>
  <artifactId>activiti-spring</artifactId>
  <version>5.11</version>
</dependency>

我们可以先把最基本的引入，如果不够肯定会报classnotfoundexception，到时候我们就知道缺少哪个了，老夫的原则是能少引入绝不多引入，原因一是怕冲突，二是文件大小和启动速度

(2). 和spring集成的配置文件activiti.cfg.xml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
    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
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
 
    <bean id="processEngineConfiguration" class="org.activiti.engine.impl.cfg.StandaloneProcessEngineConfiguration">
        <!-- 连接数据的配置 -->
        <property name="jdbcDriver" value="com.mysql.jdbc.Driver"></property>
        <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/itcast0711activiti?useUnicode=true&amp;characterEncoding=utf8"></property>
        <property name="jdbcUsername" value="root"></property>
        <property name="jdbcPassword" value="root"></property>
        <!-- 没有表创建表 -->
        <property name="databaseSchemaUpdate" value="true"></property>
    </bean>
 
</beans>

这个集成文件简单吧？对，就是这么简单，至于spring等其他的配置文件啊，log的配置文件就不多说了，接下来我们要开始Activiti5的实战：开始写代码。

二. Activiti5实战

Activiti5实战，所以第一步肯定是画图，但装好了环境之后，其实上面那篇文章是有怎么画图的，所以画图这个就先讲怎么花了，大家可以画一个最简单的练手，本文作为一个入门教程，也不会涉及到那些复杂的图，所以第一步，咱直接开始启动流程定义。

因为Activiti5所有的操作都和ProcessEngine相关，所以所有的操作都和ProcessEngine相关，我们就先获取这个对象，当做第0步吧：

1
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

1. 部署流程定义

部署流程定义，有两种，1. 从zip部署，也就是把我们的流程图压缩成zip，然后上传到项目的根目录，部署流程。

(1). 从zip部署

1
2
3
4
5
6
7
8
9
10
11
12
13
/**部署流程定义（从zip）*/
@Test
public void deploymentProcessDefinition_zip(){
    InputStream in = this.getClass().getClassLoader().getResourceAsStream("diagrams/helloworld.zip");
    ZipInputStream zipInputStream = new ZipInputStream(in);
    Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
                    .createDeployment()//创建一个部署对象
                    .name("流程定义")//添加部署的名称
                    .addZipInputStream(zipInputStream)//指定zip格式的文件完成部署
                    .deploy();//完成部署
    System.out.println("部署ID："+deployment.getId());//
    System.out.println("部署名称："+deployment.getName());//
}

(2). 从资源文件

1
2
3
4
5
6
7
8
9
10
11
12
/**部署流程定义（从classpath）*/
@Test
public void deploymentProcessDefinition_classpath(){
    Deployment deployment = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
                    .createDeployment()//创建一个部署对象
                    .name("流程定义")//添加部署的名称
                    .addClasspathResource("diagrams/helloworld.bpmn")//从classpath的资源中加载，一次只能加载一个文件
                    .addClasspathResource("diagrams/helloworld.png")//从classpath的资源中加载，一次只能加载一个文件
                    .deploy();//完成部署
    System.out.println("部署ID："+deployment.getId());//
    System.out.println("部署名称："+deployment.getName());//
}

2. 启动流程实例

当流程实例部署完成之后，肯定是开始启动流程了，下面我们就开始启动流程

1
2
3
4
5
6
7
8
9
10
/**启动流程实例*/
@Test
public void startProcessInstance(){
    //流程定义的key
    String processDefinitionKey = "helloworld";
    ProcessInstance pi = processEngine.getRuntimeService()//与正在执行的流程实例和执行对象相关的Service
                    .startProcessInstanceByKey(processDefinitionKey);//使用流程定义的key启动流程实例，key对应helloworld.bpmn文件中id的属性值，使用key值启动，默认是按照最新版本的流程定义启动
    System.out.println("流程实例ID:"+pi.getId());//流程实例ID    101
    System.out.println("流程定义ID:"+pi.getProcessDefinitionId());//流程定义ID   helloworld:1:4
}

其中helloworld就是我们画的流程图的名字，启动流程实例之后，肯定是要查询我的任务了，所以接下来查询的任务

3. 查询我的任务

查询我的任务，分好几种，一种是我们在画图的时候，直接把这个任务就分配到某个人，另一种是分配到一个组，就是只要这个组有这个权限，那么都可以获取这个任务，还有一个是我们画图的时候什么都不指定，到流程执行到这个的时候动态指定，后两个先不说，我们先说第一个

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
    /**查询当前人的个人任务*/
    @Test
    public void findMyPersonalTask(){
        String assignee = "王五";
        List<Task> list = processEngine.getTaskService()//与正在执行的任务管理相关的Service
                        .createTaskQuery()//创建任务查询对象
                        /**查询条件（where部分）*/
                        .taskAssignee(assignee)//指定个人任务查询，指定办理人
//                      .taskCandidateUser(candidateUser)//组任务的办理人查询
//                      .processDefinitionId(processDefinitionId)//使用流程定义ID查询
//                      .processInstanceId(processInstanceId)//使用流程实例ID查询
//                      .executionId(executionId)//使用执行对象ID查询
                        /**排序*/
                        .orderByTaskCreateTime().asc()//使用创建时间的升序排列
                        /**返回结果集*/
//                      .singleResult()//返回惟一结果集
//                      .count()//返回结果集的数量
//                      .listPage(firstResult, maxResults);//分页查询
                        .list();//返回列表
        if(list!=null && list.size()>0){
            for(Task task:list){
                System.out.println("任务ID:"+task.getId());
                System.out.println("任务名称:"+task.getName());
                System.out.println("任务的创建时间:"+task.getCreateTime());
                System.out.println("任务的办理人:"+task.getAssignee());
                System.out.println("流程实例ID："+task.getProcessInstanceId());
                System.out.println("执行对象ID:"+task.getExecutionId());
                System.out.println("流程定义ID:"+task.getProcessDefinitionId());
                System.out.println("########################################################");
            }
        }
    }

查询我的任务之后我们，肯定要认领任务，然后完成任务，所以接下来就是这一步

4. 认领和完成任务

1
2
3
4
5
6
7
8
9
/**完成我的任务*/
@Test
public void completeMyPersonalTask(){
    //任务ID
    String taskId = "1202";
    processEngine.getTaskService()//与正在执行的任务管理相关的Service
                .complete(taskId);
    System.out.println("完成任务：任务ID："+taskId);
}

完成了我们自己的任务之后，流程就会按照流程图标记的那样，往后走，那么我们怎么知道这个流程什么时候结束呢？下面我们就要查询流程的状态

5. 流程状态查询

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
/**查询流程状态（判断流程正在执行，还是结束）*/
@Test
public void isProcessEnd(){
    String processInstanceId = "1001";
    ProcessInstance pi = processEngine.getRuntimeService()//表示正在执行的流程实例和执行对象
                    .createProcessInstanceQuery()//创建流程实例查询
                    .processInstanceId(processInstanceId)//使用流程实例ID查询
                    .singleResult();
    if(pi==null){
        System.out.println("流程已经结束");
    }
    else{
        System.out.println("流程没有结束");
    }
}

6. 删除流程定义

我们在部署启动了流程定义之后，某些流程可能会由于各种各样的原因，导致流程无效，那么这个时候如果我们想删除该流程实例，那么这么做

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
/**附加功能：删除流程定义（删除key相同的所有不同版本的流程定义）*/
@Test
public void deleteProcessDefinitionByKey(){
    //流程定义的key
    String processDefinitionKey = "helloworld";
    //先使用流程定义的key查询流程定义，查询出所有的版本
    List<ProcessDefinition> list = processEngine.getRepositoryService()//
                    .createProcessDefinitionQuery()//
                    .processDefinitionKey(processDefinitionKey)//使用流程定义的key查询
                    .list();
    //遍历，获取每个流程定义的部署ID
    if(list!=null && list.size()>0){
        for(ProcessDefinition pd:list){
            //获取部署ID
            String deploymentId = pd.getDeploymentId();
            processEngine.getRepositoryService()//
                        .deleteDeployment(deploymentId, true);
        }
    }
}

或者也可以这么删除

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
    /**删除流程定义*/
    @Test
    public void deleteProcessDefinition(){
        //使用部署ID，完成删除
        String deploymentId = "601";
        /**
         * 不带级联的删除
         *    只能删除没有启动的流程，如果流程启动，就会抛出异常
         */
//      processEngine.getRepositoryService()//
//                      .deleteDeployment(deploymentId);
         
        /**
         * 级联删除
         *    不管流程是否启动，都能可以删除
         */
        processEngine.getRepositoryService()//
                        .deleteDeployment(deploymentId, true);
        System.out.println("删除成功！");
    }

7. 查询流程定义

在我们的正式系统中，每次肯定不会只有一个流程，我们想看看系统中有多少流程，可以这么做

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
    /**查询流程定义*/
    @Test
    public void findProcessDefinition(){
        List<ProcessDefinition> list = processEngine.getRepositoryService()//与流程定义和部署对象相关的Service
                        .createProcessDefinitionQuery()//创建一个流程定义的查询
                        /**指定查询条件,where条件*/
//                      .deploymentId(deploymentId)//使用部署对象ID查询
//                      .processDefinitionId(processDefinitionId)//使用流程定义ID查询
//                      .processDefinitionKey(processDefinitionKey)//使用流程定义的key查询
//                      .processDefinitionNameLike(processDefinitionNameLike)//使用流程定义的名称模糊查询
                         
                        /**排序*/
                        .orderByProcessDefinitionVersion().asc()//按照版本的升序排列
//                      .orderByProcessDefinitionName().desc()//按照流程定义的名称降序排列
                         
                        /**返回的结果集*/
                        .list();//返回一个集合列表，封装流程定义
//                      .singleResult();//返回惟一结果集
//                      .count();//返回结果集数量
//                      .listPage(firstResult, maxResults);//分页查询
        if(list!=null && list.size()>0){
            for(ProcessDefinition pd:list){
                System.out.println("流程定义ID:"+pd.getId());//流程定义的key+版本+随机生成数
                System.out.println("流程定义的名称:"+pd.getName());//对应helloworld.bpmn文件中的name属性值
                System.out.println("流程定义的key:"+pd.getKey());//对应helloworld.bpmn文件中的id属性值
                System.out.println("流程定义的版本:"+pd.getVersion());//当流程定义的key值相同的相同下，版本升级，默认1
                System.out.println("资源名称bpmn文件:"+pd.getResourceName());
                System.out.println("资源名称png文件:"+pd.getDiagramResourceName());
                System.out.println("部署对象ID："+pd.getDeploymentId());
                System.out.println("#########################################################");
            }
        }          
    }

好了，这就是我们的上，介绍了一些最基本的功能，其实写完之后发现，应该写一下画图的，因为代码就是根据画图来的，所以画图可以说是Activiti5最最重要的基本功，不过算了，这个就留给大家自学吧，在接下来的下篇中，我会介绍一些算是更高级也是非常经常用到的一些功能的。

全文完，如果本文对您有所帮助，请花 1 秒钟帮忙点击一下广告，谢谢。

作 者： BridgeLi，https://www.bridgeli.cn
原文链接：http://www.bridgeli.cn/archives/197
版权声明：非特殊声明均为本站原创作品，转载时请注明作者和原文链接。
分类: 工作流 标签: ,
  1. Tatanka
    2015年8月14日15:20 | #1
    回复 | 引用

    手动点赞

  1. 本文目前尚无任何 trackbacks 和 pingbacks.

请输入正确的验证码