2. 程式人生 > >activiti(7)：監聽器之流程監聽及spring注入

activiti(7)：監聽器之流程監聽及spring注入

阿新 • • 發佈：2019-01-05

這篇文章主要記錄流程監聽器的部分用法，整個環境實在整合在spring下，ssm環境：

三個監聽器：

A:普通javaBean：

package com.abc.activiti.listenner;


import org.activiti.engine.delegate.DelegateExecution;


public class JavaExpressionActivitiListenner {


	public void expression(DelegateExecution execution) throws Exception {
		System.out.println("executionId：" + execution.getId() + " ActivitiListenner" + this.toString());
	}
}

B:實現ExecutionListener介面：

package com.abc.activiti.listenner;


import org.activiti.engine.delegate.DelegateExecution;
import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.ExecutionListener;
import org.activiti.engine.delegate.TaskListener;


public class ActivitiListenner implements TaskListener, ExecutionListener {


	/**
	 * 
	 */
	private static final long serialVersionUID = -3759054058055401826L;


	@Override
	public void notify(DelegateExecution execution) throws Exception {
		System.out.println("xml流程：" + execution.getId() + " ActivitiListenner" + this.toString());
	}


	@Override
	public void notify(DelegateTask delegateTask) {
		System.out.println("xml任務：" + delegateTask.getId() + " ActivitiListenner" + this.toString());
	}


}

C:實現JavaDelegate介面

package com.abc.activiti.listenner;


import org.activiti.engine.delegate.DelegateExecution;
import org.activiti.engine.delegate.JavaDelegate;


public class JavaDelegateActivitiListenner implements JavaDelegate {


@Override
public void execute(DelegateExecution execution) throws Exception {
System.out.println("executionId：" + execution.getId() + " ActivitiListenner" + this.toString());
}


}


第一種嘗試：javaClass配置實現監聽

流程設計：


 流程非常短：啟動-辦理-結束，並配置了三個監聽器

監聽器配置：

<process id="abc" name="流程監聽注入" isExecutable="true">
<extensionElements>
<activiti:executionListener event="start"
class="com.abc.activiti.listenner.xxxListenner"></activiti:executionListener>
<activiti:executionListener event="end"
class="com.abc.activiti.listenner.xxxListenner"></activiti:executionListener>
</extensionElements>
<startEvent id="startevent1" name="Start"></startEvent>
<userTask id="usertask1" name="User Task"></userTask>
<sequenceFlow id="flow1" sourceRef="startevent1"
targetRef="usertask1"></sequenceFlow>
<endEvent id="endevent1" name="End"></endEvent>
<sequenceFlow id="flow2" sourceRef="usertask1" targetRef="endevent1">
<extensionElements>
<activiti:executionListener event="take"
class="com.abc.activiti.listenner.xxxListenner"></activiti:executionListener>
</extensionElements>
</sequenceFlow>
</process>

A類監聽測試：

2017-09-16 10:36:25.816 [http-nio-8080-exec-3] ERROR c.a.a.controller.ActivitiController.exception - 處理請求http://localhost:8080/abc-master/activiti/start?null 時出錯。
完整異常棧堆資訊
org.activiti.engine.ActivitiIllegalArgumentException: com.abc.activiti.listenner.JavaExpressionActivitiListenner doesn't implement interface org.activiti.engine.delegate.ExecutionListener nor interface org.activiti.engine.delegate.JavaDelegate
啟動流程時報錯，說明通過javaClass配置activiti的流程監聽器必須實現org.activiti.engine.delegate.ExecutionListener或者org.activiti.engine.delegate.JavaDelegate介面

B類監聽測試：

流程啟動-辦理-結束，三個監聽器的方法分別被執行：執行結果如下： 
xml流程：7f7aa2be-9a89-11e7-9d02-b4b6761cb4ac [email protected]ca6dcd
xml流程：7f7aa2be-9a89-11e7-9d02-b4b6761cb4ac [email protected]6a75c6
xml流程：7f7aa2be-9a89-11e7-9d02-b4b6761cb4ac [email protected]2664da
測試表明，通過載入java class的方式去載入實現了ExecutionListener介面的bean，可以順利實現流程監聽，但是每次獲取的監聽器都是一個新物件；

C類監聽測試：

執行結果如下： 
executionId：eebefb34-9a89-11e7-b1f2-b4b6761cb4ac ActivitiLi[email protected]26d8afc4
executionId：eebefb34-9a89-11e7-b1f2-b4b6761cb4ac ActivitiLi[email protected]38835b92
executionId：eebefb34-9a89-11e7-b1f2-b4b6761cb4ac ActivitiLi[email protected]21dcaa6e
不出所料，其結果與B類監聽一致；

