Activiti5----流程监听器与任务监听器

首先创建流程监听器和任务监听器的实体类，个人比较喜欢使用Delegate Expression方式，其他两种方式也可以


流程监听器

  1. package org.mpc.final_activiti;
  2.  
  3. import java.io.Serializable;
  4.  
  5. import org.activiti.engine.delegate.DelegateExecution;
  6. import org.activiti.engine.delegate.ExecutionListener;
  7. import org.activiti.engine.delegate.Expression;
  8.  
  9. /**
  10.  * 
  11.  * 可以使用 CLASS ,EXPRESSION,DELEGATE EXPRESSSION三种方式来创建监听器，这里使用第三种方式，其他两种方式和
  12.  * 在servicetask中的使用方式相同
  13.  * 
  14.  * */
  15. public class ExectuionListenerDemo implements Serializable, ExecutionListener {
  16.  
  17. 	/**
  18. 	 * @Fields serialVersionUID : TODO(用一句话描述这个变量表示什么)
  19. 	 */
  20. 	private static final long serialVersionUID = 8513750196548027535L;
  21. 	private Expression message;
  22.  
  23. 	public Expression getMessage() {
  24. 		return message;
  25. 	}
  26.  
  27. 	public void setMessage(Expression message) {
  28. 		this.message = message;
  29. 	}
  30.  
  31. 	@Override
  32. 	public void notify(DelegateExecution execution) throws Exception {
  33. 		System.out.println("流程监听器" + message.getValue(execution));
  34. 	}
  35.  
  36. }

任务监听器 

  1. package org.mpc.final_activiti;
  2.  
  3. import java.io.Serializable;
  4.  
  5. import org.activiti.engine.delegate.DelegateTask;
  6. import org.activiti.engine.delegate.Expression;
  7. import org.activiti.engine.delegate.TaskListener;
  8.  
  9. /**
  10.  * 
  11.  * 任务监听器，实现TaskListener接口
  12.  * 
  13.  * */
  14. public class TaskListenerDemo implements Serializable, TaskListener {
  15. 	private Expression arg;
  16.  
  17. 	public Expression getArg() {
  18. 		return arg;
  19. 	}
  20.  
  21. 	public void setArg(Expression arg) {
  22. 		this.arg = arg;
  23. 	}
  24.  
  25. 	@Override
  26. 	public void notify(DelegateTask delegateTask) {
  27. 		System.out.println("任务监听器:" + arg.getValue(delegateTask));
  28. 	}
  29.  
  30. }

这两个监听器只是简单的表明了自己的身份，并打印出在流程中注入给他们的值


接着是流程定义图




从左到右依次是  空开始事件--排他网关--用户任务--空中间抛出事件--空结束事件

首先在空白处点击鼠标，接着在properties选项卡中做如下操作：



然后在排他网关、空中间抛出事件、以及节点之间的箭头上点击鼠标同样可以做如上的操作，这些都流程监听事件的配置



在usertask上我们特别配置usertask才有的任务监听器，配置过程如下图所示



和流程监听器的配置大同小异呢


