Java工作流引擎开发Activiti|极客教程

Java工作流引擎开发Activiti

在当今的软件开发领域中，工作流引擎在企业级应用中发挥着越来越重要的作用。工作流引擎可以帮助企业进行流程管理、自动化和优化，提高工作效率和质量。在Java领域，Activiti是一个开源的轻量级工作流引擎，被广泛应用于各种企业级应用中。本文将详细介绍如何使用Java开发Activiti工作流引擎，包括Activiti的基本概念、核心API的使用和实际案例演示。

什么是Activiti

Activiti是一个基于Java的开源工作流和业务流程管理引擎，是由Alfresco公司开发和维护的。Activiti提供了一套丰富的API和工具，能够帮助开发人员快速构建复杂的工作流和业务流程应用。Activiti支持BPMN 2.0（Business Process Model and Notation）标准，可以直观地描述和构建各种类型的流程模型。

Activiti的核心概念

在使用Activiti开发工作流引擎之前，我们需要了解一些核心概念：

流程定义（Process Definition）：描述了整个工作流程的结构和流程逻辑，通常使用BPMN 2.0标准进行描述。
流程实例（Process Instance）：流程定义的具体实例化，每个流程实例对应一个实际的流程执行过程。
任务（Task）：流程中的基本执行单元，用于描述工作流程中的具体工作任务。
用户任务（User Task）：需要指定具体用户来执行的任务，通常在流程图中用人员图标表示。
服务任务（Service Task）：由系统自动执行的任务，通常用于集成外部系统。
网关（Gateway）：用于控制流程流转的逻辑分支和合并点，包括排他网关、并行网关等。
监听器（Listener）：用于监听流程中的各种事件，可以在特定事件发生时执行特定逻辑。

Activiti的核心API

Activiti提供了丰富的Java API，可以通过编程的方式创建、部署和执行工作流。下面是一些常用的核心API示例代码：

创建流程引擎

ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

部署流程定义

RepositoryService repositoryService = processEngine.getRepositoryService();
Deployment deployment = repositoryService.createDeployment()
    .addClasspathResource("processes/myProcess.bpmn20.xml")
    .deploy();

启动流程实例

RuntimeService runtimeService = processEngine.getRuntimeService();
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("myProcess");

查询用户任务

TaskService taskService = processEngine.getTaskService();
List<Task> tasks = taskService.createTaskQuery()
    .taskAssignee("Alice")
    .list();

完成用户任务

for (Task task : tasks) {
    taskService.complete(task.getId());
}

实际案例演示

为了更好地理解Activiti的使用方法，我们将通过一个简单的请假流程案例演示Activiti工作流引擎的开发过程。假设我们有一个请假流程，包括请假申请、部门审批和总经理审批三个任务节点。

创建流程定义

首先，我们需要创建一个BPMN 2.0格式的流程定义文件leaveProcess.bpmn20.xml，描述请假流程的流程逻辑和各个任务节点。

<definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xmlns:activiti="http://activiti.org/bpmn"
             xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd"
             targetNamespace="http://activiti.org/bpmn">

    <process id="leaveProcess" name="Leave Process">

        <startEvent id="startEvent" name="Start"></startEvent>

        <userTask id="applyTask" name="Apply Leave" activiti:assignee="Alice"></userTask>

        <userTask id="deptTask" name="Department Approval" activiti:assignee="Bob"></userTask>

        <userTask id="mgrTask" name="Manager Approval" activiti:assignee="Charlie"></userTask>

        <sequenceFlow id="flow1" sourceRef="startEvent" targetRef="applyTask"></sequenceFlow>

        <sequenceFlow id="flow2" sourceRef="applyTask" targetRef="deptTask"></sequenceFlow>

        <sequenceFlow id="flow3" sourceRef="deptTask" targetRef="mgrTask"></sequenceFlow>

        <endEvent id="endEvent" name="End"></endEvent>

        <sequenceFlow id="flow4" sourceRef="mgrTask" targetRef="endEvent"></sequenceFlow>

    </process>

</definitions>

部署流程定义并启动流程实例

接下来，我们通过Java代码部署流程定义并启动流程实例。

public class LeaveProcessDemo {

    public static void main(String[] args) {
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        RepositoryService repositoryService = processEngine.getRepositoryService();
        Deployment deployment = repositoryService.createDeployment()
            .addClasspathResource("processes/leaveProcess.bpmn20.xml")
            .deploy();

        RuntimeService runtimeService = processEngine.getRuntimeService();
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("leaveProcess");
    }

}

处理任务并完成流程

最后，我们需要处理用户任务并完成整个请假流程。

public class LeaveTaskDemo {

    public static void main(String[] args) {
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        TaskService taskService = processEngine.getTaskService();
        List<Task> tasks = taskService.createTaskQuery()
            .taskAssignee("Alice")
            .list();

        for (Task task : tasks) {
            taskService.complete(task.getId());
        }
    }

}

通过以上步骤，我们成功地开发了一个简单的请假流程应用，并使用Activiti工作流引擎进行了管理和执行。