activiti监听器使用

古城微笑少年丶 2022-06-06 14:05 180阅读 0赞

**分享牛原创(尊重原创 转载对的时候第一行请注明，转载出处来自分享牛http://blog.csdn.net/qq\_30739519)**

activiti使用的时候，通常需要跟业务紧密的结合在一起，有些业务非常的复杂，通常有如下一些场景：

1.activiti人员动态的分配。

2.当前任务节点完成的时候，指定需要指定下一个节点的处理人(比如，一个请假流程，a员工请假，需要指定下一步需要处理请假流程的领导。)。

3.任务节点完成的时候，需要一些复杂业务，(比如当前节点完成的时候，需要调用我们的jms消息系统发送消息)。

4.任务流转到当前的节点的时候，需要监控当前任务节点的一些信息或者其他的业务信息。

5.当前的任务节点分配处理人的时候，需要触发自定义的一些业务。

6.流程开始结束的时候，需要处理业务信息。

7.经过任务节点的出线，也就是连线的时候，需要触发自定义的业务。

那我们怎么实现以上的这些需求呢？这个时候，我们就需要使用activiti监听器，activiti提供的监听器怎么实现，以及如何触发，这些都需要我们一步步了解。下面就详细的介绍activiti监听器。

从 activiti监听器的使用范围来看，大致分为三种：

1.全局的监听器。

2.连线的监听器。

3.节点的监听器。

下面我们一个个的来看如何使用这些监听器。

### 1.1.1. 全局的监听器 ###

全局监听器主要使用的场景就是监控这个流程的启动和结束。流程开始的时候可以监控，流程结束的时候可以监控，这里说的是流程实例启动结束的监控，并非是流程引擎的启动结束监控。流程引擎的启动结束监控可以参考http://blog.csdn.net/qq\_30739519/article/details/51217614不要混淆了这些概念。

下面我们先定义一个简单的bpmn xml文件看一下如何使用全局的监听器。

全局监听器实现的接口是org.activiti.engine.delegate.ExecutionListener，org.activiti.engine.impl.pvm.delegate.ExecutionListener这个接口新版本已经废弃。

#### 1.1.1.1. ExecutionListener定义 ####

ExecutionListener定义如下：流程实例start、end、take的时候调用。take是监控连线的时候使用的。

\[java\]  [view plain][]  [copy][view plain]

1.  **public** **interface** ExecutionListener **extends** Serializable \{  
2.    String EVENTNAME\_START = "start";  
3.    String EVENTNAME\_END = "end";  
4.    String EVENTNAME\_TAKE = "take";  
5.    **void** notify(DelegateExecution execution) **throws** Exception;  
6.  \}

下面定义一个类监控流程实例的启动监控，看如何使用。

#### 1.1.1.2. 流程图 ####

![Center][]

#### 1.1.1.3. 流程定义xml ####

流程的xml如下所示：

\[html\]  [view plain][]  [copy][view plain]

1.  **<?****xml** version="1.0" encoding="UTF-8"**?>**  
2.  **<****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="daling"**>**  
3.    **<****process** id="daling" name="name\_daling" isExecutable="true" activiti:candidateStarterUsers="a,b,c,d"**>**  
4.      **<****extensionElements****>**  
5.        **<****activiti:executionListener** event="start" class="com.daling.ch1.listener.MyExecutionListener"**>****</****activiti:executionListener****>**  
6.        **<****activiti:executionListener** event="end" class="com.daling.ch1.listener.MyExecutionListener"**>****</****activiti:executionListener****>**  
7.      **</****extensionElements****>**  
8.      **<****startEvent** id="startevent1" name="Start"**>****</****startEvent****>**  
9.      **<****endEvent** id="endevent1" name="End"**>****</****endEvent****>**  
10.     **<****userTask** id="usertask2" name="User Task"**>****</****userTask****>**  
11.     **<****sequenceFlow** id="flow3" sourceRef="startevent1" targetRef="usertask2"**>****</****sequenceFlow****>**  
12.     **<****sequenceFlow** id="flow4" sourceRef="usertask2" targetRef="endevent1"**>****</****sequenceFlow****>**  
13.   **</****process****>**  
14.   **<****bpmndi:BPMNDiagram** id="BPMNDiagram\_daling"**>**  
15.     **<****bpmndi:BPMNPlane** bpmnElement="daling" id="BPMNPlane\_daling"**>**  
16.       **<****bpmndi:BPMNShape** bpmnElement="startevent1" id="BPMNShape\_startevent1"**>**  
17.         **<****omgdc:Bounds** height="35.0" width="35.0" x="120.0" y="110.0"**>****</****omgdc:Bounds****>**  
18.       **</****bpmndi:BPMNShape****>**  
19.       **<****bpmndi:BPMNShape** bpmnElement="endevent1" id="BPMNShape\_endevent1"**>**  
20.         **<****omgdc:Bounds** height="35.0" width="35.0" x="640.0" y="90.0"**>****</****omgdc:Bounds****>**  
21.       **</****bpmndi:BPMNShape****>**  
22.       **<****bpmndi:BPMNShape** bpmnElement="usertask2" id="BPMNShape\_usertask2"**>**  
23.         **<****omgdc:Bounds** height="55.0" width="105.0" x="300.0" y="90.0"**>****</****omgdc:Bounds****>**  
24.       **</****bpmndi:BPMNShape****>**  
25.       **<****bpmndi:BPMNEdge** bpmnElement="flow3" id="BPMNEdge\_flow3"**>**  
26.         **<****omgdi:waypoint** x="155.0" y="127.0"**>****</****omgdi:waypoint****>**  
27.         **<****omgdi:waypoint** x="300.0" y="117.0"**>****</****omgdi:waypoint****>**  
28.       **</****bpmndi:BPMNEdge****>**  
29.       **<****bpmndi:BPMNEdge** bpmnElement="flow4" id="BPMNEdge\_flow4"**>**  
30.         **<****omgdi:waypoint** x="405.0" y="117.0"**>****</****omgdi:waypoint****>**  
31.         **<****omgdi:waypoint** x="640.0" y="107.0"**>****</****omgdi:waypoint****>**  
32.       **</****bpmndi:BPMNEdge****>**  
33.     **</****bpmndi:BPMNPlane****>**  
34.   **</****bpmndi:BPMNDiagram****>**  
35. **</****definitions****>**

#### 1.1.1.4. 监听类 ####

上面我们定义了两个监听器分别指向同一个类com.daling.ch1.listener.MyExecutionListener我们在类中监控事件。

com.daling.ch1.listener.MyExecutionListener类的实现如下所示：

\[java\]  [view plain][]  [copy][view plain]

1.  **package** com.daling.ch1.listener;  
2.  **import** org.activiti.engine.delegate.DelegateExecution;  
3.  **import** org.activiti.engine.delegate.ExecutionListener;  
4.  **public** **class** MyExecutionListener **implements** ExecutionListener \{  
5.  **public** **void** notify(DelegateExecution execution) **throws** Exception \{  
6.  String eventName = execution.getEventName();  
7.  //start  
8.  **if** ("start".equals(eventName)) \{  
9.  System.out.println("start=========");  
10. \}**else** **if** ("end".equals(eventName)) \{  
11. System.out.println("end=========");  
12. \}  
13. \}  
14. \}

#### 1.1.1.5. 开始监控 ####

下面我们部署启动流程看一下效果，部署流程可参考之前的章节，启动流程如下所示：

ProcessInstance processInstance = runtimeService

.startProcessInstanceByKey(key,vars);

我们看一下程序的部分输出如下：

08:34:07.050 \[main\] DEBUG o.a.e.i.h.DefaultHistoryManager - Current history level: AUDIT, level required: ACTIVITY

08:34:07.056 \[main\] DEBUG o.a.e.i.h.DefaultHistoryManager - Current history level: AUDIT, level required: ACTIVITY

08:34:07.057 \[main\] DEBUG o.a.e.i.h.DefaultHistoryManager - Current history level: AUDIT, level required: FULL

start=========

08:34:07.064 \[main\] DEBUG o.a.e.i.p.r.AtomicOperationActivityExecute - ProcessInstance\[107509\] executes Activity(startevent1): org.activiti.engine.impl.bpmn.behavior.NoneStartEventActivityBehavior

08:34:07.064 \[main\] DEBUG o.a.e.i.p.e.J.selectJobsByExecutionId - ooo Using Connection \[com.mysql.jdbc.JDBC4Connection@eeb514\]

08:34:07.064 \[main\] DEBUG o.a.e.i.p.e.J.selectJobsByExecutionId - ==>  Preparing: select \* from ACT\_RU\_JOB J where J.EXECUTION\_ID\_ = ?

可以看出流程实例启动的时候，触发了我们自定义的类中的函数。

#### 1.1.1.6. 结束监控 ####

下面我们把usertask的任务结束，然后流程实例结束，看看触发了我们自定义的类中的end没有。

String taskId="107515";

demo.getTaskService().complete(taskId);

我们看一下程序的部分输出如下：

08:39:22.016 \[main\] DEBUG o.a.e.i.p.r.AtomicOperationActivityExecute - ProcessInstance\[107509\] executes Activity(endevent1): org.activiti.engine.impl.bpmn.behavior.NoneEndEventActivityBehavior

08:39:22.016 \[main\] DEBUG o.a.e.i.h.DefaultHistoryManager - Current history level: AUDIT, level required: ACTIVITY

end=========

#### 1.1.1.7. DelegateExecution类 ####

在上面的全局监听器中我们可以拿到DelegateExecution对象，这个对象可以让我们操作activiti引擎中的一些东西，下面看一下DelegateExecution类中的定义。

DelegateExecution类图如下：

![Center 1][]

启动最常用的方法如下：

\[java\]  [view plain][]  [copy][view plain]

1.  /\*\* execution Id \*/  
2.    String getId();  
3.     
4.    /\*\*  流程实例id\*/  
5.    String getProcessInstanceId();  
6.     
7.    /\*\* 这个比较有用 主要就是start、end、take  \*/  
8.    String getEventName();  
9.      
10.   /\*\* 
11.    \*  业务id已经废弃 
12.    \*/  
13.   String getBusinessKey();  
14.     
15.   /\*\* 
16.    \* 业务id   \*/  
17.   String getProcessBusinessKey();  
18.     
19.   /\*\* 
20.    \* 流程定义id 
21.    \*/  
22.   String getProcessDefinitionId();  
23.     
24.   /\*\* 
25.    \* 获取父id，并发的时候有用 
26.    \*/  
27.   String getParentId();  
28.     
29.   /\*\* 
30.    \* 获取当前的.Activityid 
31.    \*/  
32.   String getCurrentActivityId();  
33.     
34.   /\*\* 
35.    \* 获取当前的.Activity name 
36.    \*/  
37.   String getCurrentActivityName();  
38.     
39.   /\*\* 
40.    \* 获取TenantId 当有多个TenantId 有用 
41.    \*/  
42.   String getTenantId();  
43.     
44.   /\*\* 
45.    \* 这个非常有用吧。当拿到EngineServices 对象所有的xxxService都可以拿到。 
46.    \*/  
47.   EngineServices getEngineServices();

### 1.1.2. 连线监听器 ###

当节点结束的时候，经过连线的时候，我们可以在线上定义类，实现自己的业务逻辑。连线监听器怎么实现呢？

这里为了方便测试，我们还是采用上面全局监听器中的流程图，下面我们自定义一个连线监听器类，看看如何使用，可以拿到什么对象。

#### 1.1.2.1. 流程图 ####

![Center 2][]

#### 1.1.2.2. 流程定义xml ####

\[html\]  [view plain][]  [copy][view plain]

1.  **<?****xml** version="1.0" encoding="UTF-8"**?>**  
2.  **<****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="daling"**>**  
3.    **<****process** id="daling" name="name\_daling" isExecutable="true" activiti:candidateStarterUsers="a,b,c,d"**>**  
4.      **<****extensionElements****>**  
5.        **<****activiti:executionListener** event="start" class="com.daling.ch1.listener.MyExecutionListener"**>****</****activiti:executionListener****>**  
6.        **<****activiti:executionListener** event="end" class="com.daling.ch1.listener.MyExecutionListener"**>****</****activiti:executionListener****>**  
7.      **</****extensionElements****>**  
8.      **<****startEvent** id="startevent1" name="Start"**>****</****startEvent****>**  
9.      **<****endEvent** id="endevent1" name="End"**>****</****endEvent****>**  
10.     **<****userTask** id="usertask2" name="User Task"**>****</****userTask****>**  
11.     **<****sequenceFlow** id="flow3" name="flow3" sourceRef="startevent1" targetRef="usertask2"**>**  
12.       **<****extensionElements****>**  
13.         **<****activiti:executionListener** event="take" class="com.daling.ch1.listener.MyExecutionListener"**>****</****activiti:executionListener****>**  
14.       **</****extensionElements****>**  
15.     **</****sequenceFlow****>**  
16.     **<****sequenceFlow** id="flow4" sourceRef="usertask2" targetRef="endevent1"**>****</****sequenceFlow****>**  
17.   **</****process****>**  
18.   **<****bpmndi:BPMNDiagram** id="BPMNDiagram\_daling"**>**  
19.     **<****bpmndi:BPMNPlane** bpmnElement="daling" id="BPMNPlane\_daling"**>**  
20.       **<****bpmndi:BPMNShape** bpmnElement="startevent1" id="BPMNShape\_startevent1"**>**  
21.         **<****omgdc:Bounds** height="35.0" width="35.0" x="120.0" y="110.0"**>****</****omgdc:Bounds****>**  
22.       **</****bpmndi:BPMNShape****>**  
23.       **<****bpmndi:BPMNShape** bpmnElement="endevent1" id="BPMNShape\_endevent1"**>**  
24.         **<****omgdc:Bounds** height="35.0" width="35.0" x="640.0" y="90.0"**>****</****omgdc:Bounds****>**  
25.       **</****bpmndi:BPMNShape****>**  
26.       **<****bpmndi:BPMNShape** bpmnElement="usertask2" id="BPMNShape\_usertask2"**>**  
27.         **<****omgdc:Bounds** height="55.0" width="105.0" x="300.0" y="90.0"**>****</****omgdc:Bounds****>**  
28.       **</****bpmndi:BPMNShape****>**  
29.       **<****bpmndi:BPMNEdge** bpmnElement="flow3" id="BPMNEdge\_flow3"**>**  
30.         **<****omgdi:waypoint** x="155.0" y="127.0"**>****</****omgdi:waypoint****>**  
31.         **<****omgdi:waypoint** x="300.0" y="117.0"**>****</****omgdi:waypoint****>**  
32.         **<****bpmndi:BPMNLabel****>**  
33.           **<****omgdc:Bounds** height="14.0" width="100.0" x="155.0" y="127.0"**>****</****omgdc:Bounds****>**  
34.         **</****bpmndi:BPMNLabel****>**  
35.       **</****bpmndi:BPMNEdge****>**ss  
36.       **<****bpmndi:BPMNEdge** bpmnElement="flow4" id="BPMNEdge\_flow4"**>**  
37.         **<****omgdi:waypoint** x="405.0" y="117.0"**>****</****omgdi:waypoint****>**  
38.         **<****omgdi:waypoint** x="640.0" y="107.0"**>****</****omgdi:waypoint****>**  
39.       **</****bpmndi:BPMNEdge****>**  
40.     **</****bpmndi:BPMNPlane****>**  
41.   **</****bpmndi:BPMNDiagram****>**  
42. **</****definitions****>**

#### 1.1.2.3. 监听类 ####

上面我们定义了一个监听器com.daling.ch1.listener.MyExecutionListener类中监控事件。

\[java\]  [view plain][]  [copy][view plain]

1.  **public** **class** MyExecutionListener **implements** ExecutionListener \{  
2.  /\*\* 
3.   \* 
4.   \*/  
5.  **private** **static** **final** **long** serialVersionUID = 7960387497099642910L;  
6.  //ExecutionListener类的实现  
7.  **public** **void** notify(DelegateExecution execution) **throws** Exception \{  
8.  String eventName = execution.getEventName();  
9.  //start  
10. **if** ("start".equals(eventName)) \{  
11. System.out.println("start=========");  
12. \}**else** **if** ("end".equals(eventName)) \{  
13. System.out.println("end=========");  
14. \}  
15. **else** **if** ("take".equals(eventName)) \{  
16. System.out.println("take=========");  
17. \}  
18. \}  
19. \}