展示一下配置结果的xml文件，特别注意一下加注释的地方

  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="http://www.activiti.org/test">
  3.   <process id="myProcess" name="My process" isExecutable="true">
  4.     <extensionElements>
  5.       <activiti:executionListener event="start" delegateExpression="${myprocessListener}">
  6.         <activiti:field name="message">
  7.           <activiti:string><![CDATA[流程启动]]></activiti:string>
  8.         </activiti:field>
  9.       </activiti:executionListener>
  10.       <activiti:executionListener event="end" delegateExpression="${myprocessListener}">
  11.         <activiti:field name="message">
  12.           <activiti:string><![CDATA[流程结束]]></activiti:string>
  13.         </activiti:field>
  14.       </activiti:executionListener>
  15.     </extensionElements>
  16.     <startEvent id="startevent1" name="Start"></startEvent>
  17.     <exclusiveGateway id="exclusivegateway1" name="Exclusive Gateway">
  18.       <extensionElements>
  19.         <activiti:executionListener event="start" delegateExpression="${myprocessListener}">
  20.           <activiti:field name="message">
  21.             <activiti:string><![CDATA[排他网关开始]]></activiti:string>
  22.           </activiti:field>
  23.         </activiti:executionListener>
  24.         <activiti:executionListener event="end" delegateExpression="${myprocessListener}">
  25.           <activiti:field name="message">
  26.             <activiti:string><![CDATA[排他网关结束]]></activiti:string>
  27.           </activiti:field>
  28.         </activiti:executionListener>
  29.       </extensionElements>
  30.     </exclusiveGateway>
  31.     <sequenceFlow id="flow3" sourceRef="startevent1" targetRef="exclusivegateway1"></sequenceFlow>
  32.     <userTask id="usertask2" name="User Task" activiti:assignee="${user}">
  33.       <extensionElements>
  34.         <activiti:taskListener event="create" delegateExpression="${mytaskListener}">
  35.           <activiti:field name="arg">
  36.             <activiti:string><![CDATA[任务启动]]></activiti:string>
  37.           </activiti:field>
  38.         </activiti:taskListener>
  39.         <activiti:taskListener event="assignment" delegateExpression="${mytaskListener}">
  40.           <activiti:field name="arg">
  41.             <activiti:string><![CDATA[分配人员]]></activiti:string>
  42.           </activiti:field>
  43.         </activiti:taskListener>
  44.         <activiti:taskListener event="complete" delegateExpression="${mytaskListener}">
  45.           <activiti:field name="arg">
  46.             <activiti:string><![CDATA[任务完成]]></activiti:string>
  47.           </activiti:field>
  48.         </activiti:taskListener>
  49.         <!-- 在可视化工具中无法给usertask加上流程监听器，但是，我们在xml中可以自己敲进去· -->
  50.               <activiti:executionListener event="start" delegateExpression="${myprocessListener}">
  51.           <activiti:field name="message">
  52.             <activiti:string><![CDATA[流程启动任务]]></activiti:string>
  53.           </activiti:field>
  54.         </activiti:executionListener>
  55.         <activiti:executionListener event="end" delegateExpression="${myprocessListener}">
  56.           <activiti:field name="message">
  57.             <activiti:string><![CDATA[流程关闭任务]]></activiti:string>
  58.           </activiti:field>
  59.         </activiti:executionListener>
  60.         <!-- ........................................................................................................................................ -->
  61.       </extensionElements>
  62.     </userTask>
  63.     <sequenceFlow id="flow4" sourceRef="exclusivegateway1" targetRef="usertask2">
  64.       <extensionElements>
  65.         <activiti:executionListener event="take" delegateExpression="${myprocessListener}">
  66.           <activiti:field name="message">
  67.             <activiti:string><![CDATA[从排他网关到用户任务，好长的一段路]]></activiti:string>
  68.           </activiti:field>
  69.         </activiti:executionListener>
  70.       </extensionElements>
  71.     </sequenceFlow>
  72.     <intermediateThrowEvent id="noneintermediatethrowevent1" name="NoneThrowEvent">
  73.       <extensionElements>
  74.         <activiti:executionListener event="start" delegateExpression="${myprocessListener}">
  75.           <activiti:field name="message">
  76.             <activiti:string><![CDATA[中间事件开始]]></activiti:string>
  77.           </activiti:field>
  78.         </activiti:executionListener>
  79.         <activiti:executionListener event="end" delegateExpression="${myprocessListener}">
  80.           <activiti:field name="message">
  81.             <activiti:string><![CDATA[中间事件结束]]></activiti:string>
  82.           </activiti:field>
  83.         </activiti:executionListener>
  84.       </extensionElements>
  85.     </intermediateThrowEvent>
  86.     <sequenceFlow id="flow5" sourceRef="usertask2" targetRef="noneintermediatethrowevent1"></sequenceFlow>
  87.     <endEvent id="endevent1" name="End"></endEvent>
  88.     <sequenceFlow id="flow6" sourceRef="noneintermediatethrowevent1" targetRef="endevent1"></sequenceFlow>
  89.   </process>
  90.   <bpmndi:BPMNDiagram id="BPMNDiagram_myProcess">
  91.     <bpmndi:BPMNPlane bpmnElement="myProcess" id="BPMNPlane_myProcess">
  92.       <bpmndi:BPMNShape bpmnElement="startevent1" id="BPMNShape_startevent1">
  93.         <omgdc:Bounds height="35.0" width="35.0" x="160.0" y="180.0"></omgdc:Bounds>
  94.       </bpmndi:BPMNShape>
  95.       <bpmndi:BPMNShape bpmnElement="exclusivegateway1" id="BPMNShape_exclusivegateway1">
  96.         <omgdc:Bounds height="40.0" width="40.0" x="240.0" y="130.0"></omgdc:Bounds>
  97.       </bpmndi:BPMNShape>
  98.       <bpmndi:BPMNShape bpmnElement="usertask2" id="BPMNShape_usertask2">
  99.         <omgdc:Bounds height="55.0" width="105.0" x="325.0" y="123.0"></omgdc:Bounds>
  100.       </bpmndi:BPMNShape>
  101.       <bpmndi:BPMNShape bpmnElement="noneintermediatethrowevent1" id="BPMNShape_noneintermediatethrowevent1">
  102.         <omgdc:Bounds height="35.0" width="35.0" x="475.0" y="133.0"></omgdc:Bounds>
  103.       </bpmndi:BPMNShape>
  104.       <bpmndi:BPMNShape bpmnElement="endevent1" id="BPMNShape_endevent1">
  105.         <omgdc:Bounds height="35.0" width="35.0" x="555.0" y="133.0"></omgdc:Bounds>
  106.       </bpmndi:BPMNShape>
  107.       <bpmndi:BPMNEdge bpmnElement="flow3" id="BPMNEdge_flow3">
  108.         <omgdi:waypoint x="195.0" y="197.0"></omgdi:waypoint>
  109.         <omgdi:waypoint x="260.0" y="170.0"></omgdi:waypoint>
  110.       </bpmndi:BPMNEdge>
  111.       <bpmndi:BPMNEdge bpmnElement="flow4" id="BPMNEdge_flow4">
  112.         <omgdi:waypoint x="280.0" y="150.0"></omgdi:waypoint>
  113.         <omgdi:waypoint x="325.0" y="150.0"></omgdi:waypoint>
  114.       </bpmndi:BPMNEdge>
  115.       <bpmndi:BPMNEdge bpmnElement="flow5" id="BPMNEdge_flow5">
  116.         <omgdi:waypoint x="430.0" y="150.0"></omgdi:waypoint>
  117.         <omgdi:waypoint x="475.0" y="150.0"></omgdi:waypoint>
  118.       </bpmndi:BPMNEdge>
  119.       <bpmndi:BPMNEdge bpmnElement="flow6" id="BPMNEdge_flow6">
  120.         <omgdi:waypoint x="510.0" y="150.0"></omgdi:waypoint>
  121.         <omgdi:waypoint x="555.0" y="150.0"></omgdi:waypoint>
  122.       </bpmndi:BPMNEdge>
  123.     </bpmndi:BPMNPlane>
  124.   </bpmndi:BPMNDiagram>
  125. </definitions>


