在Java中,Activity工作流可以使用Activiti框架實現。Activiti是一個基于BPMN2.0標準的工作流引擎,提供了創建、部署、運行和管理工作流的功能。要使用Activiti,首先需要在項目中添加相關依賴,然后創建工作流定義文件(BPMN),最后編寫Java代碼來實現工作流的創建、部署、運行等操作。
以下是一個簡單的Activiti工作流配置文件示例:
在Maven項目的pom.xml文件中添加Activiti依賴:
<dependency>
<groupId>org.activiti</groupId>
<artifactId>activiti-engine</artifactId>
<version>7.1.0.M6</version>
</dependency>
</dependencies>
在項目的resources目錄下創建一個名為process.bpmn20.xml的文件,內容如下:
<?xml version="1.0" encoding="UTF-8"?><definitions xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:activiti="http://activiti.org/bpmn" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:omgdc="http://www.omg.org/spec/DD/20100524/DC" xmlns:omgdi="http://www.omg.org/spec/DD/20100524/DI" typeLanguage="http://www.w3.org/2001/XMLSchema" expressionLanguage="http://www.w3.org/1999/XPath" targetNamespace="http://www.activiti.org/test">
<process id="myProcess" name="My Process" isExecutable="true">
<startEvent id="startEvent" />
<sequenceFlow id="flow1" sourceRef="startEvent" targetRef="task1" />
<userTask id="task1" name="Task 1" activiti:assignee="user1" />
<sequenceFlow id="flow2" sourceRef="task1" targetRef="endEvent" />
<endEvent id="endEvent" />
</process>
</definitions>
這個BPMN文件定義了一個簡單的工作流,包含一個開始事件、一個任務和一個結束事件。任務將被分配給名為"user1"的用戶。
import org.activiti.engine.*;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
public class ActivitiDemo {
public static void main(String[] args) {
// 創建Activiti引擎
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
// 獲取RepositoryService
RepositoryService repositoryService = processEngine.getRepositoryService();
// 部署工作流定義文件
Deployment deployment = repositoryService.createDeployment()
.addClasspathResource("process.bpmn20.xml")
.deploy();
// 獲取RuntimeService
RuntimeService runtimeService = processEngine.getRuntimeService();
// 啟動工作流實例
ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("myProcess");
// 獲取TaskService
TaskService taskService = processEngine.getTaskService();
// 查詢任務
Task task = taskService.createTaskQuery().singleResult();
// 處理任務
System.out.println("Task name: " + task.getName());
System.out.println("Task assignee: " + task.getAssignee());
taskService.complete(task.getId());
// 關閉Activiti引擎
processEngine.close();
}
}
這段Java代碼首先創建了一個Activiti引擎,然后使用RepositoryService部署了工作流定義文件。接著,使用RuntimeService啟動了一個工作流實例。最后,使用TaskService查詢并處理了任務。
注意:在實際項目中,你可能需要根據實際需求對工作流定義文件和Java代碼進行更多的定制化。