進一步測試：spring容器注入bean：

可以設想一下，javaClass載入監聽器的時，每次都是activitiEngine通過反射產生新的物件，因此此種方式下通過spring管理去注入可能會失敗： 對實現了JavaDelegate的監聽器進行改造： 
package com.abc.activiti.listenner;

import org.activiti.engine.delegate.DelegateExecution;
import org.activiti.engine.delegate.JavaDelegate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.abc.activiti.service.ActivitiService;

@Service
public class JavaDelegateActivitiListenner implements JavaDelegate {

	@Autowired
	private ActivitiService activitiService;

	@Override
	public void execute(DelegateExecution execution) throws Exception {
		System.out.println("executionId：" + execution.getId() + " ActivitiListenner" + this.toString()
				+ "  spring容器注入bean：" + activitiService.toString());
	}

}

測試結果：

妥妥的空指標，注入失敗： 
2017-09-16 10:57:01.760 [http-nio-8080-exec-3] ERROR c.a.a.controller.ActivitiController.exception - 處理請求http://localhost:8080/abc-master/activiti/start?null 時出錯。
完整異常棧堆資訊
java.lang.NullPointerException: null
	at com.abc.activiti.listenner.JavaDelegateActivitiListenner.execute(JavaDelegateActivitiListenner.java:19) ~[JavaDelegateActivitiListenner.class:na]
	at org.activiti.engine.impl.delegate.JavaDelegateInvocation.invoke(JavaDelegateInvocation.java:34) ~[activiti-engine-5.20.0.jar:na]
對實現了ExecutionListener的監聽器進行改造： 
package com.abc.activiti.listenner;


import org.activiti.engine.delegate.DelegateExecution;
import org.activiti.engine.delegate.DelegateTask;
import org.activiti.engine.delegate.ExecutionListener;
import org.activiti.engine.delegate.TaskListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;


import com.abc.activiti.service.ActivitiService;


@Service
public class ActivitiListenner implements TaskListener, ExecutionListener {


/**
 * 
 */
private static final long serialVersionUID = -3759054058055401826L;


@Autowired
private ActivitiService activitiService;


@Override
public void notify(DelegateExecution execution) throws Exception {
System.out.println("xml流程：" + execution.getId() + " ActivitiListenner" + this.toString());
System.out.println("activitiService: " + activitiService.toString());
}


@Override
public void notify(DelegateTask delegateTask) {
System.out.println("xml任務：" + delegateTask.getId() + " ActivitiListenner" + this.toString());
}


}

測試結果：

xml流程：03ec2a11-9a8b-11e7-903c-b4b6761cb4ac [email protected]e11ac2
2017-09-16 10:59:11.541 [http-nio-8080-exec-3] ERROR c.a.a.controller.ActivitiController.exception - 處理請求http://localhost:8080/abc-master/activiti/start?null 時出錯。
完整異常棧堆資訊
java.lang.NullPointerException: null
at com.abc.activiti.listenner.ActivitiListenner.notify(ActivitiListenner.java:26) ~[ActivitiListenner.class:na]
at org.activiti.engine.impl.delegate.ExecutionListenerInvocation.invoke(ExecutionListenerInvocation.java:34) ~[activiti-engine-5.20.0.jar:na]
以上兩組結果表明，spring只是將其納入管理，但併成功注入到activitiEngine中。

第二種嘗試：expression配置實現監聽

監聽器配置：

<process id="abc" name="流程監聽注入" isExecutable="true">
		<extensionElements>
			<activiti:executionListener event="start"
				expression="${javaExpressionActivitiListenner.expression(execution)}"></activiti:executionListener>
			<activiti:executionListener event="end"
				expression="${javaExpressionActivitiListenner.expression(execution)}"></activiti:executionListener>
		</extensionElements>
		<startEvent id="startevent1" name="Start"></startEvent>
		<userTask id="usertask1" name="User Task"></userTask>
		<sequenceFlow id="flow1" sourceRef="startevent1"
			targetRef="usertask1"></sequenceFlow>
		<endEvent id="endevent1" name="End"></endEvent>
		<sequenceFlow id="flow2" sourceRef="usertask1" targetRef="endevent1">
			<extensionElements>
				<activiti:executionListener event="take"
					expression="${javaExpressionActivitiListenner.expression(execution)}"></activiti:executionListener>
			</extensionElements>
		</sequenceFlow>
	</process>