因为我们在flow3中定义的监听类，所以流程经过flow3的时候触发定义的take中的自定义事件。

### 1.1.3. 节点监听器 ###

#### 1.1.3.1. 节点监听器定义 ####

在实际项目开发中，任务节点是经常用到的，所以我们必须要会使用节点监听器。

节点监听器的定义接口org.activiti.engine.delegate.TaskListener，org.activiti.engine.impl.pvm.delegate.TaskListener已经废弃不用。

TaskListener类的定义如下所示：

\[java\]  [view plain][]  [copy][view plain]

1.  String EVENTNAME\_CREATE = "create";  
2.  String EVENTNAME\_ASSIGNMENT = "assignment";  
3.  String EVENTNAME\_COMPLETE = "complete";  
4.  String EVENTNAME\_DELETE = "delete";  
5.  /\*\* 
6.   \* Not an actual event, used as a marker-value for \{@link TaskListener\}s that should be called for all events, 
7.   \* including \{@link \#EVENTNAME\_CREATE\}, \{@link \#EVENTNAME\_ASSIGNMENT\} and \{@link \#EVENTNAME\_COMPLETE\} and \{@link \#EVENTNAME\_DELETE\}. 
8.   \*/  
9.  String EVENTNAME\_ALL\_EVENTS = "all";  
10.   
11. **void** notify(DelegateTask delegateTask);

#### 1.1.3.2. 节点监听器类图 ####

节点监听器的子类如下图所示：

![Center 3][]

下面开始我们详细的使用吧。首先还是定义一个xml，xml流程还是上面所示的，只是多了一些任务节点的监听。

#### 1.1.3.3. 流程图 ####

![Center 4][]

#### 1.1.3.4. 流程定义xml ####

流程的xml如下所示：

\[html\]  [view plain][]  [copy][view plain]

1.  **<?****xml** version="1.0" encoding="UTF-8"**?>**  
2.  **<****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="daling"**>**  
3.    **<****process** id="daling" name="name\_daling" isExecutable="true" activiti:candidateStarterUsers="a,b,c,d"**>**  
4.      **<****extensionElements****>**  
5.        **<****activiti:executionListener** event="start" class="com.daling.ch1.listener.MyExecutionListener"**>****</****activiti:executionListener****>**  
6.        **<****activiti:executionListener** event="end" class="com.daling.ch1.listener.MyExecutionListener"**>****</****activiti:executionListener****>**  
7.      **</****extensionElements****>**  
8.      **<****startEvent** id="startevent1" name="Start"**>****</****startEvent****>**  
9.      **<****endEvent** id="endevent1" name="End"**>****</****endEvent****>**  
10.     **<****userTask** id="usertask2" name="User Task" activiti:assignee="c"**>**  
11.       **<****extensionElements****>**  
12.         **<****activiti:taskListener** event="all" class="com.daling.ch1.listener.MyExecutionListener"**>****</****activiti:taskListener****>**  
13.       **</****extensionElements****>**  
14.     **</****userTask****>**  
15.     **<****sequenceFlow** id="flow3" name="flow3" sourceRef="startevent1" targetRef="usertask2"**>**  
16.       **<****extensionElements****>**  
17.         **<****activiti:executionListener** event="take" class="com.daling.ch1.listener.MyExecutionListener"**>****</****activiti:executionListener****>**  
18.       **</****extensionElements****>**  
19.     **</****sequenceFlow****>**  
20.     **<****sequenceFlow** id="flow4" sourceRef="usertask2" targetRef="endevent1"**>****</****sequenceFlow****>**  
21.   **</****process****>**  
22.   **<****bpmndi:BPMNDiagram** id="BPMNDiagram\_daling"**>**  
23.     **<****bpmndi:BPMNPlane** bpmnElement="daling" id="BPMNPlane\_daling"**>**  
24.       **<****bpmndi:BPMNShape** bpmnElement="startevent1" id="BPMNShape\_startevent1"**>**  
25.         **<****omgdc:Bounds** height="35.0" width="35.0" x="120.0" y="110.0"**>****</****omgdc:Bounds****>**  
26.       **</****bpmndi:BPMNShape****>**  
27.       **<****bpmndi:BPMNShape** bpmnElement="endevent1" id="BPMNShape\_endevent1"**>**  
28.         **<****omgdc:Bounds** height="35.0" width="35.0" x="640.0" y="90.0"**>****</****omgdc:Bounds****>**  
29.       **</****bpmndi:BPMNShape****>**  
30.       **<****bpmndi:BPMNShape** bpmnElement="usertask2" id="BPMNShape\_usertask2"**>**  
31.         **<****omgdc:Bounds** height="55.0" width="105.0" x="300.0" y="90.0"**>****</****omgdc:Bounds****>**  
32.       **</****bpmndi:BPMNShape****>**  
33.       **<****bpmndi:BPMNEdge** bpmnElement="flow3" id="BPMNEdge\_flow3"**>**  
34.         **<****omgdi:waypoint** x="155.0" y="127.0"**>****</****omgdi:waypoint****>**  
35.         **<****omgdi:waypoint** x="300.0" y="117.0"**>****</****omgdi:waypoint****>**  
36.         **<****bpmndi:BPMNLabel****>**  
37.           **<****omgdc:Bounds** height="14.0" width="100.0" x="155.0" y="127.0"**>****</****omgdc:Bounds****>**  
38.         **</****bpmndi:BPMNLabel****>**  
39.       **</****bpmndi:BPMNEdge****>**  
40.       **<****bpmndi:BPMNEdge** bpmnElement="flow4" id="BPMNEdge\_flow4"**>**  
41.         **<****omgdi:waypoint** x="405.0" y="117.0"**>****</****omgdi:waypoint****>**  
42.         **<****omgdi:waypoint** x="640.0" y="107.0"**>****</****omgdi:waypoint****>**  
43.       **</****bpmndi:BPMNEdge****>**  
44.     **</****bpmndi:BPMNPlane****>**  
45.   **</****bpmndi:BPMNDiagram****>**  
46. **</****definitions****>**

#### 1.1.3.5. 监听类 ####

任务节点的监听只要实现TaskListener接口即可。下面是任务监听的实现类，如下所示：

\[java\]  [view plain][]  [copy][view plain]

1.  **public** **class** MyExecutionListener **implements** ExecutionListener,TaskListener \{  
2.  /\*\* 
3.   \* 
4.   \*/  
5.  **private** **static** **final** **long** serialVersionUID = 7960387497099642910L;  
6.  //ExecutionListener类的实现  
7.  **public** **void** notify(DelegateExecution execution) **throws** Exception \{  
8.  String eventName = execution.getEventName();  
9.  //start  
10. **if** ("start".equals(eventName)) \{  
11. System.out.println("start=========");  
12. \}**else** **if** ("end".equals(eventName)) \{  
13. System.out.println("end=========");  
14. \}  
15. **else** **if** ("take".equals(eventName)) \{  
16. System.out.println("take=========");  
17. \}  
18. \}  
19. //实现TaskListener中的方法  
20. **public** **void** notify(DelegateTask delegateTask) \{  
21. String eventName = delegateTask.getEventName();  
22. **if** ("create".endsWith(eventName)) \{  
23. System.out.println("create=========");  
24. \}**else** **if** ("assignment".endsWith(eventName)) \{  
25. System.out.println("assignment========");  
26. \}**else** **if** ("complete".endsWith(eventName)) \{  
27. System.out.println("complete===========");  
28. \}**else** **if** ("delete".endsWith(eventName)) \{  
29. System.out.println("delete=============");  
30. \}  
31. \}  
32. \}

