在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代码进行更多的定制化。