Activiti7工作原理

工作原理"/>

Activiti7工作原理

Java Activiti是一个开源的工作流引擎，用于管理和执行业务流程。
它是基于BPMN 2.0标准的，提供了丰富的功能和灵活性。

Java Activiti的工作原理如下：

1.Java Activiti 流程建模

使用BPMN 2.0标准的图形化编辑器，可以创建和定义业务流程模型。这些模型描述了流程中的各个任务、活动、网关、事件等。
使用工具：
InteliJ IDEA 插件：Activiti BPMN visualizer

使用方法参考：

插件安装后，新建文件，画流程图：

注意上面的四个参数，后面会用于定位这个节点。

2. Java Activiti 流程部署

将流程模型部署到Activiti引擎中，引擎会解析和存储流程定义相关的信息，包括流程图、任务分配、表单等。
流程部署核心代码：

@Autowiredprivate ProcessEngine processEngine;public static final String processDefinitionKey = "fbr_1";public static final String resourceFilePath = "/process/fbr_1.bpmn20.xml";public static final String resourceName = "fbr_1.bpmn20.xml";@GetMapping("/deploy")public ApiResult create() {InputStream inputStream = ResourceFileUtils.loadFile(resourceFilePath);// 获取流程定义和部署对象相关的ServiceRepositoryService repositoryService = processEngine.getRepositoryService();// 创建部署对象Deployment deployment = repositoryService.createDeployment().name("Build FBR Request Process")// 声明流程的名称.addInputStream(resourceName, inputStream)// 加载资源文件，一次只能加载一个文件.deploy();// 完成部署//4.输出部署的一些信息System.out.println(deployment.getId());System.out.println(deployment.getName());return ApiResult.ok();}

部署后，会在三张元数据表中写入数据：

-- 部署信息 
-- id关联 下面两张表
select * from ACT_RE_DEPLOYMENT where name_ ='Build FBR Request Process'  order by deploy_time_ desc;
-- 流程元数据：含流程图等字段 
-- deploy_id_ 关联
select * from ACT_GE_BYTEARRAY where name_ ='fbr_1.bpmn20.xml';
-- 流程定义数据
-- deploy_id_ 关联
select * from ACT_RE_PROCDEF where key_ ='fbr_1';

这三张表的元数据，会始终保存，不同于下面会讲到的四张表实例数据表，流程最终完成后，所有实例数据会清除掉。

3. Java Activiti 流程实例化（启动流程）

通过Activiti引擎，可以根据已部署的流程定义创建流程实例。每个流程实例代表了一个具体的业务流程执行过程。
启动流程时，流程会处于第一个结点（开始结点后的第一个结点），想要获取节点信息，需要通过该节点配置的属性进行查询；
启动流程核心代码：

    @GetMapping("/start")public ApiResult start(@RequestParam("assingee") String assingee) {TaskService taskService = processEngine.getTaskService();RuntimeService runtimeService = processEngine.getRuntimeService();Map<String, Object> param = new HashMap<>();param.put("submitter", assingee);// 流程必须要有发起人，否则会报错提示；// 一般同流程文件名称ProcessInstance processInstance = runtimeService.startProcessInstanceByKey(processDefinitionKey, param);//4.输出实例的相关信息System.out.println("流程部署id:" + processInstance.getDeploymentId());//nullSystem.out.println("流程定义id:" + processInstance.getProcessDefinitionId());//fbr_1:2:5f8494b9-7a0a-11ee-b0d9-4e796eddc638System.out.println("流程实例id:" + processInstance.getId());//e464157a-7a0a-11ee-b0d9-4e796eddc638System.out.println("流程活动id:" + processInstance.getActivityId());//nullreturn ApiResult.ok();}

流程启动后，会在四张数据表中写入第一个结点的数据：

-- 流程任务表，
-- ACT_RU_TASK.proc_def_id=ACT_RE_PROCDEF.id
-- proc_inst_id 根节点 实列 id,结点变换也会一直不变，只会改变 name等字段
select * from ACT_RU_TASK where proc_def_id_ ='fbr_1:2:5f8494b9-7a0a-11ee-b0d9-4e796eddc638' order by create_time_ desc;-- 实例表，是一个维表，
select *  from ACT_RU_EXECUTION 
where proc_def_id_ ='fbr_1:2:5f8494b9-7a0a-11ee-b0d9-4e796eddc638' 
and root_proc_inst_id_ ='e464157a-7a0a-11ee-b0d9-4e796eddc638'
order by start_time_ desc;-- user表
-- 同 ACT_RU_IDENTITYLINK.TASK_ID_=ACT_RU_EXECUTION.id 关联
select *  from ACT_RU_IDENTITYLINK 
where 1=1
and (proc_inst_id_ ='e464157a-7a0a-11ee-b0d9-4e796eddc638'
or task_id_ ='e480c53d-7a0a-11ee-b0d9-4e796eddc638'
)
-- 运行时变量；
-- 同流程任务表 ACT_RU_TASK.proc_inst_id 关联，
select * from ACT_RU_VARIABLE  
where proc_inst_id_ ='e464157a-7a0a-11ee-b0d9-4e796eddc638'

4. Java Activiti 任务分配（获取结点任务）

根据流程定义中定义的任务分配规则，Activiti引擎会将任务分配给相应的参与者或角色。参与者可以是用户、组织或其他参与者。

核心代码：

    @GetMapping("/getTaskList")public void getTaskList(@RequestParam("assignee") String assignee) {//1.得到ProcessEngine对象//2.得到TaskService对象TaskService taskService = processEngine.getTaskService();//3.根据流程定义的key,负责人assignee来实现当前用户的任务列表查询//获取任务集合 （ACT_RU_TASK 数据，task.getId等所有数据皆属于该表字段）List<Task> taskList = taskService.createTaskQuery().processDefinitionKey(processDefinitionKey)// 指定流程id.processDefinitionName("fbr_1")// 指定流程名称.taskCandidateUser(assignee)// 指定接收人.taskName("提交请假申请")// 指定结点name.list();for (Task task : taskList) {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());System.out.println("#########################################################");}}

assignee 只代表一种参数，taskCandidateUser也只代表一种查询方式，
具体需要根据流程图的配置字段来。

核心 SQL 语句：

 selectdistinct RES.*
fromACT_RU_TASK RES
inner join ACT_RU_IDENTITYLINK I onI.TASK_ID_ = RES.ID_
inner join ACT_RE_PROCDEF D onRES.PROC_DEF_ID_ = D.ID_
whereRES.NAME_ = '提交请假申请'and D.KEY_ = 'fbr_1'and D.NAME_ = 'fbr_1'and RES.ASSIGNEE_ is nulland I.TYPE_ = 'candidate'and ( I.USER_ID_ = 'leiming5'or I.GROUP_ID_ in ('activitiTeam') )
order byRES.ID_ asc

5. 任务执行（让任务动起来）

参与者可以通过Activiti引擎完成分配给他们的任务。任务可以包括用户任务、服务任务、脚本任务等。

执行任务就是完成当前结点的任务，流程进入下一个节点，
这里需要将下个节点的数据（也可以是数据id，不存放具体数据）和审批人传入；使得下个节点的审批人能收到

核心代码：

    @GetMapping("/complete")public ApiResult complete(@RequestParam("assignee") String assignee) {TaskService taskService = processEngine.getTaskService();List<Task> taskList = taskService.createTaskQuery().processDefinitionKey(processDefinitionKey)// 指定流程id.processDefinitionName("fbr_1")// 指定流程名称.taskCandidateUser(assignee)// 指定接收人.taskName("提交请假申请")// 指定结点name.list();//4.处理任务,结合当前用户任务列表的查询操作的话,任务ID:task.getId()for (Task task : taskList) {Map<String, Object> param = new HashMap<>();param.put("person_1", "a,b");// 将下个节点的 审批人传入；使得下个节点的审批人能收到；param.put("person_2", "c,d");taskServiceplete(task.getId(), param);//5.输出任务的idSystem.out.println(task.getId());}return ApiResult.ok();}

核心 sql ：

更新第三步中的四张表：删除当前结点的数据，新增下一个结点的数据。
ACT_RU_TASK.proc_inst_id 不会变，只会改变结点的其他属性。

6. 流程控制

在流程执行期间，Activiti引擎会根据流程定义中定义的条件和网关，控制流程的走向和执行顺序。这包括并行网关、排他网关、事件网关等。

7. 监控和管理

Activiti引擎提供了监控和管理工具，可以跟踪和管理流程实例的执行情况，包括任务状态、流程进度、异常处理等。