做业调度框架 Quartz 学习笔记(二) -- 简单触发器(SimpleTrigger)
简单回顾一下上一节学习到的 "HelloWorld "java
1 建立一个job类,实现Job接口,覆盖 public void execute(JobExecutionContext context) 方法,在方法中写入你要执行的操做(数据导入/备份,轮询检查文件等)代码node
2 建立一个主线程类, 得到 Scheduler 对象框架
SchedulerFactory sf = new StdSchedulerFactory();
Scheduler sched = sf.getScheduler(); ide
得到要执行的对象 JobDetail job = newJob(HelloJob.class).withIdentity("job1", "group1").build();学习
定义触发器 Trigger trigger = newTrigger().withIdentity("trigger1", "group1").startAt(runTime).build();测试
将任务和Trigger放入scheduler : ui
sched.scheduleJob(job, trigger);spa
启动 和 中止
sched.start(); sched.shutdown(true);.net
注意 给job 留有足够长的时间,若是主线程类中止工做,job线程也会中止工做线程
---------------------------------------我是分割线--------------------------------------------------------
通过了 "HelloWorld" 以后,您老人家可能对 Quartz 有所了解,下面让咱们继续深刻,学习下Quartz 重复执行任务该怎么作
简单的说就是 触发器(Trigger)的参数设置. 什么? 触发器(Trigger)不知道是什么?
出门左转 <<做业调度框架 Quartz 学习笔记(一)>> 不谢
仍是老套路,一个job 类,一个主线程类
SimpleJob.java
package net.itaem.annnodemo.anno.task.task1;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.text.SimpleDateFormat;
import java.util.Calendar;
/**
* Created with IntelliJ IDEA.
* Description:
* User: zhubo
* Date: 2017-10-24
* Time: 15:33
*/
public class SimpleJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
// job 的名字
String jobName = context.getJobDetail().getKey().getName();
// 任务执行的时间
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy 年 MM 月 dd 日 HH 时 mm 分 ss 秒");
String jobRunTime = dateFormat.format(Calendar.getInstance().getTime());
// 输出任务执行状况
System.out.println("任务 : " + jobName + " 在 " +jobRunTime + " 执行了 ");
}
}
在这里 对输出 的日期进行了一小下 格式化,适应国人习惯.
其它没什么好说的 0.0
SimpleTriggerExample.java
package net.itaem.annnodemo.anno.task.task1;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* Created with IntelliJ IDEA.
* Description:
* User: zhubo
* Date: 2017-10-24
* Time: 15:33
*/
public class SimpleTriggerExample {
public static void main(String[] args) throws Exception {
new SimpleTriggerExample().run();
}
public void run() throws Exception {
// 日期格式化
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy 年 MM 月 dd 日 HH 时 mm 分 ss 秒");
SchedulerFactory sf = new StdSchedulerFactory();
Scheduler sched = sf.getScheduler();
System.out.println("--------------- 初始化 -------------------");
// 下一个第15秒 例:
// 当前 10秒,则 执行时间为15秒
// 当前 16秒,则 执行时间为30秒
// 当前 33秒,则 执行时间为45秒
// 当前 48秒,则 执行时间为00秒
Date startTime = DateBuilder.nextGivenSecondDate(null, 15);
// job1 将只会执行一次
JobDetail job = JobBuilder.newJob(SimpleJob.class).withIdentity("job1", "group1").build();
SimpleTrigger trigger = (SimpleTrigger) TriggerBuilder.newTrigger()
.withIdentity("trigger1", "group1")
.startAt(startTime).build();
// 把job1 和 trigger加入计划 . ft:此任务要执行的时间
Date ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + " 将在 : " + dateFormat.format(ft) + " 时运行.而且重复: "
+ trigger.getRepeatCount() + " 次, 每次间隔 "
+ trigger.getRepeatInterval() / 1000 + " 秒");
// job2 将只会和执行一次(和job1同样同样的,吼~~)
job = JobBuilder.newJob(SimpleJob.class).withIdentity("job2", "group1").build();
trigger = (SimpleTrigger) TriggerBuilder.newTrigger()
.withIdentity("trigger2", "group1").startAt(startTime).build();
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + " 将在 : " + dateFormat.format(ft) + " 时运行.而且重复: "
+ trigger.getRepeatCount() + " 次, 每次间隔 "
+ trigger.getRepeatInterval() / 1000 + " 秒");
// job3 将执行11次(执行1次,重复10次) ,每10秒重复一次
job = JobBuilder.newJob(SimpleJob.class).withIdentity("job3", "group1").build();
trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger3", "group1")
.startAt(startTime)
.withSchedule(
SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(10)// 重复间隔
.withRepeatCount(10)) // 重复次数
.build();
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName()+ " 将在 : " + dateFormat.format(ft) + " 时运行.而且重复: "
+ trigger.getRepeatCount() + " 次, 每次间隔 "
+ trigger.getRepeatInterval() / 1000 + " 秒");
// trigger3 改变了. 每隔10s重复.共重复2次
// 此处说明 , 上面job3已经 设定了 trigger3 重复10次,每次10s
// 在这里又改变了 trigger3的设置,不会对之前构成影响,而是当作一个新的来处理
trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger3", "group2")
.startAt(startTime)
.withSchedule(SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(10)
.withRepeatCount(2))
.forJob(job).build();
ft = sched.scheduleJob(trigger);
System.out.println(job.getKey().getName() + " 改变过trigger3属性的job3 : " + dateFormat.format(ft) + " 时运行.而且重复: "
+ trigger.getRepeatCount() + " 次, 每次间隔 "
+ trigger.getRepeatInterval() / 1000 + " 秒");
// job5 将在5分钟后运行一次
job = JobBuilder.newJob(SimpleJob.class).withIdentity("job5", "group1").build();
trigger = (SimpleTrigger) TriggerBuilder.newTrigger()
.withIdentity("trigger5", "group1")
.startAt(DateBuilder.futureDate(5, DateBuilder.IntervalUnit.MINUTE)) // 设定5分钟后运行
.build();
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName()+ " 将在 : " + dateFormat.format(ft) + " 时运行.而且重复: "
+ trigger.getRepeatCount() + " 次, 每次间隔 "
+ trigger.getRepeatInterval() / 1000 + " 秒");
// job6 每40s运行一次,没有指定重复次数,则无下限的重复
job = JobBuilder.newJob(SimpleJob.class).withIdentity("job6", "group1").build();
trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger6", "group1")
.startAt(startTime)
.withSchedule(
SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(40)
.repeatForever()).build();
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + " 将在 : " + dateFormat.format(ft) + " 时运行.而且重复: "
+ trigger.getRepeatCount() + " 次, 每次间隔 "
+ trigger.getRepeatInterval() / 1000 + " 秒");
// 全部的任务都被加入到了 scheduler中 ,但只有 schedulers.start(); 时才开始执行
sched.start();
System.out.println("------- 开始调度 (调用.start()方法) ----------------");
System.out.println("-------系统 启动 的 时间 :" + dateFormat.format(new Date()));
// 在 scheduled.start(); 以后,还能够将 jobs 添加到执行计划中
// job7 将重复20次 ,每5分钟重复一次
job = JobBuilder.newJob(SimpleJob.class).withIdentity("job7", "group1").build();
trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger7", "group1")
.startAt(startTime)
.withSchedule(
SimpleScheduleBuilder.simpleSchedule()
.withIntervalInMinutes(5) // 5分钟
.withRepeatCount(20)) // 重复20次
.build();
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + " 将在 : " + dateFormat.format(ft) + " 时运行.而且重复: "
+ trigger.getRepeatCount() + " 次, 每次间隔 "
+ trigger.getRepeatInterval() / 1000 + " 秒");
// job8 能够当即执行. 无trigger注册
job = JobBuilder.newJob(SimpleJob.class).withIdentity("job8", "group1")
.storeDurably().build();
sched.addJob(job, true);
System.out.println("手动触发 job8...(当即执行)");
sched.triggerJob(JobKey.jobKey("job8", "group1"));
System.out.println("------- 等待30 秒... --------------");
try {
Thread.sleep(30L * 1000L);
} catch (Exception e) { }
// job7 将立刻执行,重复10次,每秒一次
System.out.println("------- 从新安排 ... --------------------");
trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger7", "group1")
.startAt(startTime)
.withSchedule(
SimpleScheduleBuilder.simpleSchedule().withIntervalInMinutes(5)
.withRepeatCount(20)).build();
ft = sched.rescheduleJob(trigger.getKey(), trigger);
System.out.println("job7 被从新安排 在 : " + dateFormat.format(ft) +" 执行. \r 当前时间 :" + dateFormat.format(new Date())+"预约执行时间已过,任务当即执行");
try {
System.out.println("------- 等待5分钟 ... ------------");
Thread.sleep(300L * 1000L);
} catch (Exception e) { }
sched.shutdown(true);
System.out.println("------- 调度已关闭 ---------------------");
// 显示一下 已经执行的任务信息
SchedulerMetaData metaData = sched.getMetaData();
System.out.println("~~~~~~~~~~ 执行了 " + metaData.getNumberOfJobsExecuted() + " 个 jobs.");
}
}
定时任务开始后继续注册 与 手动出发启动定时任务
package net.itaem.annnodemo.anno.task.task1;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.TimeUnit;
/**
* Created with IntelliJ IDEA.
* Description:
* User: zhubo
* Date: 2017-10-24
* Time: 15:33
*/
public class SimpleTriggerExampleTwo {
public static void main(String[] args) throws Exception {
new SimpleTriggerExampleTwo().run();
}
public void run() throws Exception {
// 日期格式化
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy 年 MM 月 dd 日 HH 时 mm 分 ss 秒");
SchedulerFactory sf = new StdSchedulerFactory();
Scheduler sched = sf.getScheduler();
System.out.println("--------------- 初始化 -------------------");
Date startTime = DateBuilder.nextGivenSecondDate(null, 10);
// job3 将执行11次(执行1次,重复10次) ,每10秒重复一次
JobDetail job = JobBuilder.newJob(SimpleJob.class).withIdentity("job3", "group1").build();
SimpleTrigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger3", "group1")
.startAt(startTime)
.withSchedule(
SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(3)// 重复间隔
.withRepeatCount(5)) // 重复次数
.build();
Date ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName()+ " 将在 : " + dateFormat.format(ft) + " 时运行.而且重复: "
+ trigger.getRepeatCount() + " 次, 每次间隔 "
+ trigger.getRepeatInterval() / 1000 + " 秒");
sched.start();
System.out.println("------- 开始调度 (调用.start()方法) ----------------");
System.out.println("-------系统 启动 的 时间 :" + dateFormat.format(new Date()));
// 在 scheduled.start(); 以后,还能够将 jobs 添加到执行计划中
// job7 将重复20次 ,每5分钟重复一次
job = JobBuilder.newJob(SimpleJob.class).withIdentity("job7", "group1").build();
trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger7", "group1")
.startAt(startTime)
.withSchedule(
SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(5) // 5分钟
.withRepeatCount(3)) // 重复20次
.build();
ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + " 将在 : " + dateFormat.format(ft) + " 时运行.而且重复: "
+ trigger.getRepeatCount() + " 次, 每次间隔 "
+ trigger.getRepeatInterval() / 1000 + " 秒");
// job8 能够当即执行. 无trigger注册
job = JobBuilder.newJob(SimpleJob.class).withIdentity("job8", "group1")
.storeDurably().build();
sched.addJob(job, true);
System.out.println("手动触发 job8...(当即执行)");
sched.triggerJob(JobKey.jobKey("job8", "group1"));
Thread.sleep(20*1000L);
// 显示一下 已经执行的任务信息
SchedulerMetaData metaData = sched.getMetaData();
System.out.println("~~~~~~~~~~ 执行了 " + metaData.getNumberOfJobsExecuted() + " 个 jobs.");
}
}
从新安排触发器
package net.itaem.annnodemo.anno.task.task1;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* Created with IntelliJ IDEA.
* Description:
* User: zhubo
* Date: 2017-10-24
* Time: 16:04
*/
public class ReInject {
public static void main(String[] args) throws Exception {
new ReInject().run();
}
public void run() throws Exception {
// 日期格式化
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy 年 MM 月 dd 日 HH 时 mm 分 ss 秒");
SchedulerFactory sf = new StdSchedulerFactory();
Scheduler sched = sf.getScheduler();
System.out.println("--------------- 初始化 -------------------");
Date startTime = DateBuilder.nextGivenSecondDate(null, 10);
sched.start();
JobDetail job = JobBuilder.newJob(SimpleJob.class).withIdentity("job7", "group1").build();
SimpleTrigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger7", "group1")
.startAt(startTime)
.withSchedule(
SimpleScheduleBuilder.simpleSchedule()
.withIntervalInMinutes(5) // 5分钟
.withRepeatCount(20)) // 重复20次
.build();
Date ft = sched.scheduleJob(job, trigger);
System.out.println(job.getKey().getName() + " 将在 : " + dateFormat.format(ft) + " 时运行.而且重复: "
+ trigger.getRepeatCount() + " 次, 每次间隔 "
+ trigger.getRepeatInterval() / 1000 + " 秒");
// job7 将立刻执行,重复10次,每秒一次
System.out.println("------- 从新安排 ... --------------------");
trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger7", "group1")
.startAt(startTime)
.withSchedule(
SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5)
.withRepeatCount(5)).build();
ft = sched.rescheduleJob(trigger.getKey(), trigger);
System.out.println("job7 被从新安排 在 : " + dateFormat.format(ft) +" 执行. \r 当前时间 :" + dateFormat.format(new Date())+"预约执行时间已过,任务当即执行");
}
}
几点说明:
1 DateBuilder.nextGivenSecondDate 的意思代码中已经说明了,就是下一个你想要的时间,不懂的能够本身测试一下
2 同一个任务能够屡次注册.
3 重复执行 须要设置
trigger = newTrigger()
.withIdentity("trigger3", "group1")
.startAt(startTime)
.withSchedule(
simpleSchedule()
.withIntervalInSeconds(10)// 重复间隔
.withRepeatCount(10)) // 重复次数
.build();
若是须要一直重复:
trigger = newTrigger()
.withIdentity("trigger6", "group1")
.startAt(startTime)
.withSchedule(
simpleSchedule().withIntervalInSeconds(40)
.repeatForever()).build();
4 无trigger注册,表示任务当即执行 : sched.addJob(job, true);
5 // 在scheduler.start以后调用，能够在job开始后从新定义trigger，而后从新注册
sched.rescheduleJob(trigger.getKey(), trigger);
这个Example 仍是比较简单的,主要 就是Trigger的参数设置,多看看代码,里面有注释的 0.0
本身动手试试吧
相关文章
- 1. 做业调度框架 Quartz 学习笔记(一) -- HelloWorld !!!
- 2. 做业调度框架 Quartz 学习笔记(五) -- 错过的任务怎么办?
- 3. Quartz.NET做业调度框架详解
- 4. java 调度框架quartz
- 5. quartz入门（二）SimpleTrigger简单实例
- 6. 用 Quartz 进行做业调度
- 7. Quartz学习笔记
- 8. SpringMVC（六）：Spring 整合quartz做业调度框架
- 9. java作业调度框架Quartz
- 10. 定时任务调度框架Quartz
- 更多相关文章...
- • MySQL触发器简介 - MySQL教程
- • SQLite 触发器（Trigger） - SQLite教程
- • Tomcat学习笔记（史上最全tomcat学习笔记）
- • Kotlin学习（二）基本类型
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
欢迎关注本站公众号,获取更多信息