当流程运转到usertask2我们看一下程序的输出：

assignment========

create=========

因为usertask2节点配置了处理人所以触发assignment事件监听，当任务运转到usertask2的时候触发了create事件。

这里我们也可以得出一个结论：assignment事件比create先执行。

使用代码结束任务，代码如下：

String taskId="127515";

demo.getTaskService().complete(taskId);

当我们结束usertask2我们看一下程序的输出：

complete===========

delete=============

在这里我们可以得出结论：

任务完成的时候，触发complete事件，因为任务完成之后，要从ACT\_RU\_TASK中删除这条记录，所以触发delete事件。

#### 1.1.3.6. DelegateTask类 ####

在上面的任务监听器中我们可以拿到DelegateTask对象，这个对象可以让我们操作activiti引擎中的一些东西，下面看一下DelegateTask类中的定义主要访法。

\[java\]  [view plain][]  [copy][view plain]

1.  **public** **interface** DelegateTask **extends** VariableScope \{  
2.    /\*\* 数据库中的taskId主键\*/  
3.    String getId();  
4.      
5.    /\*\* 任务名称 \*/  
6.    String getName();  
7.      
8.    /\*\* 修改任务名称 \*/  
9.    **void** setName(String name);  
10.    
11.   /\*\* 获取任务的描述信息 \*/  
12.   String getDescription();  
13.     
14.   /\*\* 修改任务的描述信息 \*/  
15.   **void** setDescription(String description);  
16.     
17.   /\*\* 
18.    \* lower priority: \[0..19\] lowest, \[20..39\] low, \[40..59\] normal, \[60..79\] high 
19.    \* \[80..100\] highest 
20. 任务处理的优先级范围是0-100 
21. \*/  
22.   **int** getPriority();  
23.     
24.   /\*\* 修改优先级\*/  
25.   **void** setPriority(**int** priority);  
26.     
27.   /\*\* 获取流程实例id \*/  
28.   String getProcessInstanceId();  
29.     
30.   /\*\*获取执行id\*/  
31.   String getExecutionId();  
32.     
33.   /\*\* 获取流程定义id\*/  
34.   String getProcessDefinitionId();  
35.   /\*\* Adds the given user as a candidate user to this task. \*/  
36.   **void** addCandidateUser(String userId);  
37.     
38.   /\*\* 添加候选人 \*/  
39.   **void** addCandidateUsers(Collection<String> candidateUsers);  
40.     
41.   /\*\* 添加候选组 \*/  
42.   **void** addCandidateGroup(String groupId);  
43. \}

