package com.java110.event.service.init;
|
|
import com.java110.utils.util.Assert;
|
import com.java110.event.service.BusinessServiceDataFlowEventPublishing;
|
import org.springframework.core.io.ClassPathResource;
|
import org.springframework.core.io.support.PropertiesLoaderUtils;
|
|
import java.util.Properties;
|
|
/**
|
* 系统启动时加载信息
|
* Created by wuxw on 2017/4/14.
|
*/
|
public class SystemStartLoadBusinessConfigure {
|
|
/**
|
* 默认 事件配置路径classpath:/
|
*/
|
private final static String DEFAULT_EVENT_PATH = "config/";
|
|
/**
|
* 默认 文件名称 .properties
|
*/
|
private final static String DEFAULT_FILE_NAME = "business_listener.properties";
|
|
|
public static void initSystemConfig(String listenerPath){
|
//加载配置文件，注册订单处理侦听
|
try {
|
Assert.hasLength(listenerPath,"listenerPath 为空");
|
Properties properties = load(DEFAULT_EVENT_PATH,DEFAULT_FILE_NAME);
|
|
registerListener(listenerPath,properties);
|
|
}
|
catch (Exception ex) {
|
throw new IllegalStateException("system init error", ex);
|
}
|
}
|
|
/**
|
* 加载文件
|
* @param location
|
* @param filename
|
* @param
|
*/
|
private static Properties load(String location,String filename) throws Exception{
|
Properties properties = PropertiesLoaderUtils.loadProperties(new ClassPathResource(location+filename));
|
return properties;
|
}
|
|
/**
|
* 注册侦听
|
* @param properties
|
*/
|
private static void registerListener(String listenerPath,Properties properties) throws Exception{
|
|
String[] listeners = properties.getProperty(listenerPath).split("\\,");
|
|
for(String listener : listeners){
|
|
//这里不能直接反射，这样 IXXXService 无法注入，所以直接从spring 中获取已经注入的
|
//AppListener<?> appListener = (AppListener<?>)Class.forName(listener).newInstance();
|
try {
|
// BusinessServiceDataFlowListener businessServiceDataFlowListener = (BusinessServiceDataFlowListener) ApplicationContextFactory.getBean(listener);
|
//将 listener 放入 AppEventPublishing 中方便后期操作
|
//注册侦听
|
BusinessServiceDataFlowEventPublishing.addListener(listener);
|
}catch (Exception e){
|
|
}
|
}
|
}
|
|
|
|
}
|
