SpringBoot Quartz

什么是Quartz

Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目，完全由Java开发，可以用来执行定时任务，类似于java.util.Timer。但是相较于Timer， Quartz增加了很多功能：

持久性作业 - 就是保持调度定时的状态;
作业管理 - 对调度作业进行有效的管理;

在实际项目开发中，随着业务的增大，需要操作Job的也就越多，肯定不能是人工操作，我们需要应该自动调度的任务框架去解决，功能的具体实现如下：

首先我们需要定义实现一个定时功能的接口，我们可以称之为Task或者Job（Quartz中称之为Job），如定时发送邮件Job，优惠卷到期通知Job，实现如下：
有了Job之后，我们需要一个能触发Job并执行的触发器（Trigger），Trigger最基本的功能是指定Job的执行时间，执行间隔，运行次数等。
有了Job和Trigger后，需要一个Schedule，来指定Trigger去执行指定的Job。

上面三个部分就是Quartz的基本组成部分：

调度器：Scheduler
任务：JobDetail
触发器：Trigger，包括SimpleTrigger和CronTrigger

Quartz在SpringBoot的应用

使用Maven添加依赖

<!-- SpringBoot 整合 Quartz 定时任务 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-quartz</artifactId>
    <version>2.3.5.RELEASE</version>
</dependency>

配置yml

spring:
  quartz:
    scheduler-name: communityScheduler//scheduler名称
    job-store-type: jdbc//持久化方法

实现Job接口，实现定时任务逻辑

public class AlphaJob implements Job {
    //实现Job接口
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        System.out.println(Thread.currentThread().getName()+": execute a quartz job.");
    }
}

配值定时任务，创建一个Config类，设置

//配置-》数据库-》调用
//Quartz 定时任务配置类
@Configuration
public class QuartzConfig {
    //FactoryBean可简化Bean的实例化过程：
    //1.通过FactoryBean封装Bean的实例化过程
    //2.将FactoryBean封装到Spring容器中
    //3.将FactoryBean注入给其他的Bean
    //4.该Bean得到的是FactoryBean所管理的对象实例

    // 配置JobDetail
    @Bean
    public JobDetailFactoryBean alphaJobDetail(){
        JobDetailFactoryBean factoryBean = new JobDetailFactoryBean();
        factoryBean.setJobClass(AlphaJob.class);
        factoryBean.setName("alphaJob");//设置名称
        factoryBean.setGroup("alphaJobGroup");//设置分组
        factoryBean.setDurability(true);//是否持久(数据库中是否删除)
        factoryBean.setRequestsRecovery(true);//是否可恢复
        return factoryBean;
    }

    // 配置Trigger(SimpleTriggerFactoryBean(简单任务用，按指定的时间间隔执行多少次任务的情况),CronTriggerFactoryBean(复杂任务用，通过Cron表达式来控制任务的执行时间))
    @Bean
    public SimpleTriggerFactoryBean alphaTrigger(JobDetail alphaJobDetail){
        SimpleTriggerFactoryBean factoryBean = new SimpleTriggerFactoryBean();
        factoryBean.setJobDetail(alphaJobDetail);//关联上述JobDetail
        factoryBean.setName("alphaTrigger");//设置名称
        factoryBean.setGroup("alphaTriggerGroup");//设置分组
        factoryBean.setRepeatInterval(3000);//设置执行的时间间隔
        factoryBean.setJobDataMap(new JobDataMap());
        return factoryBean;
    }
}