Spring Boot Quartz在Java Project中的使用

这一篇文章，我们紧接着上一篇的文章，讲讲在Quartz在java project的项目中如何进行使用，在这里我们使用maven进行构建项目。先看下本章的大纲：

（1）新建工程quartz-java;

（2）配置pom.xml文件；

（3）编码说明；

（4）编写Job类；

（5）编写启动类进行代码测试；

（6）quartz.properties配置文件说明；

接下里一起看下具体的内容：

（1）新建工程quartz-java;

新建一个java project取名为quartz-java。

（2）配置pom.xml文件；

在pom.xml文件中添加quartz的依赖：

<groupId>org.quartz-scheduler<span class="hljs-name"groupId>

 <artifactId>quartz<span class="hljs-name"artifactId>

 <version>2.2.3<span class="hljs-name"version>

（3）编码说明；

（一）首先我们需要定义一个任务类，比如为HelloJob ，该类需要继承Job类，然后添加execute(JobExecutionContext context)方法，在这个方法中就是我们具体的任务执行的地方。

（二）在哪里定义“在什么时候执行什么任务呢？”：那么我们需要Scheduler，此类的创建方式使用Quartz提供的工厂类StdSchedulerFactory.getDefaultScheduler()进行创建。

（三）如何触发呢：scheduler.scheduleJob(jobDetail,trigger);进行触发定时任务，在这里需要两个参数。jobDetail可以通过JobBuilder.newJob进行创建，在这里就需要制定一个Job类了，也就是我们第一步创建的HelloJob；trigger类的话，可以通过TriggerBuilder.newTrigger进行创建。

（4）编写Job类；

编写HelloJob任务类：

package com.kfit.job;

import java.util.Date;

import org.quartz.Job;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

/**

• 任务类.
• @author Angel --守护天使
• @version v.0.1
• @date 2017年4月21日

*/

**public **class HelloJob implements Job{

**public ****void** execute(JobExecutionContext context) **throws**JobExecutionException {

    // 执行响应的任务.

   System. ***out*** .println("HelloJob.execute,"+**new** Date());

}

}

（5）编写启动类进行代码测试；

在Main方法中进行编码测试：

package com.kfit;

import java.util.concurrent.TimeUnit;

import org.quartz.JobBuilder;

import org.quartz.JobDetail;

import org.quartz.Scheduler;

import org.quartz.SchedulerException;

import org.quartz.SimpleScheduleBuilder;

import org.quartz.Trigger;

import org.quartz.TriggerBuilder;

import org.quartz.impl.StdSchedulerFactory;

import com.kfit.job.HelloJob;

/**

• 直接在Main方法中进行启动测试.
• @author Angel --守护天使
• @version v.0.1
• @date 2017年4月21日

*/

**public **class App {

**public ****static ****void** main(String[] args) **throws** SchedulerException, InterruptedException {

   /*

    *在 Quartz 中， scheduler 由 scheduler 工厂创建：DirectSchedulerFactory或者StdSchedulerFactory。第二种工厂StdSchedulerFactory 使用较多，

    *因为DirectSchedulerFactory 使用起来不够方便，需要作许多详细的手工编码设置。

    */

   // 获取Scheduler实例

   Scheduler scheduler = StdSchedulerFactory. *getDefaultScheduler* ();

   scheduler.start();

   System. ***out*** .println("scheduler.start");

  

   //具体任务.

   JobDetail jobDetail = JobBuilder. *newJob* (HelloJob. **class** ).withIdentity("job1","group1").build();

  

   //触发时间点. (每5秒执行1次.)

   SimpleScheduleBuilder simpleScheduleBuilder =SimpleScheduleBuilder. *simpleSchedule* ().withIntervalInSeconds(5).repeatForever();

   Trigger trigger = TriggerBuilder. *newTrigger* ().withIdentity("trigger1","group1").startNow().withSchedule(simpleScheduleBuilder).build();

  

   // 交由Scheduler安排触发

   scheduler.scheduleJob(jobDetail,trigger);

  

   //睡眠20秒.

   TimeUnit. ***SECONDS*** .sleep(20);

   scheduler.shutdown();//关闭定时任务调度器.

   System. ***out*** .println("scheduler.shutdown");

}

}

执行代码查看控制台的打印信息：

scheduler.start

HelloJob.execute,Fri Apr 2119:50:01 CST 2017

HelloJob.execute,Fri Apr 2119:50:06 CST 2017

HelloJob.execute,Fri Apr 2119:50:11 CST 2017

HelloJob.execute,Fri Apr 2119:50:16 CST 2017

HelloJob.execute,Fri Apr 2119:50:21 CST 2017

scheduler.shutdown

（6）quartz.properties配置文件说明；

Quartz中有一个配置quartz.properties可以配置参数，比如：线程池的容量，实例名称。比如：

org.quartz.scheduler.instanceName= MyScheduler

org.quartz.threadPool.threadCount= 3

org.quartz.jobStore.class=org.quartz.simpl.RAMJobStore

org.quartz.threadPool.threadCount：配置线程池的容量，即表示同时最多可运行的线程数量。

org.quartz.scheduler.instanceName：scheduler实例名称。

org.quartz.jobStore.class：job存储方式，RAMJobStore是使用JobStore最简单的一种方式，它也是性能最高效的，顾名思义，JobStore是把它的数据都存储在RAM中，这也是它的快速和简单配置的原因；JDBCJobStore也是一种相当有名的JobStore，它通过JDBC把数据都保存到数据库中，所以在配置上会比RAMJobStore复杂一些，而且不像RAMJobStore那么快，但是当我们对数据库中的表的主键创建索引时，性能上的缺点就不是很关键的了。

您可以在代码中打印scheduler实例名称，如下代码：

Scheduler scheduler =StdSchedulerFactory. getDefaultScheduler ();

scheduler.start();

   System. ***out*** .println("scheduler.start");

   System. ***out*** .println(scheduler.getSchedulerName());