简单 Quartz定时器使用入门

拼搏现实的明天。 2023-06-18 05:54 10阅读 0赞

### 简单 Quartz定时器使用 入门 ###

*  Quartz介绍
 *   *  Quartz的触发器
     *  存储方式
     *  如何使用
     *  新建任务
     *  新建Dome定时器 首先演示SimpleTrigger
     *  接下来就是CronTrigger

# Quartz介绍 #

任务调度框架“Quartz”是OpenSymphony开源组织在Job scheduling领域又一个开源项目，是完全由java开发的一个开源的任务日程管理系统，“任务进度管理器”就是一个在预先确定（被纳入日程）的时间到达时，负责执行（或者通知）其他软件组件的系统  
简单来说就是实现“计划(或定时)任务”的系统，例如：订单下单后未付款，15分钟后自动撤消订单，并自动解锁锁定的商品

## Quartz的触发器 ##

触发器用来告诉调度程序作业什么时候触发。框架提供了5种触发器类型，但两个最常用的SimpleTrigger和CronTrigger

五种类型的Trigger(定时器)

1.  **SimpleTrigger**；
2.  **CronTirgger**；
3.  **DateIntervalTrigger**；
4.  **NthIncludedDayTrigger**；
5.  **Calendar**；

在这里简单介绍下两种常用的触发器  
场景：  
SimpleTrigger：执行N次，重复N次  
CronTrigger：几秒 几分 几时 哪日 哪月 哪周 哪年，执行

## 存储方式 ##

RAMJobStore(内存作业存储类型)和JDBCJobStore(数据库作业存储类型)，两种方式对比如下：  
RAMJobStore  
**优缺点：**  
不要外部数据库，配置容易，运行速度快 因为调度程序信息是存储在被分配给JVM的内存里面，所以，当应用程序停止运行时，所有调度信息将被丢失。另外因为存储到JVM内存里面，所以可以存储多少个Job和Trigger将会受到限制。

JDBCJobStor  
**优缺点**  
支持集群，因为所有的任务信息都会保存到数据库中 运行速度的快慢取决与连接数据库快慢 ，可以控制事物，还有就是如果应用服务器关闭或者重启，任务信息都不会丢失，并且可以恢复因服务器关闭或者重启而导致执行失败的任务 。

## 如何使用 ##

首先新建一个maven工程  
加入pom依赖

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

## 新建任务 ##

新建任务就是 ：定时器到设定时间的时候会调用的方法  
这里需要实现Job(作业)接口

package com.zking.quartz01.util;
    
    import org.quartz.*;
    
    /** * 功能描述: <br> * 〈〉 作业 * @Param: * @Return: * @Author: 骄傲的骨傲天 * @Date: 2019/11/30 14:26 */
    public class MyJob implements Job { 
        @Override
        public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { 
            System.out.println("这是一个简单的任务");
    		System.out.println("name="+jobDataMap.get("name")+",age="+jobDataMap.get("age"));
        }
    }

## 新建Dome定时器 首先演示SimpleTrigger ##

定时任务可以分为五个步骤

1.  创建SchedulerFactory工厂类
2.  创建Scheduler调度器实例
3.  创建JobDetail
4.  创建Trigger（SimpleTrigger和CronTrigger）
5.  将JobDetail和Trigger注入到Scheduler调度器中
6.  启动任务

下面时代码展示

package com.zking.quartz01.util;
    
    import org.quartz.*;
    import org.quartz.impl.StdSchedulerFactory;
    
    import java.util.Date;
    
    import static org.quartz.JobBuilder.newJob;
    
    public class Demo { 
        public static void main(String[] args) { 
            try { 
                //1.创建SchedulerFactory工厂类
                SchedulerFactory schedulerFactory=new StdSchedulerFactory();
                //2.创建Scheduler调度器实例
                Scheduler scheduler=schedulerFactory.getScheduler();
                //3.创建JobDetail
                JobDetail jobDetail=newJob(MyJob.class)
                        .withDescription("this is a jobDetail!!!")
                        .withIdentity("jobname1","jobgroup1")
                        //有两种方式设置外部参数到Job中，这是第一种
    // .usingJobData("name","张三")
    // .usingJobData("age",12) 
                        .build();
    
                //第二种
                JobDataMap jobDataMap=jobDetail.getJobDataMap();
                jobDataMap.put("name","李四");
                jobDataMap.put("age",12);
                
                //4.创建Trigger（SimpleTrigger和CronTrigger）
                //SimpleTrigger:执行N次，重复N次
                long start=System.currentTimeMillis()+3*1000L;  //3秒钟后执行
                Date date=new Date(start);
    
                Trigger trigger= TriggerBuilder.newTrigger()
                        .withDescription("this is a trigger")
                        .withIdentity("jobname1","jobgroup1")
                        //设置定时规则 这里是：重复二次 每次三秒后执行
                        .withSchedule(SimpleScheduleBuilder.simpleSchedule()
                                .withIntervalInSeconds(3).withRepeatCount(2))   
                        .build();
                //5.将JobDetail和Trigger注入到Scheduler调度器中
                scheduler.scheduleJob(jobDetail,trigger);
    
                //6.启动任务
                scheduler.start();
            } catch (Exception e) { 
                e.printStackTrace();
            }
        }
    
    }