上面我们总结了，全局监听器、连线、任务节点的使用，下面我们看一下共性的东西再做一次总结。

### 1.1.4. 其他的使用方式 ###

#### 1.1.4.1. spring整合 ####

上面我们在定义类的的时候，我们直接使用的类定义的方式，当然我们还可以跟sring整合使用，因为在实际项目中类的管理可能交给spring容器。使用也很简单如下图所示：

![Center 5][]

需要填写的表达书，只需要使用spring方式注入即可，$\{\}里面的值为需要使用的bean在spring中的id.可以xml定义或者在注解中定义。注解中定义需要开启spring包扫描机制。比如我的@Service("myExecutionListener")。

### 1.1.5. 小结 ###

1.activiti监听方式分为三大类，节点监听、全局监听、连线监听。

2.activiti监听主要实现的类是两个 节点监听、全局监听实现org.activiti.engine.delegate.ExecutionListener

节点的监听实现org.activiti.engine.delegate.TaskListener接口即可。

3.监听器其实就是一个观察者模式。(关于观察者模式，我们后续章节讲解，限于篇幅有限)

4.监听器获取spring对象，如何获取spring中的bean呢？

### 1.1.6. 遗留点 ###

5.监听器关于观察者模式，我们后续章节讲解。

6.监听器获取spring对象，如何获取spring中的bean呢？留到下一个章节讲解吧。

*  本文已收录于以下专栏：
 *  [activiti工作流敏捷开发][activiti]

[view plain]: http://blog.csdn.net/qq_30739519/article/details/51258447#
[Center]: /images/20220606/029ec48f2b8e4aee9df45e70c0228bc9.png
[Center 1]: /images/20220606/5b9b26d216a84be3bc5cda2982c46d7d.png
[Center 2]: /images/20220606/ed1b7c6489324d7f88e62137fdef930f.png
[Center 3]: /images/20220606/2cfecb9918c3447a87b06f6b8bbbf49a.png
[Center 4]: /images/20220606/610aa443fefd49309d564413aab49326.png
[Center 5]: /images/20220606/a471b04535c143d789b6e6bbfa3b174c.png
[activiti]: http://blog.csdn.net/column/details/activitishareniu.html