From fec26dfca0c796c2c9d4cd3c206affa0bc06c281 Mon Sep 17 00:00:00 2001
From: wuxw7 <wuxw7@asiainfo.com>
Date: 星期一, 02 七月 2018 22:52:48 +0800
Subject: [PATCH] 事件侦听改为注解方式，方便后期开发，取消配置文件方式
---
java110-event/src/main/java/com/java110/event/center/DataFlowEventPublishing.java | 71 +++++++++++++++++++++++++++++++----
1 files changed, 62 insertions(+), 9 deletions(-)
diff --git a/java110-event/src/main/java/com/java110/event/center/DataFlowEventPublishing.java b/java110-event/src/main/java/com/java110/event/center/DataFlowEventPublishing.java
index 035d10a..bbe334e 100644
--- a/java110-event/src/main/java/com/java110/event/center/DataFlowEventPublishing.java
+++ b/java110-event/src/main/java/com/java110/event/center/DataFlowEventPublishing.java
@@ -2,11 +2,11 @@
import com.java110.common.constant.CommonConstant;
import com.java110.common.exception.BusinessException;
+import com.java110.common.factory.ApplicationContextFactory;
import com.java110.common.log.LoggerEngine;
import com.java110.common.util.Assert;
-import com.java110.event.center.event.DataFlowEvent;
-import com.java110.event.center.event.DataPreValidateEvent;
-import com.java110.event.center.event.ReceiveRequestEvent;
+import com.java110.core.context.DataFlow;
+import com.java110.event.center.event.*;
import com.java110.event.center.listener.DataFlowListener;
import java.lang.reflect.ParameterizedType;
@@ -32,7 +32,7 @@
/**
* 淇濆瓨渚﹀惉瀹炰緥淇℃伅锛屼竴鑸惎鍔ㄦ椂鍔犺浇
*/
- private final static List<DataFlowListener<?>> listeners = new ArrayList<DataFlowListener<?>>();
+ private final static List<String> listeners = new ArrayList<String>();
/**
* 淇濆瓨浜嬩欢瀹炰緥淇℃伅锛屼竴鑸惎鍔ㄦ椂鍔犺浇
@@ -52,15 +52,25 @@
* 娣诲姞 渚﹀惉锛岃繖涓彧鏈夊惎鍔ㄦ椂锛屽崟绾跨▼ 澶勭悊锛屾墍浠ユ槸绾跨▼瀹夊叏鐨�
* @param listener
*/
- public static void addListener(DataFlowListener<?> listener){
+ /*public static void addListener(DataFlowListener<?> listener){
listeners.add(listener);
+ }*/
+
+ /**
+ * 娉ㄨВ娉ㄥ唽渚﹀惉
+ * @param listenerBeanName
+ */
+ public static void addListener(String listenerBeanName){
+ //灏� listener 鏀惧叆 AppEventPublishing 涓柟渚垮悗鏈熸搷浣�
+ //娉ㄥ唽渚﹀惉
+ listeners.add(listenerBeanName);
}
/**
* 鑾峰彇渚﹀惉锛堝叏閮ㄤ睛鍚級
* @return
*/
- private static List<DataFlowListener<?>> getListeners(){
+ private static List<String> getListeners(){
return listeners;
}
@@ -72,7 +82,7 @@
*/
private static List<DataFlowListener<?>> getListeners(String interfaceClassName){
- Assert.isNull(interfaceClassName,"鑾峰彇闇�瑕佸彂甯冪殑浜嬩欢澶勭悊渚﹀惉鏃讹紝浼犻�掍簨浠朵负绌猴紝璇锋鏌�");
+ Assert.hasLength(interfaceClassName,"鑾峰彇闇�瑕佸彂甯冪殑浜嬩欢澶勭悊渚﹀惉鏃讹紝浼犻�掍簨浠朵负绌猴紝璇锋鏌�");
//鍏堜粠缂撳瓨涓幏鍙栵紝涓轰簡鎻愬崌鏁堢巼
if(cacheListenersMap.containsKey(interfaceClassName)){
@@ -80,7 +90,9 @@
}
List<DataFlowListener<?>> dataFlowListeners = new ArrayList<DataFlowListener<?>>();
- for(DataFlowListener<?> listener : getListeners()){
+
+ for(String listenerBeanName : getListeners()){
+ DataFlowListener<?> listener = ApplicationContextFactory.getBean(listenerBeanName,DataFlowListener.class);
Type[] types = listener.getClass().getGenericInterfaces();
for (Type type : types) {
if (type instanceof ParameterizedType) {
@@ -141,7 +153,7 @@
*/
private static void multicastEvent(final DataFlowEvent event, String asyn) {
- for (final DataFlowListener<?> listener : getListeners(event.getClass().getName())) {
+ for (final DataFlowListener<?> listener : getListeners(event.getClass().getName())) {
if(CommonConstant.PROCESS_ORDER_ASYNCHRONOUS.equals(asyn)){ //寮傛澶勭悊
@@ -206,5 +218,46 @@
multicastEvent(new DataPreValidateEvent("",null,requestData,headers));
}
+ /**
+ * 鍒濆鍖� DataFlow 瀵硅薄瀹屾垚
+ * @param dataFlow 鏁版嵁娴佸璞�
+ */
+ public static void initDataFlowComplete(DataFlow dataFlow){
+ multicastEvent(new DataFlowInitCompleteEvent("",dataFlow));
+ }
+
+ /**
+ * 瑙勫垯鏍￠獙瀹屾垚浜嬩欢
+ * @param dataFlow 鏁版嵁娴佸璞�
+ */
+ public static void ruleValidateComplete(DataFlow dataFlow){
+ multicastEvent(new RuleValidateCompleteEvent("",dataFlow));
+ }
+
+ /**
+ * 鍔犺浇閰嶇疆鏂囦欢瀹屾垚
+ * @param dataFlow 鏁版嵁娴佸璞�
+ */
+ public static void loadConfigDataComplete(DataFlow dataFlow){
+ multicastEvent(new LoadConfigDataCompleteEvent("",dataFlow));
+ }
+
+
+ /**
+ * 璋冪敤涓氬姟绯荤粺浜嬩欢
+ * @param dataFlow 鏁版嵁娴�
+ */
+ public static void invokeBusinessSystem(DataFlow dataFlow){
+ multicastEvent(new InvokeBusinessSystemEvent("",dataFlow));
+ }
+
+ /**
+ * 鏁版嵁杩斿洖浜嬩欢
+ * @param dataFlow 鏁版嵁娴�
+ */
+ public static void dataResponse(DataFlow dataFlow,String responseData,Map<String,String> headers){
+ multicastEvent(new DataResponseEvent("",dataFlow,responseData,headers));
+ }
+
/***********************************************鍙戝竷渚﹀惉 缁撴潫***************************************************************/
}
--
Gitblit v1.8.0