A類監聽測試：

需要注意的是，此時通過expression表示式注入時，是的
2017-09-16 11:27:29.420 [http-nio-8080-exec-3] ERROR c.a.a.controller.ActivitiController.exception - 處理請求http://localhost:8080/abc-master/activiti/start?null 時出錯。
完整異常棧堆資訊
org.activiti.engine.ActivitiException: Unknown property used in expression: ${javaExpressionActivitiListenner.expression(execution)}
	at org.activiti.engine.impl.el.JuelExpression.getValue(JuelExpression.java:53) ~[activiti-engine-5.20.0.jar:na]
......
Caused by: org.activiti.engine.impl.javax.el.PropertyNotFoundException: Cannot resolve identifier 'javaExpressionActivitiListenner'
	at org.activiti.engine.impl.juel.AstIdentifier.eval(AstIdentifier.java:83) ~[activiti-engine-5.20.0.jar:5.20.0]

監聽器改造：

package com.abc.activiti.listenner;

import org.activiti.engine.delegate.DelegateExecution;
import org.springframework.stereotype.Component;

@Component
public class JavaExpressionActivitiListenner {

	public void expression(DelegateExecution execution) throws Exception {
		System.out.println("executionId：" + execution.getId() + " ActivitiListenner" + this.toString());
	}
}
測試結果如下： 
executionId：ddd3f07e-9a8d-11e7-9fc5-b4b6761cb4ac ActivitiList[email protected]420a38c6
executionId：ddd3f07e-9a8d-11e7-9fc5-b4b6761cb4ac ActivitiList[email protected]420a38c6
executionId：ddd3f07e-9a8d-11e7-9fc5-b4b6761cb4ac ActivitiList[email protected]420a38c6

B類監聽測試：

測試結果：

xml流程：2175ef09-9a8e-11e7-9af4-b4b6761cb4ac [email protected]68610c
xml流程：2175ef09-9a8e-11e7-9af4-b4b6761cb4ac [email protected]68610c
xml流程：2175ef09-9a8e-11e7-9af4-b4b6761cb4ac [email protected]68610c

C類監聽測試：

測試結果：

executionId：719dc30a-9a8d-11e7-9ac9-b4b6761cb4ac ActivitiLi[email protected]7374d21e
executionId：719dc30a-9a8d-11e7-9ac9-b4b6761cb4ac ActivitiLi[email protected]7374d21e
executionId：719dc30a-9a8d-11e7-9ac9-b4b6761cb4ac ActivitiLi[email protected]7374d21e

進一步測試：spring注入bean：

測試結果： 
xml流程：2b882f40-9a91-11e7-9325-b4b6761cb4ac [email protected]e9857e
activitiService: [email protected]
xml流程：2b882f40-9a91-11e7-9325-b4b6761cb4ac [email protected]e9857e
activitiService: [email protected]
xml流程：2b882f40-9a91-11e7-9325-b4b6761cb4ac [email protected]e9857e
activitiService: [email protected]
此處僅提供A類監聽測試結果，其餘測試結果均一致，以上測試結果表明，使用expression表示式江容器中的bean作為監聽器注入到activitiEngine中是一種非常靈活強大的方式。

第三種嘗試：delegate expression配置實現監聽

監聽器配置： 
	<process id="abc" name="流程監聽注入" isExecutable="true">
		<extensionElements>
			<activiti:executionListener event="start"
				delegateExpression="${activitiListenner}"></activiti:executionListener>
			<activiti:executionListener event="end"
				delegateExpression="${activitiListenner}"></activiti:executionListener>
		</extensionElements>
		<startEvent id="startevent1" name="Start"></startEvent>
		<userTask id="usertask1" name="User Task"></userTask>
		<sequenceFlow id="flow1" sourceRef="startevent1"
			targetRef="usertask1"></sequenceFlow>
		<endEvent id="endevent1" name="End"></endEvent>
		<sequenceFlow id="flow2" sourceRef="usertask1" targetRef="endevent1">
			<extensionElements>
				<activiti:executionListener event="take"
					delegateExpression="${activitiListenner}"></activiti:executionListener>
			</extensionElements>
		</sequenceFlow>
	</process>
