Quartz使用介紹

Qaurtz简介

Quartz是一个完全由java编写的任务调度框架。
那么什么是任务调度呢&＃xff1f;很多时候你可能会收到某个需求&＃xff0c;要求程序 “ 隔某个特定的时间段在某个特定的时间做某个特定的事情 ”&＃xff0c;比如&＃xff1a;

每天早上8:00自动发送早安给你的爸爸妈妈
每年12月1日0点发送生日祝福给你的朋友
每个月的9号自动还款蚂蚁花呗

这些都是任务调度。而Quartz就是可以方便你创建各种任务定时执行的一个框架&＃xff0c;而且触发这些任务的时间点可以设计的非常复杂&＃xff0c;几乎都能完美匹配你的要求。

优点

简单高效。Quartz用起来非常简单。你只要写一个继承org.quartz.Job的job类&＃xff0c;将逻辑写入execute()方法&＃xff0c;并将这个类设定好时间&＃xff0c;之后Quartz就能自动帮你监控这个任务&＃xff0c;到了指定时间自动执行&＃xff0c;就不再需要你管这些任务了。
容错。如果其中的一个节点挂了&＃xff0c;并不会影响其他节点上面任务的执行。
支持分布式

主要API

Scheduler - 与调度器交互的主要API。
Job - 需要被调度器调度的任务必须实现的接口。
JobDetail - 用于定义任务的实例。
Trigger - 用于定义调度器何时调度任务执行的组件。
JobBuilder - 用于定义或创建JobDetail的实例。
TriggerBuilder - 用于定义或创建触发器实例。

实例介绍

使用Quartz开发&＃xff0c;首先&＃xff0c;你要写一个实现org.quartz.Job的类&＃xff0c;重写org.quartz.Job接口唯一的方法execute()&＃xff0c;在这个方法里面写你要定时执行的代码。

public class TestJob implements Job{public void execute(JobExecutionContext arg0) throws JobExecutionException {Date date&＃61;new Date();SimpleDateFormat sf &＃61; new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");System.out.print("now:"&＃43;sf.format(date));} }

然后&＃xff0c;创建一个执行任务的类&＃xff0c;创建scheduler&＃xff0c;这可以理解为一个调度程序-任务执行计划表&＃xff0c;在这个表里面对各个job任务进行时间分配。

SchedulerFactory sfact &＃61; new StdSchedulerFactory(); Scheduler schedule &＃61; sfact.getScheduler();

然后&＃xff0c;创建JobDetail的实例&＃xff0c;指定执行哪个job。

JobDetail jobDetail1 &＃61; JobBuilder.newJob((Class) TestJob.class) //定义Job类为TestJob类.withIdentity("myjob1", "group1") //定义name、group.build();

然后&＃xff0c;创建一个CronTrigger实例&＃xff0c;指定执行时间。

CronTrigger trigger1 &＃61;(CronTrigger) TriggerBuilder.newTrigger().withIdentity("trigger1", "group1").withSchedule(CronScheduleBuilder.cronSchedule("0 0 10 ? * MON")) //每週一早上十點執行.build();

最后&＃xff0c;将哪个job由哪个trigger触发安排设置进调度程序-任务执行计划表&＃xff0c;并启动它。

schedule.scheduleJob(jobDetail1, trigger1); schedule.start();

至此&＃xff0c;一个定时任务就写出来了&＃xff0c;真的很简单。
完整代码如下&＃xff1a;

public class QuartzLoad {private static Scheduler sched; public static void run() throws Exception { //一個job可以對應多個tigger&＃xff0c;但是一個trigger不能對應多個job。System.out.println("啟動定時任務");//创建SchedulerSchedulerFactory sfact &＃61; new StdSchedulerFactory();sched &＃61; sfact.getScheduler();//每週一早上8點执行任务JobDetail jobDetail1 &＃61; JobBuilder.newJob((Class) TestJob.class).withIdentity("myjob1", "group1").build();CronTrigger trigger1 &＃61;(CronTrigger) TriggerBuilder.newTrigger().withIdentity("trigger1", "group1").withSchedule(CronScheduleBuilder.cronSchedule("0 0 8 ? * MON")) .build();schedule.scheduleJob(jobDetail1, trigger1);schedule.start();}//停止 public static void stop() throws Exception{ sched.shutdown(); } }

可以先用main方法启动试试&＃xff0c;如果是web项目可以用监听器启动。例&＃xff1a;

/*** 監聽器**/ public class TimingTaskSchedule implements ServletContextListener{// 服务器启动时执行该事件public void contextInitialized(ServletContextEvent arg0) {try {QuartzLoad.run();} catch (Exception e) {e.printStackTrace();}}// 服务器停止时执行该事件public void contextDestroyed(ServletContextEvent arg0) {try {QuartzLoad.stop();} catch (Exception e) {e.printStackTrace();}}}