为了让usertak产生一个指定人员的事件，我们给这个usertask弄一个指定人员



然后就是测试代码

  1. package final_activiti.progress;
  2.  
  3. import java.util.HashMap;
  4. import java.util.Map;
  5.  
  6. import org.activiti.engine.impl.test.PluggableActivitiTestCase;
  7. import org.activiti.engine.test.Deployment;
  8. import org.junit.Test;
  9. import org.mpc.final_activiti.ExectuionListenerDemo;
  10. import org.mpc.final_activiti.TaskListenerDemo;
  11.  
  12. public class ListenersTest extends PluggableActivitiTestCase {
  13.  
  14. 	@Test
  15. 	@Deployment(resources = "final_activiti/progress/listeners.bpmn")
  16. 	public void test() {
  17. 		Map<String, Object> map = new HashMap<String, Object>();
  18. 		map.put("myprocessListener", new ExectuionListenerDemo());
  19. 		map.put("mytaskListener", new TaskListenerDemo());
  20. 		map.put("user", "mpc");
  21. 		runtimeService.startProcessInstanceByKey("myProcess", map);
  22. 		taskService.complete(taskService.createTaskQuery().singleResult()
  23. 				.getId());
  24. 		;
  25. 	}
  26.  
  27. }

测试结果：


分析：

1.我们给usertask定义的流程监听实现了

2.usertask中先执行流程监听的start、然后是分配人员、任务启动、任务完成、流程关闭任务；任务是包含在流程中的

原文地址：https://blog.csdn.net/u012613903/article/details/43732941
【推广】 免费学中医，健康全家人
原文地址：https://www.cnblogs.com/jpfss/p/11101605.html