六、SpringBoot +Quartz整合多定时任务同时执行

布满荆棘的人生 2022-04-03 15:22 1190阅读 0赞

本例中设置的是双任务每五秒钟同时执行一次，如果要设置多个任务，直接根据注释说明添加第三个任务即可，已经验证过，可以实现，因为刚开始接触Quartz，运行过程中会遇到什么问题目前不清楚，仅是多任务同时定时同时执行的实现

build.gradle中配置

compile 'org.quartz-scheduler:quartz:2.1.6'

第一个执行类RefreshTrbase

import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.stereotype.Component;
    
    @Component
    @EnableScheduling
    public class RefreshTrbase {
    
        public void getTrbase(){
            System.out.println("1111111....");
        }
    }

第二个执行类RefreshNews

import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.stereotype.Component;
    
    @Component
    @EnableScheduling
    public class RefreshNews {
        public void getNews(){
            System.out.println("222222....");
        }
    }

Quartz配置类

import org.quartz.JobDetail;
    import org.quartz.Trigger;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.scheduling.quartz.CronTriggerFactoryBean;
    import org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean;
    import org.springframework.scheduling.quartz.SchedulerFactoryBean;
    import org.springframework.scheduling.quartz.SimpleTriggerFactoryBean;
    
    @Configuration
    public class QuartzConfiguration {
        // 配置定时任务1
        @Bean(name = "firstJobDetail")
        public MethodInvokingJobDetailFactoryBean firstJobDetail(RefreshNews refreshNews) {
            MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();
            // 是否并发执行
            jobDetail.setConcurrent(false);
            // 为需要执行的实体类对应的对象
            jobDetail.setTargetObject(refreshNews);
            // 需要执行的方法
            jobDetail.setTargetMethod("getNews");
            return jobDetail;
        }
    
    
        // 配置触发器1
        @Bean(name = "firstTrigger")
        public SimpleTriggerFactoryBean firstTrigger(JobDetail firstJobDetail) {
            SimpleTriggerFactoryBean trigger = new SimpleTriggerFactoryBean();
            trigger.setJobDetail(firstJobDetail);
            // 设置任务启动延迟
            trigger.setStartDelay(0);
            // 设置定时任务启动时间
            trigger.setStartTime(new Date(DateUtil.getNowTimeInMillis()));
            // 每5秒执行一次
            trigger.setRepeatInterval(5000);
            return trigger;
        }
    
        // 配置定时任务2
        @Bean(name = "secondJobDetail")
        public MethodInvokingJobDetailFactoryBean secondJobDetail(RefreshTrbase refreshTrbase) {
            MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();
            // 是否并发执行
            jobDetail.setConcurrent(true);
            // 为需要执行的实体类对应的对象
            jobDetail.setTargetObject(refreshTrbase);
            // 需要执行的方法
            jobDetail.setTargetMethod("getTrbase");
            return jobDetail;
        }
    
        // 配置触发器2
        @Bean(name = "secondTrigger")
        public SimpleTriggerFactoryBean secondTrigger(JobDetail secondJobDetail) {
            SimpleTriggerFactoryBean trigger = new SimpleTriggerFactoryBean();
            trigger.setJobDetail(secondJobDetail);
            // 设置定时任务启动时间
            trigger.setStartTime(new Date(DateUtil.getNowTimeInMillis()));
            // cron表达式
            trigger.setRepeatInterval(5000);
            return trigger;
        }
    
        // 配置Scheduler
        @Bean(name = "scheduler")
        public SchedulerFactoryBean schedulerFactory(Trigger firstTrigger, Trigger secondTrigger) {
            SchedulerFactoryBean bean = new SchedulerFactoryBean();
            // 延时启动，应用启动1秒后
            bean.setStartupDelay(1);
            // 注册触发器
            bean.setTriggers(firstTrigger,secondTrigger);
            return bean;
        }
    }

以上已经实现两种任务每5s执行一次，若要添加多种任务则

第三个任务Hehe

import org.springframework.scheduling.annotation.EnableScheduling;
    import org.springframework.stereotype.Component;
    
    @Component
    @EnableScheduling
    public class Hehe {
        public void getHehe(){
            System.out.println("获取呵呵....");
        }
    }

QuartzConfiguration中修改如下

// 配置定时任务3
        @Bean(name = "thirdJobDetail")
        public MethodInvokingJobDetailFactoryBean thirdJobDetail(Hehe hehe) {
            MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();
            // 是否并发执行
            jobDetail.setConcurrent(true);
            // 为需要执行的实体类对应的对象
            jobDetail.setTargetObject(hehe);
            // 需要执行的方法
            jobDetail.setTargetMethod("getHehe");
            return jobDetail;
        }
    
        // 配置触发器3
        @Bean(name = "thirdTrigger")
        public SimpleTriggerFactoryBean thirdTrigger(JobDetail thirdJobDetail) {
            SimpleTriggerFactoryBean trigger = new SimpleTriggerFactoryBean();
            trigger.setJobDetail(thirdJobDetail);
            // cron表达式
            trigger.setRepeatInterval(5000);
            return trigger;
        }
    
        // 配置Scheduler
        @Bean(name = "scheduler")
        public SchedulerFactoryBean schedulerFactory(Trigger firstTrigger, Trigger secondTrigger, Trigger thirdTrigger) {
            SchedulerFactoryBean bean = new SchedulerFactoryBean();
            // 延时启动，应用启动1秒后
            bean.setStartupDelay(1);
            // 注册触发器
            bean.setTriggers(firstTrigger,secondTrigger,thirdTrigger);
            return bean;
        }

执行结果：打印内容自己设置测试

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTk5NjYzMg_size_16_color_FFFFFF_t_70][]

### 说明：  ###

以上代码是间隔时间启动定时任务，如果要在固定时间(比如每周一九点执行)，则修改以上代码设置按以下进行修改，以下代码是每一分钟执行一次

// 配置触发器2
        @Bean(name = "secondTrigger")
        public CronTriggerFactoryBean secondTrigger(JobDetail secondJobDetail) {
            CronTriggerFactoryBean trigger = new CronTriggerFactoryBean();
            trigger.setJobDetail(secondJobDetail);
            // 设置任务启动延迟
    //      trigger.setStartDelay(0);
    //      trigger.setStartTime(new Date(DateUtil.getCurrentWeekTimeInMillis()));
            trigger.setStartTime(new Date(DateUtil.getNowTimeInMillis()));
            // cron表达式(设置间隔60s) 7天(d)=604800000毫秒(ms)
            trigger.setCronExpression("0 * * * * ?");
            return trigger;
        }

文章参考：[https://blog.csdn.net/wk52525/article/details/79100973][https_blog.csdn.net_wk52525_article_details_79100973]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MTk5NjYzMg_size_16_color_FFFFFF_t_70]: /images/20220403/22be96dec3934bc09158db5cc8432330.png
[https_blog.csdn.net_wk52525_article_details_79100973]: https://blog.csdn.net/wk52525/article/details/79100973