A類監聽測試： 
2017-09-16 12:21:54.134 [http-nio-8080-exec-3] ERROR c.a.a.controller.ActivitiController.exception - 處理請求http://localhost:8080/abc-master/activiti/start?null 時出錯。
完整異常棧堆資訊
org.activiti.engine.ActivitiIllegalArgumentException: Delegate expression ${javaExpressionActivitiListenner} did not resolve to an implementation of interface org.activiti.engine.delegate.ExecutionListener nor interface org.activiti.engine.delegate.JavaDelegate
	at org.activiti.engine.impl.bpmn.listener.DelegateExpressionExecutionListener.notify(DelegateExpressionExecutionListener.java:57) ~[activiti-engine-5.20.0.jar:5.20.0]
	at org.activiti.engine.impl.pvm.runtime.AbstractEventAtomicOperation.execute(AbstractEventAtomicOperation.java:42) ~[activiti-engine-5.20.0.jar:na]
B類監聽測試： 
xml流程：fcc6c8ba-9a95-11e7-826d-b4b6761cb4ac [email protected]425d05
activitiService: [email protected]
xml流程：fcc6c8ba-9a95-11e7-826d-b4b6761cb4ac [email protected]425d05
activitiService: [email protected]
xml流程：fcc6c8ba-9a95-11e7-826d-b4b6761cb4ac [email protected]425d05
activitiService: [email protected]
C類監聽測試： 
executionId：c96567e2-9a95-11e7-b7e3-b4b6761cb4ac ActivitiLi[email protected]6f660921  spring容器注入bean：[email protected]
executionId：c96567e2-9a95-11e7-b7e3-b4b6761cb4ac ActivitiLi[email protected]6f660921  spring容器注入bean：[email protected]
executionId：c96567e2-9a95-11e7-b7e3-b4b6761cb4ac ActivitiLi[email protected]6f660921  spring容器注入bean：[email protected]
以上測試結果表明： 通過delegate expression配置容器中的監聽器時，仍然需要實現ExecutionListener或者JavaDelegate介面

總結：

1通過javaClass載入指定類，這種硬編碼的形式管理監聽器，是將class位元組碼檔案交由activitiEngine處理，每次需要的時候則由engine通過反射構建例項物件，spring無法管理； 2通過delegate expression配置容器中的bean作為監聽器，${類名}；需要bean自身實現org.activiti.engine.delegate.ExecutionListener或者 org.activiti.engine.delegate.JavaDelegate介面，並重寫對應的方法，在改監聽器被呼叫時，會預設制定重寫方法中的邏輯，此時，bean物件是由spring管理，可以與容器無縫對接； 3通過expression配置容器中的bean作為監聽器，${類名.方法名(引數名)}；這是最為靈活也最為強大的方法，可以使用任意的bean，也可以自定義將要執行的方法，與spring容器無縫對接，與業務邏輯完美契合。

相關推薦

activiti(7)：監聽器之流程監聽及spring注入

這篇文章主要記錄流程監聽器的部分用法，整個環境實在整合在spring下，ssm環境： 三個監聽器： A:普通javaBean： package com.abc.activiti.listenner;

Activiti工作流之事件監聽

工作流程事件監聽可用於任務提醒、超時提醒等的模組的設計。以下是相關事件的介紹 一、事件監聽型別 ENGINE_CREATED 監聽器監聽的流程引擎已經建立完畢，並準備好接受API呼叫。 ENGINE_CLOSED 監聽器監聽的流程引擎已經關閉，不再接受API呼叫。 ENTIT

監聽總結之3.監聽命令：lsnrctl工具的三個命令start、stop和status都是分步執行的

首先，我們需要知道兩個事情： 1、lsnrctl工具下的三個命令，分別是status、stop、start。 我們從三個命令執行後在螢幕上顯示的結果來看，可以發現一個共性，就是都有“正在連線到”這句話 。 2、每次進入lsnrctl工具的環境時，lsnrctl工具都會自動讀

javaWeb學習之Listener監聽

host idle .get 序列化 name mov 面試題 感知 就是 】 一、監聽器Listener javaEE包括13門規範 在課程中主要學習 servlet技術 和 jsp技術 其中 servlet規範包括三個技術點：servlet l

zookeeper源碼之配置監聽

com continue 點數據 lis process 節點數 hashset ace tree 　　配置存儲不僅維護了一個樹結構，還對各個節點添加了變更監聽。 類圖 　　DataTree內部維護兩個通知管理器，分別監聽節點數據變更和子節點變更。 public cl

No.5一步步學習vuejs之事件監聽和組件

sage 應該 shift vuejs 進行 編譯器 add round mage 一監聽事件 可以用 v-on 指令監聽 DOM 事件，並在觸發時運行一些 JavaScript 代碼。 <div id="demo1"> <button v-on:cli

