Java Activiti|极客笔记

Java Activiti

1. 什么是Activiti

Activiti是一个开源的工作流和业务流程管理系统，它是用Java编写的。它是一个轻量级、灵活、可扩展的流程引擎，通过Activiti，我们可以轻松地管理复杂的业务流程。

Activiti支持BPMN 2.0（Business Process Model and Notation）标准，BPMN是一种现代化的业务流程建模语言，它提供了一种直观的方式来描述业务流程。Activiti使得我们能够将业务流程直观地建模为BPMN图形，并将其转化为可执行的流程。通过Activiti，我们可以通过图形界面来设计业务流程，也可以通过Java代码来实现灵活的流程控制。

2. Activiti的优势

灵活性：Activiti提供了灵活的流程引擎，允许我们根据实际需求定制业务流程。
可扩展性：Activiti可以与其他系统集成，通过API调用或消息通知来扩展其功能。
易用性：Activiti通过可视化的BPMN图形界面，使得业务流程的设计更加直观容易。
高性能：Activiti采用轻量级的流程引擎，具有高性能和可靠性。

3. Activiti的核心概念

3.1 流程定义

流程定义是业务流程的模板，它定义了业务流程中每个环节的处理逻辑，包括任务、网关、事件等。在Activiti中，流程定义通常通过BPMN图形来描述，然后部署到Activiti引擎中执行。

3.2 流程实例

流程实例是流程定义的具体执行实例，每个流程实例对应一个具体的业务流程。在Activiti中，我们可以通过流程实例来管理业务流程的执行。

3.3 任务

任务是流程中的工作单元，是对业务流程中某个具体操作的描述。任务可以被分配给特定的用户或角色，等待处理。

3.4 网关

网关用于控制流程的走向，根据条件判断来决定流程的分支和汇聚。

3.5 事件

事件是流程中的触发器，可以是启动事件、结束事件、中间事件等，用于响应特定的流程事件。

4. Activiti的使用示例

4.1 创建流程定义

public static void createProcessDefinition() {
    // 创建流程引擎
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

    // 部署流程定义
    RepositoryService repositoryService = processEngine.getRepositoryService();
    Deployment deployment = repositoryService.createDeployment()
        .addClasspathResource("MyProcess.bpmn")
        .deploy();

    System.out.println("流程部署ID：" + deployment.getId());
}

4.2 启动流程实例

public static void startProcessInstance() {
    // 创建流程引擎
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

    // 启动流程实例
    RuntimeService runtimeService = processEngine.getRuntimeService();
    ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("myProcess");

    System.out.println("流程实例ID：" + processInstance.getId());
}

4.3 处理任务

public static void handleTask() {
    // 创建流程引擎
    ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();

    // 查询待办任务
    TaskService taskService = processEngine.getTaskService();
    List<Task> tasks = taskService.createTaskQuery().taskCandidateUser("john").list();

    // 处理任务
    if(tasks != null && tasks.size() > 0) {
        for(Task task : tasks) {
            System.out.println("待办任务：" + task.getName());
            taskService.complete(task.getId());
            System.out.println("处理任务成功");
        }
    }
}