接上文,本文主要讲述如何使用Activiti搭建一个简单的工程。
首先就是下载Activiti5.9的官方文件,下载地址见:http://activiti.org/download.html,新建一个Java工程导入相关的JAR包,安装Activiti的插件。因为单一的仅使用Activiti的项目在现实生活中几乎不存在,所以本文中的项目还是集成了Spring框架,所需要的JAR包截图如下:
新建一个Java Project,在该项目中新建一个Activiti Process,打开插件面板。
这里模拟的流程是某公司的实习生招聘流程:
新建一个开始节点:
接下来新建其余的节点:
最终的结果图如下:
该步骤会自动生成相应的bpmn2.0文件,如图所示:
接下来就是创建配置文件了:
activiti.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"
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="true" />
<property name="jdbcUrl" value="jdbc:mysql://localhost:9906/activiti" />
<property name="jdbcDriver" value="com.mysql.jdbc.Driver" />
<property name="jdbcUsername" value="root" />
<property name="jdbcPassword" value="root" />
<property name="jobExecutorActivate" value="true" />
</bean>
</beans>
测试类:
InterviewTest.java
package com.activiti04;
import java.util.List;
import org.activiti.engine.HistoryService;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngineConfiguration;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.RuntimeService;
import org.activiti.engine.TaskService;
import org.activiti.engine.history.HistoricProcessInstance;
import org.activiti.engine.task.Task;
public class InterviewTest {
//本流程模拟的是某公司2012年实习生招聘流程
public static void main(String[] args) {
//加载配置文件
ProcessEngine processEngine = ProcessEngineConfiguration
.createProcessEngineConfigurationFromResource("activiti.cfg.xml")
.buildProcessEngine();
RepositoryService repositoryService = processEngine.getRepositoryService();
RuntimeService runtimeService = processEngine.getRuntimeService();
repositoryService.createDeployment()
.addClasspathResource("main/resources/diagrams/Interview.bpmn20.xml")
.deploy();
String processId = runtimeService.startProcessInstanceByKey("Interview").getId();
TaskService taskService = processEngine.getTaskService();
//得到笔试的流程
System.out.println("***************笔试流程开始***************");
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("***************一面流程开始***************");
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("***************二面流程开始***************");
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("***************录用流程开始***************");
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("流程结束时间:"+historicProcessInstance.getEndTime());
System.exit(0);
}
}
然后执行即可,结果如下:
***************笔试流程开始***************
人力资源部的任务:name:笔试,id:307
张三的任务数量:1
张三的任务:name:笔试,id:307
张三的任务数量:0
***************笔试流程结束***************
***************一面流程开始***************
技术部的任务:name:技术一面,id:310
李四的任务数量:1
李四的任务:name:技术一面,id:310
李四的任务数量:0
***************一面流程结束***************
***************二面流程开始***************
技术部的任务:name:技术二面,id:313
李四的任务数量:1
李四的任务:name:技术二面,id:313
李四的任务数量:0
***************二面流程结束***************
***************HR面流程开始***************
技术部的任务:name:HR面,id:316
李四的任务数量:1
李四的任务:name:HR面,id:316
李四的任务数量:0
***************HR面流程结束***************
***************录用流程开始***************
技术部的任务:name:录用,发放Offer,id:319
李四的任务数量:1
李四的任务:name:录用,发放Offer,id:319
李四的任务数量:0
***************录用流程结束***************
流程结束时间:Tue May 15 17:44:26 CST 2012
至此,该项目结束,项目源码放在附件中。
- 大小: 10.9 KB
- 大小: 11.8 KB
- 大小: 10.6 KB
- 大小: 32.1 KB
- 大小: 16.7 KB
- 大小: 18.8 KB
- 大小: 10.4 KB
分享到:
相关推荐
Activiti学习笔记,介绍Activiti的组成结构,工作流BPMN2.0规范等
### Activiti5学习笔记核心知识点解析 #### 一、Activiti5概述与环境搭建 **Activiti5**是一款开源的工作流引擎,基于Java语言开发,主要用于实现业务流程管理(BPM)和工作流自动化。其核心特性包括流程建模、...
在“Activiti学习笔记三:管理流程定义”中,我们将深入探讨如何使用Activiti来管理和操作流程定义。 首先,流程定义是Activiti中的核心概念,它是流程模型的静态表示,描述了工作流的结构和规则。流程定义通常以...
Activiti 学习笔记11:接收活动(receiveTask,即等待活动)
本学习笔记将聚焦于流程执行的历史记录,这是理解流程运行情况、追踪问题以及优化流程的关键。 一、Activiti 的历史记录功能 历史记录是 Activiti 中的一个重要特性,它允许开发者和管理员查看已经执行过的流程实例...
在本篇Activiti学习笔记中,我们将深入探讨工作流定义中的关键概念——角色组,以及它们在Activiti流程引擎中的应用。Activiti是一款强大的、开源的企业级工作流和业务自动化引擎,广泛应用于业务流程管理(BPM)...
在本篇Activiti学习笔记中,我们将探讨如何在工作流引擎Activiti中分配组任务,这对于构建企业级流程管理系统至关重要。Activiti是一个轻量级、开源的业务流程管理(BPM)和工作流系统,它提供了强大的流程定义、...
在本篇学习笔记中,我们将深入探讨并行网关的工作原理、使用场景以及如何在 Activiti 中进行配置。 一、并行网关的概念 并行网关,也称为并发网关,允许流程实例同时沿着多个路径进行,这些路径可以是独立的,然后...
本篇学习笔记将深入探讨SequenceFlow的概念、作用以及如何在流程设计中使用。 一、SequenceFlow简介 SequenceFlow 是 Activiti 流程模型中的概念,它表示了流程实例从一个活动(Activity)到另一个活动的流转。每个...
理解并熟练操作流程变量是深入学习 Activiti 的关键部分。 在 Activiti 中,流程变量可以在以下场景中发挥作用: 1. **定义变量**:在 BPMN2.0 流程图中,可以通过 `user task`、`service task` 或其他元素的属性...
本学习笔记主要聚焦在开始活动节点以及如何判断流程是否结束,同时涵盖了查询历史流程实例的相关内容。 一、开始活动节点(Start Event) 在 Activiti 流程图中,开始活动节点(Start Event)标志着流程的起始点。...
<sequence-flow id="flow2" source-ref="exclusiveGateway" target-ref="taskB"> ${someVariable == 'valueB'} ``` 在这个例子中,如果`someVariable`的值等于'valueA',流程将流向任务A;否则,如果值等于'...
本篇学习笔记将深入探讨如何在Activiti中进行个人任务的分配。 一、理解个人任务 在Activiti中,个人任务(User Task)代表了流程中的一个节点,这个节点只能由特定的用户或用户组来处理。这种任务的分配方式确保了...
### Activiti5学习笔记知识点概览 #### 一、Activiti5概述与环境搭建 - **JDK版本**: 使用Activiti5至少需要JDK 1.5或更高版本。建议使用较新版本以获得更好的性能和支持。 - **构建工具**: Ant 1.8.1或以上版本是...
本学习笔记将深入探讨流程实例和任务执行这两个关键概念。 流程实例是 Activiti 中的一个核心概念,它代表了流程定义在实际运行中的一个具体执行。当你启动一个流程,实际上就是创建了一个流程实例。流程实例是动态...
本文将深入探讨Activiti 5.9 的学习笔记,特别是关于流程发布的部分,这对于理解如何在实际环境中部署和运行流程至关重要。 ### 1. Activiti 简介 Activiti 是一个轻量级、灵活且强大的业务流程管理系统(BPM),它...
本学习资料集合包含两份文档:《Activiti学习笔记.docx》和《Activitiʵ۸.pdf》,它们将帮助你快速入门并逐步深入理解Activiti的核心功能。 《Activiti学习笔记.docx》可能是作者在学习过程中整理的笔记,通常这类...
深入学习,我们关注到Activiti数据库的各个部分: 1. 资源库流程规则表: - act_re_deployment:包含部署信息。 - act_re_model:流程设计模型的部署信息。 - act_re_procdef:存储流程定义数据。 2. 运行时...