SpringBoot入門之事件監聽

int () AI stat boot.s over style 資源 nvi 　　spring boot在啟動過程中增加事件監聽機制，為用戶功能拓展提供極大的便利，sptingboot支持的事件類型有以下五種： ApplicationStartingEvent Appl

Android 7.0 Gallery圖庫源碼分析4 - SlotView手勢監聽及頁面跳轉

ofo 自帶 end follow mat views mha creat 找到 上篇文章講了初始化View時會實例化一個SlotView並監聽其事件，至於它是怎麽實現的，用的是Android自帶的GestureDetector。 GestureDetector是Andro

分享：50行程式碼監聽watch小程式的globalData

監聽方法： 1 // 在任何元件、頁面，例如頁面 2 3 const app = getApp( ); 4 5 Page({ 6 7 onLoad: function( ) { 8 app.watch$('role', ( val, old ) => {

Vue之資料監聽存在的問題

Vue之資料監聽 當資料監聽的是列表時，資料發生改變，不會被監聽到。 // 用$set修改陣列中的陣列能夠被監聽 // app.$set(this.hobby, 0, "愛你哦"); <div id="app"> {{name}} <hr> {

layui select下拉框改變之 change 監聽事件

 在layui中使用 jquery 觸發select 的 change事件無效   使用layui.use監聽select事件           <select lay-filter="dem

vue之watch監聽物件或者一個值時注意事項（深度觀察deep:true慎用！）

vue中想在某個值改變的時候能夠做一些其他事情，可以使用其提供的監聽機制，使用watch。注意，本篇不講技術問題，只是講解如何應用，因為筆者也是一個前端的小白 例：經手專案中就有使用，截圖如下： 下面來分析上面分別是怎樣實現監聽的： 其實除了畫紅線的地方，別的都沒什

Bootstrap的js外掛之滾動監聽(scrollspy)

data-spy="scroll"——向您想要監聽的元素（通常是 body）新增滾動監聽事件 。 data-target=".navbar"——指明導航條為監聽目標； data-offset="70"——計算滾動位置時相對於頂部的偏移量（畫素數）; <!DOCTY

09.VUE學習之watch監聽屬性變化實現類百度搜索欄功能ajax異步請求數據

class ivr url 實現類 int php head 實現 sta cmd下安裝axios npm install axios 安裝好後,會多出node_modules文件夾 思路: 監聽data裏的word改變時,發送ajax異步請求數據, 把返回的數據賦值給d

監聽器(對application監聽)

1:jsp <%@ page contentType="text/html;charset=UTF-8" language="java" import="java.util.*" pageEncoding="UTF-8"%> <!DOCTYPE HTML

[踏石留印之Android] 監聽activity的狀態(Create\Destroy)進行響應

最近在做串列埠資料處理時需要監聽某activity的狀態，以方便地開啟關閉串列埠，而監聽也非常簡單，鑑於我專案中已有繼承Application的BaseApplication類，用來設定全域性變數和重複使用的方法，以及為我的第三方SDK進行初始化操作。 Bas

【spring系列】之7：生命週期-BeanPostProcessor原理以及在spring底層中的運用

本章節重點說一下我們自定義的BeanPostProcessor的執行機制和呼叫棧。 事前準備： 1.自定義beanPostProcessor 2.註冊自定義的beanPostProcessor到容器中 1.自定義beanPostProcessor @Componen

針對非Webapp測試的Burp技巧(一)：攔截和代理監聽

Burp不僅僅可以被用於Web應用程式測試。我常在移動端和胖客戶端測試中使用Burp。如果應用使用了HTTP方法，那麼Burp絕對會成為你最好的選擇。我要記錄在工作中對我有很大幫助的Burp技巧。目的之一是與大家一起分享這些技巧，另一個目的是把這些技巧記

09.1.VUE學習之watch監聽屬性變化實現類百度搜索欄功能ajax非同步請求資料,返回陣列

09.1html裡 <!DOCTYPE html> <html> <head> <meta charset="utf-8"> <meta http-equiv="X-UA-Compatible" content="IE=edge">

GameFramework學習之新增監聽

監聽可以使用在很多地方,主要是監聽一個東西如果這個東西發生了改變,執行一個方法去體現出來,可以用在不同的指令碼中 這個型別可以是任何型別甚至是表 EventKey這個指令碼主要是存貯時間的關鍵字 相當於是中轉,連線著TriggerListener和AddListener 這個程式碼的主