取消java110-common jar包，提升为CommonService服务,将之前的Java110-common内容变更为Java110-utils包

webapp

2019-09-30 cbc1f9db3d796683d88d6d30df3659984dfbeda3

 java110-event/src/main/java/com/java110/event/center/init/EventConfigInit.java

@@ -1,14 +1,9 @@
package com.java110.event.center.init;

import com.java110.common.factory.ApplicationContextFactory;
import com.java110.event.app.AppEventPublishing;
import com.java110.event.center.DataFlowEventPublishing;
import com.java110.event.center.DataFlowListener;
import org.apache.commons.lang3.StringUtils;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.support.PropertiesLoaderUtils;

import javax.naming.ConfigurationException;
import java.util.Properties;

/**
@@ -33,10 +28,6 @@
     */
    private final static String DATAFLOW_LISTENER = "java110.event.properties.centerServiceListener";

    /**
     * 订单调度事件
     */
    private final static String DISPATCH_EVENT = "java110.event.properties.centerServiceEvent";


    public static void initSystemConfig(){
@@ -46,9 +37,6 @@
            Properties properties = load(DEFAULT_EVENT_PATH,DEFAULT_FILE_NAME);

            registerListener(properties);

            //注册事件
            registerEvent(properties);

        }
        catch (Exception ex) {
@@ -77,42 +65,13 @@
        String[] listeners = properties.getProperty(DATAFLOW_LISTENER).split("\\,");

        for(String listener : listeners){

            //这里不能直接反射，这样 IXXXService 无法注入，所以直接从spring 中获取已经注入的
            DataFlowListener<?> dataFlowListener = (DataFlowListener<?>) ApplicationContextFactory.getBean(listener);

            //将 listener 放入 AppEventPublishing 中方便后期操作
            //注册侦听
            DataFlowEventPublishing.addListenner(dataFlowListener);
            DataFlowEventPublishing.addListener(listener);
        }
    }

    /**
     * 注册事件
     * @param properties
     * @throws Exception
     */
    private static void registerEvent(Properties properties) throws Exception{
        String[] events = properties.getProperty(DISPATCH_EVENT).split("\\,");

        for (String event : events){

            if(StringUtils.isBlank(event) || !event.contains("::")){
                throw new ConfigurationException("配置错误，["+DISPATCH_EVENT+"= "+events+"] 当前 [event = "+event+"],不存在 :: ,配置格式为 A::B");
            }

            String[] tmpEvent = event.split("::");

            if(tmpEvent.length > 2){
                throw new ConfigurationException("配置错误，["+DISPATCH_EVENT+"= "+events+"] 当前 [event = "+event+"],只能有一个 :: ,配置格式为 A::B");
            }

            Class clazz = Class.forName(tmpEvent[1]);

            AppEventPublishing.addEvent(tmpEvent[0],clazz);
        }

    }


}