@IPU_FIXBUG_2021@使用spring自带的SchedulerFactoryBean实现定时任务

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

@@ -1,11 +1,6 @@
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;
@@ -23,6 +18,7 @@ public class IpuCacheListener extends AbstractListener {
		try {
			log.debug(">>>>>>>>>>>>>>>>>>>new config from nacos:" + configInfo);
			IpuSpringNacosConfig config = SpringBeanUtil.getBean(IpuSpringNacosConfig.class);
			ScheduledTask scheduledTask = SpringBeanUtil.getBean(ScheduledTask.class);
			//新配置第二天0点0分1秒生效
			StringBuffer cron = new StringBuffer();
			cron.append("1").append(" 0").append(" 0 ");
@@ -32,8 +28,8 @@ public class IpuCacheListener extends AbstractListener {
			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);
//			scheduledTask.addCronJob("0 05 16 12 9 ? 2021", config.getIpuCacheDataid(), configInfo);
			scheduledTask.addCronJob(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

@@ -26,19 +26,19 @@ public class ScheduleIpuCacheJob implements Job {
						logger.debug("map:" + map);
						logger.debug("为ipu-cache添加配置成功");
					} catch (Exception e) {
						failed();
						failed(e);
					}
				}
			}).start();
		} catch (Exception e) {
			logger.error("为ipu-cache添加配置异常:" + e.getMessage());
			logger.error("为ipu-cache添加配置异常:" + e.toString(), e);
		}
	}
	private void failed() {
		logger.error("error");
	private void failed(Exception e) {
		logger.error("error " + e.toString(), e);
	}
}

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

@@ -1,40 +1,58 @@
package com.ai.ipu.server.demo.schedule;
import java.util.Map;
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.SchedulerException;  
import org.quartz.Trigger;  
import org.quartz.TriggerBuilder;  
import org.quartz.impl.StdSchedulerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import org.springframework.stereotype.Component;
import com.ai.ipu.basic.log.ILogger;
import com.ai.ipu.basic.log.IpuLoggerFactory;
  
@Component
public class ScheduledTask{  
	private static final ILogger logger = IpuLoggerFactory.createLogger(ScheduledTask.class);
	private static final ConcurrentMap<String, Scheduler> task = new ConcurrentHashMap<String, Scheduler>();
	private Map<String, Scheduler> task = new ConcurrentHashMap<String, Scheduler>();
	
	@Autowired
	SchedulerFactoryBean schedulerFactoryBean;
	
	public static void run(String cron, String dataId, String xml) 
	private void clearCronJob(Scheduler sched) throws SchedulerException {
		sched.shutdown();
		sched.clear();
	}
	public void addCronJob(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();
				clearCronJob(sched);
			}
			else
			{
				sched = sf.getScheduler();
				task.put(dataId, sched);
			{	
				synchronized (this) { 
					if (task.containsKey(dataId))
					{
						sched = task.get(dataId);
						clearCronJob(sched);
					}
					else
					{
						sched = schedulerFactoryBean.getScheduler();
						task.put(dataId, sched);
					}
				}
			}
			// Define job  
			JobDataMap newJobDataMap = new JobDataMap();
@@ -49,14 +67,11 @@ public class ScheduledTask{
	                .withIdentity("trigger1", "group1")  
	                .withSchedule(CronScheduleBuilder.cronSchedule(cron))  
	                .build();  
	        sched.scheduleJob(job, trigger);  
	        
	        // Start the job  
	        sched.start();  
	        sched.scheduleJob(job, trigger); 
	        
	        sched.start();
		} catch (SchedulerException e) {
			logger.error(e.getMessage());
		}  
        
    } 
			logger.error(e.toString(), e);
		}          
    }
}