SpringBoot+ MySQL +Dubbo+scheduling实现动态定时添加

左手的ㄟ右手 2023-10-18 16:47 9阅读 0赞

前景提要：spring自带的scheduling定时调度任务相当于轻量级的Quartz,但是不支持分布式,若要实现分布式定时任务就得使用Quartz。

1、项目整体结构：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70][]

2、定时任务核心代码：

程序入口：

package com.zzg;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.context.annotation.ImportResource;
    
    @SpringBootApplication
    @ImportResource({"classpath:dubbo-consumer.xml"})
    public class Application {
    
    	public static void main(String[] args) {
    		// TODO Auto-generated method stub
    		SpringApplication.run(Application.class, args);
    	}
    
    }

容器Bean组件类：

package com.zzg.application;
    
    import org.springframework.beans.BeansException;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.ApplicationContextAware;
    import org.springframework.stereotype.Component;
    
    
    @Component
    public class SpringBeanUtil implements ApplicationContextAware {
    	private static ApplicationContext applicationContext;
    	@Override
    	public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
    		// TODO Auto-generated method stub
    		 if(SpringBeanUtil.applicationContext == null) {
    			 SpringBeanUtil.applicationContext = applicationContext;
    	     }
    	}
    	
    	//获取applicationContext
        public static ApplicationContext getApplicationContext() {
            return applicationContext;
        }
    
        //通过name获取 Bean.
        public static Object getBean(String name){
            return getApplicationContext().getBean(name);
        }
    
        //通过class获取Bean.
        public static <T> T getBean(Class<T> clazz){
            return getApplicationContext().getBean(clazz);
        }
    
        //通过name,以及Clazz返回指定的Bean
        public static <T> T getBean(String name,Class<T> clazz){
            return getApplicationContext().getBean(name, clazz);
        }
    
    }

定时任务抽象类：

package com.zzg.cron.abstr;
    
    /**
     * 
     * @ClassName:  CronAbstract   
     * @Description: 定时任务抽象类
     * @author: 世纪伟图 -zzg
     * @date:   2019年4月9日 上午9:39:47   
     *     
     * @Copyright: 2019 www.digipower.cn 
     * 注意：本内容仅限于深圳市世纪伟图科技开发有限公司内部使用，禁止用于其他的商业目的
     */
    public abstract class CronAbstract implements Runnable {
    	public abstract void execute();
    
    	@Override
    	public void run() {
    		// TODO Auto-generated method stub
    		this.execute();
    	}
    	
    	
    }

定时任务实列化组件：

package com.zzg.cron.component;
    
    import org.springframework.stereotype.Component;
    import com.zzg.cron.abstr.CronAbstract;
    
    @Component("cronObject")
    public class CronObject extends CronAbstract {
    
    	@Override
    	public void execute() {
    		// TODO Auto-generated method stub
    		System.out.println("CronObject 对象执行输出任务");
    	}
    
    }

定时任务配置类：

package com.zzg.cron.config;
    
    import java.util.Date;
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.Trigger;
    import org.springframework.scheduling.TriggerContext;
    import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.scheduling.annotation.SchedulingConfigurer;
    import org.springframework.scheduling.config.ScheduledTaskRegistrar;
    import org.springframework.scheduling.support.CronTrigger;
    
    import com.zzg.api.CronService;
    import com.zzg.application.SpringBeanUtil;
    import com.zzg.entity.Cron;
    
    @Configuration
    @EnableScheduling
    public class CronScheduleConfig implements SchedulingConfigurer{
    	@Autowired
    	private CronService service;
    	@Autowired
    	private SpringBeanUtil container;
    	@Override
    	public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
    		// TODO Auto-generated method stub
    		List<Cron> list = service.getCrons();
    		if(list != null && list.size() > 0){
    			list.stream().forEach(item ->{
    				// 获取task 对象
    				String cronName = item.getCron_name();
    				Runnable task = (Runnable) container.getBean(cronName);
    				Trigger trigger = new Trigger() {
    					@Override
    					public Date nextExecutionTime(TriggerContext triggerContext) {
    						// TODO Auto-generated method stub
    						CronTrigger trigger = new CronTrigger(item.getCron_time());
    						Date nextExec = trigger.nextExecutionTime(triggerContext);
    						return nextExec;
    					}
    				};
    				// 添加cron 任务
    				taskRegistrar.addTriggerTask(task, trigger);
    				
    			});
    		}
    		
    	}
    
    }

dubbo 服务配置文件，在这里不做讲解。

sql 语句：

DROP TABLE IF EXISTS `cron`;
    CREATE TABLE `cron`  (
      `id` int(11) NOT NULL AUTO_INCREMENT,
      `cron_name` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      `cron_time` varchar(255) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
      PRIMARY KEY (`id`) USING BTREE
    ) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic;
    
    -- ----------------------------
    -- Records of cron
    -- ----------------------------
    INSERT INTO `cron` VALUES (1, 'cronObject', '0 0/2 * * * ?');

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20190409101013107.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n,size_16,color_FFFFFF,t_70