Activity学习笔记

墨蓝 2022-12-01 14:11 177阅读 0赞

## Activiti表前缀 ##

Activiti的后台是有数据库的支持，所有的表都以ACT\_开头。 第二部分是表示表的用途的两个字母标识。 用途也和服务的API对应。  
ACT\_RE\_*: 'RE’表示repository。 这个前缀的表包含了流程定义和流程静态资源 （图片，规则，等等）。  
ACT\_RU\_*: 'RU’表示runtime。 这些运行时的表，包含流程实例，任务，变量，异步任务，等运行中的数据。 Activiti只在流程实例执行过程中保存这些数据， 在流程结束时就会删除这些记录。 这样运行时表可以一直很小速度很快。  
ACT\_ID\_*: 'ID’表示identity。 这些表包含身份信息，比如用户，组等等。  
ACT\_HI\_*: 'HI’表示history。 这些表包含历史数据，比如历史流程实例， 变量，任务等等。  
ACT\_GE\_\*: 通用数据， 用于不同场景下，如存放资源文件，act\_ge\_bytearray 通用字节资源表；act\_ge\_property 通用属性表，可以生成部署id。  
– 流程实例与任务

SELECT * FROM act_ru_execution  # 流程执行对象信息
    SELECT * FROM act_ru_task   # 正在运行的任务表
    SELECT * FROM act_hi_procinst # 历史流程实例表
    SELECT * FROM act_hi_taskinst  # 历史流程任务表

流程实例与流程对象的区别：  
1 如果是单例流程，执行对象ID就是流程实例ID  
2 如果一个流程有分支和聚合，那么执行对象ID和流程实例ID就不相同  
3 一个流程中，流程实例只有1个，执行对象可以存在多个。

## Activiti-Explorer中设计的流程图保存到哪里去了？ ##

流程设计器设计流程后，保存数据到ACT\_RE\_MODEL 表。  
EDITOR\_SOURCE\_VALUE\_ID（流程文件放在ACT\_GE\_BYTEARRAY中的ID）；  
EDITOR\_SOURCE\_EXTRA\_VALUE\_ID(流程文件图像放在ACT\_GE\_BYTEARRAY中的ID)

ACT\_GE\_BYTEARRAY表保存了PNG图片和xml文件信息(其实是json格式的字符串)，并关联到ACT\_RE\_MODEL表。  
ACT\_GE\_BYTEARRAY表中NAME\_列值source-extra行中存储的是：PNG图片  
ACT\_GE\_BYTEARRAY表中NAME\_列值source行中存储的是：xml文件信息

## 1 TaskListener 与 ExecutionListener ##

当流程途径连线或者节点的时候，会触发对应的事件类型。TaskListener(任务监听器)与ExecutionListener(执行监听器)在生产中经常会用在几个方面：

*  动态分配节点处理人。通过前一个节点设置的变量，在运行到下一个节点时设置对应的处理人；
 *  当流程运行到某个节点时，发送邮件或短信给待办用户；
 *  统计流程处理时长，是否超时等；
 *  业务层面数据处理。

**TaskListener** 顾名思义是监听任务的。任务监听器的生命周期如下图所示，会经历assignment、create、complete、delete。当流程引擎触发这四种事件类型时，对应的任务监听器会捕获其事件类型，再按照监听器的处理逻辑进行处理。  
![在这里插入图片描述][2020082714434612.png_pic_center]**ExecutionListener** 则监听流程的所有节点和连线。主要有start、end、take事件。其中节点有start、end两种事件，而连线则有take事件。下图是执行监听器的生命周期：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2pvaG5ueV9uaXU_size_16_color_FFFFFF_t_70_pic_center]**TaskListener代码：**

package listener;
     
    import org.activiti.engine.delegate.DelegateTask;
    import org.activiti.engine.delegate.TaskListener;
     
    public class MyTaskListener implements TaskListener{
        
     
    	public void notify(DelegateTask delegateTask) {
        
    		System.out.println("============TaskListener start============");
    		String taskDefinitionKey = delegateTask.getTaskDefinitionKey();
    		String eventName = delegateTask.getEventName();
    		System.out.println("事件名称:" + eventName);
    		System.out.println("taskDefinitionKey:" + taskDefinitionKey);
    		System.out.println("============TaskListener end============");
    	}
    }

自定义任务监听器需要实现TaskListener接口，并且实现notify方法。这里我们打印对应的事件和任务节点键值（即bpmn图里userTask的id）。

**ExecutionListener代码**

package listener;
     
    import org.activiti.engine.delegate.DelegateExecution;
    import org.activiti.engine.delegate.ExecutionListener;
     
    public class MyExecutionListener implements ExecutionListener {
        
     
    	public void notify(DelegateExecution execution) throws Exception {
        
    		System.out.println("============executionListener start============");
    		String eventName = execution.getEventName();
    		String currentActivitiId = execution.getCurrentActivityId();
    		System.out.println("事件名称:" + eventName);
    		System.out.println("ActivitiId:" + currentActivitiId);
    		System.out.println("============executionListener  end============");
    	}
    }

