package com.java110.core.event.init;
|
|
import com.java110.utils.factory.ApplicationContextFactory;
|
import com.java110.core.event.app.AppEvent;
|
import com.java110.core.event.app.AppEventPublishing;
|
import com.java110.core.event.app.AppListener;
|
import com.java110.core.event.listener.common.CommonDispatchListener;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.boot.context.event.ApplicationReadyEvent;
|
import org.springframework.context.ApplicationContext;
|
import org.springframework.core.io.ClassPathResource;
|
import org.springframework.core.io.support.PropertiesLoaderUtils;
|
|
import javax.naming.ConfigurationException;
|
import java.util.Properties;
|
|
/**
|
* 系统启动时加载信息
|
* Created by wuxw on 2017/4/14.
|
*/
|
public class SystemStartUpInit /*implements ApplicationListener<ApplicationReadyEvent>*/ {
|
|
/**
|
* 默认 事件配置路径classpath:/
|
*/
|
private final String DEFAULT_EVENT_PATH = "config/";
|
|
|
/**
|
* 默认 文件名称 .properties
|
*/
|
private final String DEFAULT_FILE_NAME = "event.properties";
|
|
/**
|
* 订单调度处理侦听
|
*/
|
private final static String DISPATCH_LISTER = "java110.event.properties.orderDispatchListener";
|
|
/**
|
* 订单调度事件
|
*/
|
private final static String DISPATCH_EVENT = "java110.event.properties.orderDispatchEvent";
|
|
/**
|
* 服务
|
*/
|
private final static String LISTENER_SERVICE = "java110.event.properties.listener.service";
|
|
|
|
/**
|
* 加载配置文件，将侦听初始化
|
* @param event
|
*/
|
// @Override
|
public void onApplicationEvent(ApplicationReadyEvent event){
|
|
|
//加载配置文件，注册订单处理侦听
|
try {
|
|
ApplicationContextFactory.setApplicationContext(event.getApplicationContext());
|
|
Properties properties = this.load(DEFAULT_EVENT_PATH,DEFAULT_FILE_NAME);
|
|
registerListener(properties);
|
|
//注册事件
|
registerEvent(properties);
|
|
//注册服务
|
registerService(properties);
|
}
|
catch (Exception ex) {
|
throw new IllegalStateException("system init error", ex);
|
}
|
|
}
|
|
public void initSystemConfig(ApplicationContext context){
|
//加载配置文件，注册订单处理侦听
|
try {
|
|
ApplicationContextFactory.setApplicationContext(context);
|
|
Properties properties = this.load(DEFAULT_EVENT_PATH,DEFAULT_FILE_NAME);
|
|
registerListener(properties);
|
|
//注册事件
|
registerEvent(properties);
|
|
//注册服务
|
registerService(properties);
|
}
|
catch (Exception ex) {
|
throw new IllegalStateException("system init error", ex);
|
}
|
}
|
|
|
/**
|
* 加载文件
|
* @param location
|
* @param filename
|
* @param
|
*/
|
private Properties load(String location,String filename) throws Exception{
|
Properties properties = PropertiesLoaderUtils.loadProperties(new ClassPathResource(location+filename));
|
return properties;
|
}
|
|
/**
|
* 注册侦听
|
* @param properties
|
*/
|
private void registerListener(Properties properties) throws Exception{
|
|
String[] listeners = properties.getProperty(DISPATCH_LISTER).split("\\,");
|
|
for(String listener : listeners){
|
|
//这里不能直接反射，这样 IXXXService 无法注入，所以直接从spring 中获取已经注入的
|
//AppListener<?> appListener = (AppListener<?>)Class.forName(listener).newInstance();
|
|
AppListener<?> appListener = (AppListener<?>) ApplicationContextFactory.getBean(listener);
|
|
//将 listener 放入 AppEventPublishing 中方便后期操作
|
//注册侦听
|
AppEventPublishing.addListenner(appListener);
|
}
|
}
|
|
/**
|
* 注册事件
|
* @param properties
|
* @throws Exception
|
*/
|
private 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<AppEvent> clazz = (Class<AppEvent>) Class.forName(tmpEvent[1]);
|
|
AppEventPublishing.addEvent(tmpEvent[0],clazz);
|
}
|
|
}
|
|
|
/**
|
* 注册服务
|
* @param properties
|
* @throws Exception
|
*/
|
private void registerService(Properties properties) throws Exception{
|
String[] services = properties.getProperty(LISTENER_SERVICE).split("\\,");
|
|
for(String service : services){
|
if(StringUtils.isBlank(service) || !service.contains("::")){
|
throw new ConfigurationException("配置错误，["+LISTENER_SERVICE+"= "+services+"] 当前 [event = "+service+"],不存在 :: ,配置格式为 A::B");
|
}
|
|
String[] tmpService = service.split("::");
|
|
if(tmpService.length > 2){
|
throw new ConfigurationException("配置错误，["+LISTENER_SERVICE+"= "+services+"] 当前 [event = "+service+"],只能有一个 :: ,配置格式为 A::B");
|
}
|
|
CommonDispatchListener.addService(tmpService[0],tmpService[1]);
|
|
}
|
|
}
|
|
|
}
|