结果

"C:\Program Files\Java\jdk1.8.0_131\bin\java" "-javaagent:F:\develop\Idea2017\Idea2017\IntelliJ IDEA 2017.3.1\lib\idea_rt.jar=9996:F:\develop\Idea2017\Idea2017\IntelliJ IDEA 2017.3.1\bin" -Dfile.encoding=UTF-8 -classpath "C:\Program Files\Java\jdk1.8.0_131\jre\lib\charsets.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\deploy.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\access-bridge-64.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\cldrdata.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\dnsns.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\jaccess.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\jfxrt.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\localedata.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\nashorn.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\sunec.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\sunjce_provider.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\sunmscapi.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\sunpkcs11.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\ext\zipfs.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\javaws.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\jce.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\jfr.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\jfxswt.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\jsse.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\management-agent.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\plugin.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\resources.jar;C:\Program Files\Java\jdk1.8.0_131\jre\lib\rt.jar;F:\develop\Idea2017\Quartz\quartz01\target\classes;E:\repository\mvn-repository\org\quartz-scheduler\quartz\2.2.1\quartz-2.2.1.jar;E:\repository\mvn-repository\c3p0\c3p0\0.9.1.1\c3p0-0.9.1.1.jar;E:\repository\mvn-repository\org\slf4j\slf4j-api\1.6.6\slf4j-api-1.6.6.jar;E:\repository\mvn-repository\org\quartz-scheduler\quartz-jobs\2.2.1\quartz-jobs-2.2.1.jar" com.zking.quartz01.util.Demo
    SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
    SLF4J: Defaulting to no-operation (NOP) logger implementation
    SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
    这是一个简单的任务
    name=李四,age=12
    这是一个简单的任务
    name=李四,age=12
    这是一个简单的任务
    name=李四,age=12

欸！为啥我定时规则设定重复两次为什么输出了三个  
因为启动定时器的时候会自动执行一次，然后在根据定时规则执行，所以就有了三次输出。  
如果你想执行两次

> .withRepeatCount(2) 改为1就好

## 接下来就是CronTrigger ##

这种定时器比SimpleTrigger更加灵活  
因为它是根据表达式制定定时规则  
[Quartz表达式在线生成][Quartz]

贴上代码

package com.zking.quartz01.util;
    
    import org.quartz.*;
    import org.quartz.impl.StdSchedulerFactory;
    
    import java.util.Date;
    
    import static org.quartz.JobBuilder.newJob;
    
    public class Demo { 
        public static void main(String[] args) { 
            try { 
                //1.创建SchedulerFactory工厂类
                SchedulerFactory schedulerFactory=new StdSchedulerFactory();
                //2.创建Scheduler调度器实例
                Scheduler scheduler=schedulerFactory.getScheduler();
                //3.创建JobDetail
                JobDetail jobDetail=newJob(MyJob.class)
                        .withDescription("this is a jobDetail!!!")
                        .withIdentity("jobname1","jobgroup1")// 每个线程都需要个主键,确保不会重复
    // .usingJobData("name","张三")
    // .usingJobData("age",12) //有两种凡是设置外部参数到Job中，这是第一种
                        .build();
    
                //第二种
                JobDataMap jobDataMap=jobDetail.getJobDataMap();
                jobDataMap.put("name","李四");
                jobDataMap.put("age",12);
                //4.创建Trigger（CronTrigger）
                //CronTrigger：几秒 几分 几时 哪日 哪月 哪周 哪年，执行
                Trigger trigger= TriggerBuilder.newTrigger()
                        .withDescription("this is a trigger")
                        .withIdentity("jobname1","jobgroup1")  //主键
                        //每隔五秒执行一次
                        .withSchedule(CronScheduleBuilder.cronSchedule("*/5 * * * * ?"))
                        .build();
                //5.将JobDetail和Trigger注入到Scheduler调度器中
                scheduler.scheduleJob(jobDetail,trigger);
    
                //6.启动任务
                scheduler.start();
            } catch (Exception e) { 
                e.printStackTrace();
            }
        }
    
    }

以上

[Quartz]: http://www.bejson.com/othertools/cron/