spring-boot-quartz的任务管理

本是古典何须时尚 2024-02-19 13:34 37阅读 0赞

1.Quartz:来触发和执行作业

2.表结构 （官方提供了11张表）

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70][]

[表结构说明][Link 1]

表位置:

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70 1][]

SpringbootQuartz配置：

import java.io.IOException;
    import java.util.Properties;
    import org.quartz.Scheduler;
    import org.quartz.ee.servlet.QuartzInitializerListener;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.config.PropertiesFactoryBean;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.io.ClassPathResource;
    import org.springframework.scheduling.quartz.SchedulerFactoryBean;
    /**
     * quartz配置
     */
    @Configuration
    public class SchedulerConfig {
    	
    	@Autowired
    	private SpringJobFactory springJobFactory;
    	
        @Bean(name="SchedulerFactory")
        public SchedulerFactoryBean schedulerFactoryBean() throws IOException {
            SchedulerFactoryBean factory = new SchedulerFactoryBean();
            factory.setAutoStartup(true);
            factory.setStartupDelay(5);//延时5秒启动
            factory.setQuartzProperties(quartzProperties());
            factory.setJobFactory(springJobFactory);  
            return factory;
        }
    
        @Bean
        public Properties quartzProperties() throws IOException {
            PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
            propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));
            propertiesFactoryBean.afterPropertiesSet();
            return propertiesFactoryBean.getObject();
        }
    
        /*
         * quartz初始化监听器
         */
        @Bean
        public QuartzInitializerListener executorListener() {
           return new QuartzInitializerListener();
        }
    
        /*
         * 通过SchedulerFactoryBean获取Scheduler的实例
         */
        @Bean(name="Scheduler")
        public Scheduler scheduler() throws IOException {
            return schedulerFactoryBean().getScheduler();
        }
    
    }

import org.quartz.spi.TriggerFiredBundle;  
    import org.springframework.beans.factory.annotation.Autowired;  
    import org.springframework.beans.factory.config.AutowireCapableBeanFactory;  
    import org.springframework.scheduling.quartz.AdaptableJobFactory;  
    import org.springframework.stereotype.Component;
    /**
     * 解决spring bean注入Job的问题
     */
    @Component  
    public class SpringJobFactory extends AdaptableJobFactory  {       
        @Autowired    
        private AutowireCapableBeanFactory capableBeanFactory;    
        
        @Override    
        protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {    
               
            Object jobInstance = super.createJobInstance(bundle);    
              
            capableBeanFactory.autowireBean(jobInstance);    
            return jobInstance;    
        }    
    }

springboot启动时候自动执行定时任务

import com.maobc.quartz.entity.QuartzEntity;
    import org.quartz.CronScheduleBuilder;
    import org.quartz.JobBuilder;
    import org.quartz.JobDetail;
    import org.quartz.Scheduler;
    import org.quartz.Trigger;
    import org.quartz.TriggerBuilder;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.boot.ApplicationArguments;
    import org.springframework.boot.ApplicationRunner;
    import org.springframework.stereotype.Component;
    
    import com.maobc.quartz.service.IJobService;
    @Component
    public class TaskRunner implements ApplicationRunner{
       
    
    	@Autowired @Qualifier("Scheduler")
        private Scheduler scheduler;
    	
       
    	@Override
        public void run(ApplicationArguments var) throws Exception{
        		LOGGER.info("初始化测试任务");
        		QuartzEntity quartz = new QuartzEntity();
        		quartz.setJobName("test");
        		quartz.setJobGroup("test");
        		quartz.setDescription("测试任务");
        		quartz.setJobClassName("com.xxx.quartz.job.StoreDiscountJob");
        		quartz.setCronExpression("0/20 * * * * ?");
       	        Class cls = Class.forName(quartz.getJobClassName()) ;
       	        cls.newInstance();
       	        //构建job信息
       	        JobDetail job = JobBuilder.newJob(cls).withIdentity(quartz.getJobName(),
       	        		quartz.getJobGroup())
       	        		.withDescription(quartz.getDescription()).build();
       	        // 触发时间点
       	        CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(quartz.getCronExpression());
       	        Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger"+quartz.getJobName(), quartz.getJobGroup())
       	                .startNow().withSchedule(cronScheduleBuilder).build();	
       	        //交由Scheduler安排触发
       	        scheduler.scheduleJob(job, trigger);
        	}
        }
    
    }

public class StoreDiscountJob implements Job, Serializable {
    
        private static final long serialVersionUID = 1L;
    
        @Autowired
        private StoreDiscountService storeDiscountService;
    
        @Override
        public void execute(JobExecutionContext context) throws JobExecutionException {
            System.out.println("开启任务");
            //TODO 业务逻辑
            System.out.println("结束任务");
        }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/73a4c29a989c4276a30a4c13a6b3b6f7.png
[Link 1]: https://www.cnblogs.com/Rozdy/p/4269762.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzU0OTU3OA_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/158190b24ab345c4993140d41e1b0ff7.png