activiti 增加连线 java-CFANZ编程社区

如何在 Activiti 中增加连线

在 BPM（业务流程管理）工具 Activiti 中，连线（Sequence Flow）是连接过程元素的重要组成部分。通过连线，你可以定义活动之间的流转关系。本文将详细介绍如何在 Activiti 中通过 Java 代码添加连线，并提供清晰的步骤和示例代码。

流程概述

在开始之前，我将首先列出实现此功能的基本步骤。这个过程可以通过以下表格形式呈现：

步骤	描述
1	创建 Process Engine 实例
2	定义流程模型
3	添加活动（节点）
4	增加连线
5	部署流程模型
6	启动流程实例

各步骤详解

步骤 1：创建 Process Engine 实例

首先，你需要创建一个 Activiti 的 ProcessEngine 实例，这样才能与 Activiti 的 API 进行交互。

// 创建 ProcessEngine 配置
ProcessEngineConfiguration configuration = ProcessEngineConfiguration
        .createStandaloneProcessEngineConfiguration();

// 设置数据库连接信息
configuration.setJdbcDriver("com.mysql.cj.jdbc.Driver");
configuration.setJdbcUrl("jdbc:mysql://localhost:3306/activiti");
configuration.setJdbcUsername("root");
configuration.setJdbcPassword("password");

// 创建 ProcessEngine
ProcessEngine processEngine = configuration.buildProcessEngine();
// 输出创建成功的信息
System.out.println("ProcessEngine created: " + processEngine.getName());

该代码块创建了一个连接到 MySQL 数据库的 Process Engine。

步骤 2：定义流程模型

接下来，我们需要定义一个流程模型，使用 Activiti 的 API 创建基本的流程结构。

// 创建流程定义
RepositoryService repositoryService = processEngine.getRepositoryService();
BpmnModelInstance modelInstance = Bpmn.createExecutableProcess("myProcess")
        .name("My Sample Process")
        .done();

// 将模型保存为 XML
repositoryService.createDeployment()
        .addModelInstance("myProcess.bpmn", modelInstance)
        .deploy();

此代码定义了一个名为 "myProcess" 的简单流程，并将其部署到 Activiti 引擎中。

步骤 3：添加活动（节点）

现在，我们要向流程中添加节点，例如开始节点和结束节点。

// 添加开始节点
StartEvent startEvent = modelInstance.newInstance(StartEvent.class);
startEvent.setId("startEvent");
modelInstance.getModelElementById("myProcess").addChildElement(startEvent);

// 添加结束节点
EndEvent endEvent = modelInstance.newInstance(EndEvent.class);
endEvent.setId("endEvent");
modelInstance.getModelElementById("myProcess").addChildElement(endEvent);

该代码段在流程中添加了一个开始节点和一个结束节点。

步骤 4：增加连线

现在我们可以在活动之间添加连线。我们将在开始节点和结束节点之间添加一条连线。

// 创建连线
SequenceFlow sequenceFlow = modelInstance.newInstance(SequenceFlow.class);
sequenceFlow.setSource(startEvent);
sequenceFlow.setTarget(endEvent);
modelInstance.getModelElementById("myProcess").addChildElement(sequenceFlow);

此代码创建了一条从开始节点到结束节点的连线。

步骤 5：部署流程模型

如果之前没有执行部署操作，我们在此步骤中再次确认部署。

repositoryService.createDeployment()
        .addModelInstance("myProcess.bpmn", modelInstance)
        .deploy();

这段代码确保我们的流程模型已经成功部署。

步骤 6：启动流程实例

最后，我们可以启动流程实例，看看我们的连线是否工作正常。

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

// 输出启动成功的消息
System.out.println("Process instance started: " + processInstance.getProcessInstanceId());

该代码启动了我们刚创建的流程，并输出实例 ID。