自定义执行监听器需要实现ExecutionListener接口，并且实现notify方法。这里我们打印对应的事件和活动节点id。

之后新建一个bpmn图：

<?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="listenerBpmProcess" name="My process" isExecutable="true">
        <startEvent id="startevent1" name="Start"></startEvent>
        <userTask id="usertask1" name="myTask1" activiti:assignee="张三">
          <extensionElements>
            <activiti:executionListener event="start" class="listener.MyExecutionListener"></activiti:executionListener>
            <activiti:executionListener event="end" class="listener.MyExecutionListener"></activiti:executionListener>
            <activiti:taskListener event="all" class="listener.MyTaskListener"></activiti:taskListener>
          </extensionElements>
        </userTask>
        <endEvent id="endevent1" name="End"></endEvent>
        <sequenceFlow id="flow1" sourceRef="startevent1" targetRef="usertask1"></sequenceFlow>
        <sequenceFlow id="flow2" sourceRef="usertask1" targetRef="endevent1"></sequenceFlow>
      </process>
      <bpmndi:BPMNDiagram id="BPMNDiagram_listenerBpmProcess">
        <bpmndi:BPMNPlane bpmnElement="listenerBpmProcess" id="BPMNPlane_listenerBpmProcess">
          <bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">
            <omgdc:Bounds height="41.0" width="35.0" x="505.0" y="40.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="usertask1" id="BPMNShape_usertask1">
            <omgdc:Bounds height="55.0" width="105.0" x="470.0" y="150.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">
            <omgdc:Bounds height="35.0" width="35.0" x="505.0" y="240.0"></omgdc:Bounds>
          </bpmndi:BPMNShape>
          <bpmndi:BPMNEdge bpmnElement="flow1" id="BPMNEdge_flow1">
            <omgdi:waypoint x="522.0" y="81.0"></omgdi:waypoint>
            <omgdi:waypoint x="522.0" y="150.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
          <bpmndi:BPMNEdge bpmnElement="flow2" id="BPMNEdge_flow2">
            <omgdi:waypoint x="522.0" y="205.0"></omgdi:waypoint>
            <omgdi:waypoint x="522.0" y="240.0"></omgdi:waypoint>
          </bpmndi:BPMNEdge>
        </bpmndi:BPMNPlane>
      </bpmndi:BPMNDiagram>
    </definitions>

这里我们给userTask1添加了执行监听器和任务监听器。部署bpmn图后，我们观察流程运转时监听器的触发时机和作用，启动流程：

public void startProcessById() {
        
        RuntimeService runtimeService = pe.getRuntimeService();
        ProcessInstance pi = runtimeService.startProcessInstanceById("listenerBpmProcess:1:4");
    }

流程启动后，从开始节点运转到userTask1节点，观察控制台输出：

============executionListener start============
    事件名称:start
    ActivitiId:usertask1
    ============executionListener  end============
    ============TaskListener start============
    事件名称:assignment
    taskDefinitionKey:usertask1
    ============TaskListener end============
    ============TaskListener start============
    事件名称:create
    taskDefinitionKey:usertask1
    ============TaskListener end============

可以看到流程走到userTask1节点时，首先触发start事件，调用我们自定义的执行监听器，随后触发assignment和create事件，执行自定义任务监听器的内容。注意这里是先触发assignment进行人员分配，再触发create事件，与一般的认知有些差异。

接下来通过taskService的complete方法完成userTask1节点上流程的提交，观察控制台输出：

============TaskListener start============
    事件名称:complete
    taskDefinitionKey:usertask1
    ============TaskListener end============
    ============TaskListener start============
    事件名称:delete
    taskDefinitionKey:usertask1
    ============TaskListener end============
    ============executionListener start============
    事件名称:end
    ActivitiId:usertask1
    ============executionListener  end============

可以看到userTask1节点提交的时候，首先触发complete事件再触发delete事件，最后触发end事件。

以上就是执行监听器与任务监听器的基本使用方式。实际工程中，由于流程节点十分多，并且流程和业务常常需要进行微调，通常是不会在bpmn图上逐个节点添加监听器的，往往是在解析bpmn对象期间利用对象解析器动态添加监听器。这里涉及的原理比较复杂，留到后面的文章再讨论。

[2020082714434612.png_pic_center]: /images/20221123/b488496db2ba4539aacdf1bf0b36a1ed.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2pvaG5ueV9uaXU_size_16_color_FFFFFF_t_70_pic_center]: /images/20221123/2eabbfc234474ed5b2f5018bfcc96ba3.png