@IPU_REQ_2021@添加ipu-spring-nacos示例代码

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/control/nacos/IpuSpringNacosController.java

@@ -34,6 +34,7 @@ import com.ai.ipu.nosql.INoSql;
import com.ai.ipu.nosql.config.IpuNoSQLConfig;
import com.ai.ipu.nosql.mongodb.MongoCacheFactory;
import com.ai.ipu.server.demo.config.IpuSpringNacosConfig;
import com.ai.ipu.server.demo.listener.IpuCacheListener;
import com.github.pagehelper.util.StringUtil;
/**
 * 基于ipu-spring-nacos组件对ipu-cache/ipu-nacos/ipu-s3/ipu-database动态刷新配置范例。
@@ -341,4 +342,22 @@ public class IpuSpringNacosController {
        }
        return dbsMap;
    }
    
	@ResponseBody
    @RequestMapping("/scheduleIpuConfigUsingIpuCache")
    public JMap scheduleIpuConfigUsingIpuCache(JMap param) throws Exception {
		JMap result = new JsonMap();	
		try {		
			//监听配置中心里ipu-cache.xml的配置
			service.addListener(nacosConfig.getIpuCacheDataid(), nacosConfig.getIpuCacheGroup(), new IpuCacheListener());
			result.put("result", "监听配置中心:" + IpuNacosConfig.getNacosServerAddr() + "ipu-cache.xml的配置" + nacosConfig.getIpuCacheDataid() + "成功");		
		} catch (Exception e)
		{
			String errorMsg = "监听配置中心:" + IpuNacosConfig.getNacosServerAddr() + "ipu-cache.xml的配置" + nacosConfig.getIpuCacheDataid() + "错误：" + e.toString();
			LOGGER.error(errorMsg);
			result.put("result", errorMsg);
		}
		return result;
	}
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/listener/IpuCacheListener.java

@@ -0,0 +1,44 @@
package com.ai.ipu.server.demo.listener;
import java.util.Calendar;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.common.date.TimeUtil;
import com.ai.ipu.restful.spring.SpringBeanUtil;
import com.ai.ipu.server.demo.config.IpuSpringNacosConfig;
import com.ai.ipu.server.demo.schedule.ScheduledTask;
import com.alibaba.nacos.api.config.listener.AbstractListener;
public class IpuCacheListener extends AbstractListener {
	private static final ILogger log = IpuLoggerFactory.createLogger(IpuCacheListener.class);
	
	@Override
	public void receiveConfigInfo(String configInfo) {
		
		try {
			log.debug(">>>>>>>>>>>>>>>>>>>new config from nacos:" + configInfo);
			IpuSpringNacosConfig config = SpringBeanUtil.getBean(IpuSpringNacosConfig.class);
			//新配置第二天0点0分1秒生效
			StringBuffer cron = new StringBuffer();
			cron.append("1").append(" 0").append(" 0 ");
			String day = TimeUtil.getSysDate(1, "dd");
			String month = TimeUtil.getSysDate(1, "MM");
			cron.append(day.startsWith("0")?day.substring(1):day).append(" ");
			cron.append(month.startsWith("0")?month.substring(1):month).append(" ");
			cron.append("? ");
			cron.append(TimeUtil.getSysDate(1, "yyyy"));
			//ScheduledTask.run("0 22 10 2 8 ? 2021", config.getIpuCacheDataid(), configInfo);
			ScheduledTask.run(cron.toString(), config.getIpuCacheDataid(), configInfo);
		} catch (Exception e) {
			log.error("receiveConfigInfo error:", e);
		}
	}
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/schedule/ScheduleIpuCacheJob.java

@@ -0,0 +1,44 @@
package com.ai.ipu.server.demo.schedule;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.util.Map;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
import com.ai.ipu.restful.spring.SpringBeanUtil;
import com.ai.ipu.server.demo.config.IpuSpringNacosConfig;
import com.ai.ipu.server.demo.util.XmlUtil;
public class ScheduleIpuCacheJob implements Job {
	private static final ILogger logger = IpuLoggerFactory.createLogger(ScheduleIpuCacheJob.class);
	public void execute(JobExecutionContext context) throws JobExecutionException {
		try {
			Map xml = context.getMergedJobDataMap();
			new Thread(new Runnable() {
				@Override
				public void run() {
					try {
						IpuSpringNacosConfig config = SpringBeanUtil.getBean(IpuSpringNacosConfig.class);
						Map map = XmlUtil.ipuCacheXmlToMap((String) xml.get(config.getIpuCacheDataid()), "utf-8");
						logger.debug("map:" + map);
						logger.debug("为ipu-cache添加配置成功");
					} catch (Exception e) {
						failed();
					}
				}
			}).start();
		} catch (Exception e) {
			logger.error("为ipu-cache添加配置异常:" + e.getMessage());
		}
	}
	private void failed() {
		logger.error("error");
	}
}

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/schedule/ScheduledTask.java

@@ -0,0 +1,62 @@
package com.ai.ipu.server.demo.schedule;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import org.quartz.CronScheduleBuilder;  
import org.quartz.JobBuilder;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;  
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;  
import org.quartz.Trigger;  
import org.quartz.TriggerBuilder;  
import org.quartz.impl.StdSchedulerFactory;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
  
public class ScheduledTask{  
	private static final ILogger logger = IpuLoggerFactory.createLogger(ScheduledTask.class);
	private static final ConcurrentMap<String, Scheduler> task = new ConcurrentHashMap<String, Scheduler>();
	
	public static void run(String cron, String dataId, String xml) 
    {	  
        // Define scheduler  
        SchedulerFactory sf = new StdSchedulerFactory();  
        Scheduler sched;
		try {
			if (task.containsKey(dataId))
			{
				sched = task.get(dataId);
				sched.clear();
			}
			else
			{
				sched = sf.getScheduler();
				task.put(dataId, sched);
			}
			// Define job  
			JobDataMap newJobDataMap = new JobDataMap();
			newJobDataMap.put(dataId, xml);
	        JobDetail job = JobBuilder.newJob(ScheduleIpuCacheJob.class)  
	                .withIdentity("update ipu-cache configaration", "group1")
	                .setJobData(newJobDataMap)
	                .build();  
	  
	        // Define trigger strategy  
	        Trigger trigger = TriggerBuilder.newTrigger()  
	                .withIdentity("trigger1", "group1")  
	                .withSchedule(CronScheduleBuilder.cronSchedule(cron))  
	                .build();  
	        sched.scheduleJob(job, trigger);  
	        
	        // Start the job  
	        sched.start();  
	        
		} catch (SchedulerException e) {
			logger.error(e.getMessage());
		}  
        
    } 
}  

ipu-rest-demo/src/main/java/com/ai/ipu/server/demo/util/XmlUtil.java

@@ -0,0 +1,110 @@
package com.ai.ipu.server.demo.util;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import com.ai.ipu.basic.string.StringUtil;
import com.ai.ipu.cache.config.IpuCacheConfig;
import com.ai.ipu.common.xml.Dom4jHelper;
import com.ai.ipu.dfs.s3.conf.IpuDfsConfig;
import com.ai.ipu.nosql.config.IpuNoSQLConfig;
import com.ai.ipu.nosql.util.MongoConstant;
public class XmlUtil {
	/**
     * @description 将ipu-s3的xml字符串转换成map
     * @param xml
     * @return Map
     * @throws Exception 
     */
    public static Map ipuS3XmlToMap(String xml, String charsetName) throws Exception {
        Dom4jHelper dh = new Dom4jHelper(xml, charsetName);
        
        return IpuDfsConfig.parseIpuConfig((HashMap<String, ?>) dh.getAll(), "nacos");
    }
    
    /**
     * @description 将ipu-cache的xml字符串转换成map
     * @param xml
     * @return Map
     * @throws Exception 
     */
    public static Map ipuCacheXmlToMap(String xml, String charsetName) throws Exception {
        Dom4jHelper dh = new Dom4jHelper(xml, charsetName);
        
        return IpuCacheConfig.parseIpuConfig((HashMap<String, ?>) dh.getAll(), "nacos");
    }
    /**
     * @description 将ipu-nosql的xml字符串转换成map
     * @param xml
     * @return Map
     * @throws Exception 
     */
    public static List<Map> ipuNosqlXmlToMap(String xml, String charsetName) throws Exception {
        Dom4jHelper dh = new Dom4jHelper(xml, charsetName);
        
        return IpuNoSQLConfig.parseIpuConfig((HashMap<String, ?>) dh.getAll(), "nacos");
    }
    
    /**
     * @description 将ipu-database的xml字符串转换成map
     * @param xml
     * @return Map
     * @throws Exception 
     */
    public static Map ipuDatabaseXmlToMap(String xml, String charsetName) throws Exception {
        Dom4jHelper dh = new Dom4jHelper(xml, charsetName);
        Map<String, ?> originData = dh.getAll();
        List<Map<String, Object>> configs = (List<Map<String, Object>>) originData.get("environments");
        Map cachesMap = new HashMap<String, Object>();
        Map<String, Object> cacheMap;
        List<Map<String, String>> cacheServer;
        Map<String, String> configAttr;
        /*循环缓存实例*/
        for (Map<String, Object> config : configs) {
            cacheMap = new HashMap<String, Object>();
            cacheServer = new ArrayList<Map<String, String>>();
            configAttr = new HashMap<String, String>();
            
            Map<String, String> cacheAttrMap = (Map<String, String>) config.get("environment" + Dom4jHelper.SUFFIX_ATTR);
            String datdbaseName = cacheAttrMap.get("id");
            List<Map<String, Object>> cacheList = (List<Map<String, Object>>)config.get("environment");
            String type = "";
            String driver = "";
            for(Map<String, Object> map : cacheList){
            	if(map.get("transactionManager_attr")!=null){
                    /*解析缓存实例的服务列表*/
                    Map<String, Object> serverMap = (Map<String, Object>)map.get("transactionManager_attr");
                    type = (String)serverMap.get("type");
                }
            	if(map.get("dataSource_attr")!=null){
                    /*解析缓存实例的服务列表*/
                    Map<String, Object> serverMap = (Map<String, Object>)map.get("dataSource_attr");
                    driver = (String)serverMap.get("type");
                }
            	if(map.get("dataSource")!=null){
                    /*解析缓存实例的服务列表*/
            		List<Map<String, Object>> serverList = (List<Map<String, Object>>)map.get("dataSource");
//                    List<Map<String, Object>> serverList = (List<Map<String, Object>>)serverMap.get("property_attr");
                    for(Map<String, Object> configValue : serverList){
                    	Map<String, Object> configMap = (Map<String, Object>)configValue.get("property_attr");
                    	configAttr.put((String)configMap.get("name"), (String)configMap.get("value"));
                    }
                                        
                }
                
            }            
            cacheMap.put("databaseName", datdbaseName+"1.0");
            cacheMap.put("type", type);
            cacheMap.put("property", configAttr);
            cacheMap.put("dataSource_driver", driver);
            cachesMap.put(datdbaseName, cacheMap);
        }
        return cachesMap;
    }
}