1 创建bpmn流程resources下新建一个文件夹，名称随意，这里我们叫：bpmn右键，新创建一个：bpmnFile，名称随意，这里我们叫：hello.bpmn拖拽生成流程节点信息，这里我们简单操作，视频操作流程如下：
好了，截止目前我们就生成了一个简单的，单节点审批的工作流。接下来我们就将以此流程作为Demo，开始我们的学习之路。2 部署流程定义此代码是模拟我们开发好一套审批流程，后续员工就可以发起这个流程请确保你已正确配置数据库连接（端口、用户名、密码），数据库处于启动状态，并且在本地创建了对应的数据库：activiti（名称可以随意）。代码编写上述代码唯一需要注意的地方，就是：addClasspathResource 中的路径，如果读者们与我保持不一致，请记得及时修改。代码测试运行单测，会发现日志中打印了大量的DDL语句，这是因为Activiti作为一款成熟的工作流引擎框架，他已经有了完善的数据库：执行完成我们在最后的日志中看到输出结果：此时我们去刷新数据库，会发现多了25张表，如下（大概表分类我们放在：04-Activiti拓展篇讲解，这里只讲最简单的上手Demo）：此时，最关键的来了：我们去：act_re_procdef中会发现有我们刚才的流程定义：这就验证了我们的流程定义代码测试成功。相当于我们公司现在有了一个单节点的审批流程，后面就等着用户发起，这个流程就可以使用起来。3 启动流程实例此代码模拟的就是某个用户开始提交流程，此时就会开启某个流程，如下这里面需要注意的是：流程实例的key，对应表：act_re_procdef.key字段，二者必须保持一致，也就是bpmn文件id属性值。当我们执行完成，输出打印如下：此时我们去：act_ru_task 表中可以看到生成一个新的task数据，即当前用户开启了一个新的流程同时可以查看到流程的多个任务节点信息：act_ru_execution4 查询当前任务此代码模拟员工查询目前审批在哪个节点，好催促对应审批人员进行审批运行后代码输出如下：5 完成指定任务此代码模拟某个用户完成对应的节点，即：审批通过/拒绝，流程就会自动流转至下一个节点需要注意的是，此id对应的是上述：4 查询当前任务 返回任务ID保持一致。当运行完成后，表：act_ru_task、act_ru_execution这种进行中数据都会清空，进入到：act_hi_**表中。以上我们就完成了一个简单的工作流引擎代码编写与测试。6 完整代码汇总
Java
运行代码复制代码
package com.demo;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.junit.Test;
import java.util.List;
public class ActivitiTest {
@Test
public void deploymentProcessDefinition(){
//创建ProcessEngine对象
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//获取RepositoryService对象
RepositoryService repositoryService = processEngine.getRepositoryService();
//进行部署
Deployment deployment = repositoryService
.createDeployment()
.name("测试入门案例")
.addClasspathResource("bpmn/hello.bpmn")
.deploy();
//输出部署的一些信息
System.out.println("流程部署ID:"+deployment.getId());
System.out.println("流程部署名称:"+deployment.getName());
}
@Test
public void startProcessInstance(){
//获取与正在执行的流程示例和执行对象相关的Service
ProcessInstance processInstance = ProcessEngines.getDefaultProcessEngine().getRuntimeService()
//使用流程定义的key启动实例，key对应bpmn文件中id的属性值，默认按照最新版本流程启动
.startProcessInstanceByKey("myProcess_1");
System.out.println("流程实例ID:"+processInstance.getId());
System.out.println("流程实例定义ID:"+processInstance.getProcessDefinitionId());
}
@Test
public void findPersonalTask(){
//与正在执行的任务相关的Service
List<Task> list = ProcessEngines.getDefaultProcessEngine().getTaskService()
.createTaskQuery() //创建查询任务对象
// .taskAssignee("UserTask") //指定个人任务查询，指定办理人
.list();
if(list != null && list.size() > 0){
for(Task task : list){
System.out.println("任务ID" + task.getId());
System.out.println("任务名称" + task.getName());
System.out.println("任务创建时间" + task.getCreateTime());
System.out.println("任务指定人" + task.getAssignee());
System.out.println("任务流程实例ID" + task.getProcessInstanceId());
System.out.println("任务执行ID" + task.getExecutionId());
System.out.println("任务流程定义ID" + task.getProcessDefinitionId());
}
}
}
@Test
public void completePersonalTask(){
// 对应task表的id
ProcessEngines.getDefaultProcessEngine()
.getTaskService()
.complete("2505");
}
/**
* 1-2-3-4
*
* 2-1-3-4
* 3-1-2-4
* 流程编排、流程可视化
*/
}
package com.demo;
import org.activiti.engine.ProcessEngine;
import org.activiti.engine.ProcessEngines;
import org.activiti.engine.RepositoryService;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.junit.Test;
import java.util.List;
public class ActivitiTest {
@Test
public void deploymentProcessDefinition(){
//创建ProcessEngine对象
ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
//获取RepositoryService对象
RepositoryService repositoryService = processEngine.getRepositoryService();
//进行部署
Deployment deployment = repositoryService
.createDeployment()
.name("测试入门案例")
.addClasspathResource("bpmn/hello.bpmn")
.deploy();
//输出部署的一些信息
System.out.println("流程部署ID:"+deployment.getId());
System.out.println("流程部署名称:"+deployment.getName());
}
@Test
public void startProcessInstance(){
//获取与正在执行的流程示例和执行对象相关的Service
ProcessInstance processInstance = ProcessEngines.getDefaultProcessEngine().getRuntimeService()
//使用流程定义的key启动实例，key对应bpmn文件中id的属性值，默认按照最新版本流程启动
.startProcessInstanceByKey("myProcess_1");
System.out.println("流程实例ID:"+processInstance.getId());
System.out.println("流程实例定义ID:"+processInstance.getProcessDefinitionId());
}
@Test
public void findPersonalTask(){
//与正在执行的任务相关的Service
List<Task> list = ProcessEngines.getDefaultProcessEngine().getTaskService()
.createTaskQuery() //创建查询任务对象
// .taskAssignee("UserTask") //指定个人任务查询，指定办理人
.list();
if(list != null && list.size() > 0){
for(Task task : list){
System.out.println("任务ID" + task.getId());
System.out.println("任务名称" + task.getName());
System.out.println("任务创建时间" + task.getCreateTime());
System.out.println("任务指定人" + task.getAssignee());
System.out.println("任务流程实例ID" + task.getProcessInstanceId());
System.out.println("任务执行ID" + task.getExecutionId());
System.out.println("任务流程定义ID" + task.getProcessDefinitionId());
}
}
}
@Test
public void completePersonalTask(){
// 对应task表的id
ProcessEngines.getDefaultProcessEngine()
.getTaskService()
.complete("2505");
}
/**
* 1-2-3-4
*
* 2-1-3-4
* 3-1-2-4
* 流程编排、流程可视化
*/
}
