Spring Boot整合Quartz定时任务框架

曾经终败给现在 2022-01-29 05:41 311阅读 0赞

本文介绍下Quartz框架的使用

> Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目，它可以与J2EE与J2SE应用程序相结合也可以单独使用。Quartz可以用来创建简单或为运行十个，百个，甚至是好几万个Jobs这样复杂的程序。Jobs可以做成标准的Java组件或 EJBs。Quartz的最新版本为Quartz 2.3.0。

# Quartz的使用 #

## 一、Quartz 的使用思路 ##

<table> 
 <thead> 
  <tr> 
   <th>组成</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>job - 任务</td> 
   <td align="left">你要做什么事？</td> 
  </tr> 
  <tr> 
   <td>Trigger - 触发器</td> 
   <td align="left">你什么时候去做？</td> 
  </tr> 
  <tr> 
   <td>Scheduler - 任务调度</td> 
   <td align="left">你什么时候需要去做什么事？</td> 
  </tr> 
 </tbody> 
</table>

## 二、Quartz 的基本使用方式 ##

### 1.创建项目添加依赖 ###

创建普通maven项目，添加相关依赖:

<dependency>
        <groupId>org.quartz-scheduler</groupId>
        <artifactId>quartz</artifactId>
        <version>2.2.1</version>
    </dependency>

### 2.创建job ###

/** * @program: spring-boot-schedueld-demo * @description: Quartz介绍Job * @author: 波波烤鸭 * @create: 2019-05-21 09:51 */
    public class QuartzDemo implements Job { 
        @Override
        public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { 
            System.out.println("quartz任务执行了...."+new Date());
        }
    }

### 3.测试 ###

通过主方法测试。

public static void main(String[] args) throws Exception{ 
         // 1、创建Job对象:你要做什么事?
         JobDetail job = JobBuilder.newJob(QuartzDemo.class).build();
         /** * 2、创建trigger * 简单的 trigger 触发时间：通过 Quartz 提供一个方法来完成简单的重复调用 cron * Trigger：按照 Cron 的表达式来给定触发的时间 */
         Trigger trigger = TriggerBuilder.newTrigger()
         .withSchedule(CronScheduleBuilder.cronSchedule("0/2 * * * * ?"))
         .build();
    
         // 3.创建Scheduled对象，在什么时候做什么事?
         Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
         scheduler.scheduleJob(job,trigger);
    
         // 启动
         scheduler.start();
     }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70]

## 三、SpringBoot整合Quartz ##

### 1.创建项目，添加依赖 ###

创建SpringBoot项目，添加如下依赖:

<dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.2.1</version>
            <exclusions>
                <exclusion>
                    <artifactId>slf4j-api</artifactId>
                    <groupId>org.slf4j</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
        </dependency>
        
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
        </dependency>
    
    </dependencies>

### 2.添加Quartz的配置类 ###

/** * @program: spring-boot-schedueld-demo * @description: Quartz的配置类 * @author: 波波烤鸭 * @create: 2019-05-21 10:09 */
    @Configuration
    public class QuartzConfig { 
        /** * 1.创建 Job 对象 */
        @Bean
        public JobDetailFactoryBean jobDetailFactoryBean() { 
            JobDetailFactoryBean factory = new JobDetailFactoryBean();
            //关联我们自己的 Job 类
            factory.setJobClass(QuartzDemo.class);
            return factory;
        }
    
        /** * 2.创建 Trigger 对象 * 简单的 Trigger */
        @Bean
        public SimpleTriggerFactoryBean simpleTriggerFactoryBean(JobDetailFactoryBean jobDetailFactoryBean) { 
            SimpleTriggerFactoryBean factory = new SimpleTriggerFactoryBean();
            //关联 JobDetail 对象
            factory.setJobDetail(jobDetailFactoryBean.getObject());
            //该参数表示一个执行的毫秒数
            factory.setRepeatInterval(2000);
            //重复次数
            factory.setRepeatCount(5);
            return factory;
        }
    
        /** * Cron Trigger */
        @Bean
        public CronTriggerFactoryBean cronTriggerFactoryBean(JobDetailFactoryBean jobDetailFactoryBean){ 
            CronTriggerFactoryBean factory = new CronTriggerFactoryBean();
            factory.setJobDetail(jobDetailFactoryBean.getObject());
            //设置触发时间
            factory.setCronExpression("0/2 * * * * ?");
            return factory;
        }
    
        /** * 3.创建 Scheduler 对象 */
        @Bean
        public SchedulerFactoryBean schedulerFactoryBean(CronTriggerFactoryBean cronTriggerFactoryBean) { 
            SchedulerFactoryBean factory = new SchedulerFactoryBean();
            //关联 trigger
            factory.setTriggers(cronTriggerFactoryBean.getObject());
            return factory;
        }
    }

### 3.单元测试 ###

@SpringBootApplication
    @EnableScheduling // 开启Scheduled定时任务
    public class SpringBootSchedueldDemoApplication { 
    
        public static void main(String[] args) { 
            SpringApplication.run(SpringBootSchedueldDemoApplication.class, args);
        }
    
    }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 1]

搞定~

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70]: /images/20220129/731e6c2184d248c3bc19b49df99a865e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9kcGItYm9ib2thb3lhLXNtLmJsb2cuY3Nkbi5uZXQ_size_16_color_FFFFFF_t_70 1]: /images/20220129/3be49229d53d48d7955d97a326bb1319.png