Python 官方文档:入门教程 => 点击学习
目录1、Quartz 1.1 引入依赖 1.2 入门案例 任务类,需要实现 Job 接口 定时器类 1.3 Job 与 JobDetail 1.4 JobExecutionConte
Quartz相较于Timer, Quartz增加了很多功能:
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.3.2</version>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz-jobs</artifactId>
<version>2.3.2</version>
</dependency>
任务:将任务类执行 10 次,每次间隔 3 秒。
package com.sugar.quartz.utils;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.text.SimpleDateFORMat;
import java.util.Date;
public class HelloJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
// 获取当前时间,并格式化
Date date = new Date();
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateSrting = format.format(date);
// 业务功能模拟
System.out.println("开始备份数据库,时间:" + dateSrting);
}
}
package com.sugar.quartz.utils;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
public class HelloSchedulerDemo {
public static void main(String[] args) throws SchedulerException {
// 1、调度器 - 从工厂获取调度实例
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
// 2、任务实例 - 执行的任务对象
JobDetail job = JobBuilder.newJob(HelloJob.class)
.withIdentity("job1", "group1") // 任务名称,组名称
.build();
// 3、触发器 - 控制执行次数和执行时间
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger1", "group1") // 同上
.startNow() // 立刻启动
.withSchedule(SimpleScheduleBuilder.simpleSchedule().
withIntervalInSeconds(3).
withRepeatCount(10)) // 循环10次,每次间隔3s
.build();
// 调度器关联触发器,并启动
scheduler.scheduleJob(job,trigger);
scheduler.start();
}
}
Job
:基于反射的任务调度接口,所有任务类都要实现该接口,在接口的 execute 里编写自己的业务逻辑。Job 生命周期
:每次执行 Job,在 execute 方法前会创建新的 Job实例,调用后实例被释放,再被GC回收。JobDetail
:封装 Job,给 Job 实例提供许多属性。JobDetail 属性
:name、group、jobClass、jobDataMap。下文将 JobExecutionContext 简称为 JEC
JEC
:当调度器调用 Job 时,会将 JEC 传递给 Job 的 execute 方法。JEC 作用
:Job 通过 JEC 获取运行环境信息,以及 Job 信息。下文将 JobDataMap 简称为 JDM
JDM
:任务调度时,JDM 存储在 JEC 中,方便获取。JDM 优点
:实现 Map 接口,可以存取任何可序列化对象,Job 执行时会将参数传给 JDM。HelloSchedulerDemo:
package com.sugar.quartz.utils;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
public class HelloSchedulerDemo {
public static void main(String[] args) throws SchedulerException {
// 1、调度器 - 从工厂获取调度实例
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
// 2、任务实例 - 执行的任务对象
JobDetail job = JobBuilder.newJob(HelloJob.class)
.withIdentity("job1", "group1") // 任务名称,组名称
.usingJobData("msg","JDM使用 - Detail") // JDM 传递参数
.build();
// 3、触发器 - 控制执行次数和执行时间
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger1", "group1") // 同上
.startNow() // 立刻启动
.withSchedule(SimpleScheduleBuilder.simpleSchedule().
withIntervalInSeconds(3).
withRepeatCount(10)) // 循环10次,每次间隔3s
.usingJobData("msg","JDM使用 - Trigger")
.build();
// 调度器关联触发器,并启动
scheduler.scheduleJob(job,trigger);
scheduler.start();
}
}
HelloJob:
package com.sugar.quartz.utils;
import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.text.SimpleDateFormat;
import java.util.Date;
public class HelloJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
// 获取当前时间,并格式化
Date date = new Date();
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateSrting = format.format(date);
// 获取 JDM
JobDataMap Detail_JDM = context.getJobDetail().getJobDataMap();
JobDataMap Trigger_JDM = context.getTrigger().getJobDataMap();
String detail_jdmString = Detail_JDM.getString("msg");
String trigger_jdmString = Trigger_JDM.getString("msg");
System.out.println("---------------------------------------------------");
System.out.println("detail_jdmString = " + detail_jdmString);
System.out.println("trigger_jdmString = " + trigger_jdmString);
// 业务功能模拟
System.out.println("开始备份数据库,时间:" + dateSrting);
// 其他内容
System.out.println("Job 运行时间:" + context.getJobRunTime());
System.out.println("Job 当前运行时间:" + context.getFireTime());
System.out.println("Job 下次运行时间:" + context.getNextFireTime());
System.out.println("---------------------------------------------------");
}
}
HelloJob:
// 实例化时自动绑定 JDM key对应的值
private String msg;
public void setMsg(String msg) {
this.msg = msg;
}
// 获取 JDM
System.out.println(Trigger JDM : " + msg);
预期:无状态 count 输出永远为 1,有状态 count 输出累加。
HelloSchedulerDemo:
// JobDeatil 添加一个 JDM,用做计数器
.usingJobData("count",0)
无状态 HelloJob:
package com.sugar.quartz.utils;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.text.SimpleDateFormat;
import java.util.Date;
public class HelloJob implements Job {
// 实例化时自动绑定 JDM key对应的值
private String msg;
private Integer count;
public void setMsg(String msg) {
this.msg = msg;
}
public void setCount(Integer count) {
this.count = count;
}
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
// 获取当前时间,并格式化
Date date = new Date();
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateSrting = format.format(date);
// 获取 JDM
System.out.println("---------------------------------------------------");
System.out.println("Trigger JDM : " + msg);
System.out.println("Count : " + count);
// 更新 JobDetail JDM 的 count
count++;
context.getJobDetail().getJobDataMap().put("count",count);
// 业务功能模拟
System.out.println("开始备份数据库,时间:" + dateSrting);
// 其他内容
System.out.println("Job 运行时间:" + context.getJobRunTime());
System.out.println("Job 当前运行时间:" + context.getFireTime());
System.out.println("Job 下次运行时间:" + context.getNextFireTime());
System.out.println("---------------------------------------------------");
}
}
有状态 HelloJob:
// 任务类加上下面注解,多次调用 Job,会持久化 Job,JDM 的数据会被保存,供下次使用
@PersistJobDataAfterExecution
Trigger 常用
:SimpleTrigger
、CronTrigger
。JobKey
:Job 实例标识,触发器触发时,执行 JobKey 对应任务。StartTime
:第一次触发时间。EndTime
:终止触发时间。HelloSchedulerTriggerDemo:
package com.sugar.quartz.utils;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import java.util.Date;
public class HelloSchedulerTriggerDemo {
public static void main(String[] args) throws SchedulerException {
// 任务开始时间推迟 3 s,结束时间推迟 10 s
Date startData = new Date();
startData.setTime(startData.getTime() + 3000);
Date endData = new Date();
endData.setTime(endData.getTime() + 10000);
// 1、调度器 - 从工厂获取调度实例
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
// 2、任务实例 - 执行的任务对象
JobDetail job = JobBuilder.newJob(helloJobTrigger.class)
.withIdentity("job1", "group1") // 任务名称,组名称
.usingJobData("msg","JDM使用 - Detail") // JDM 传递参数
.build();
// 3、触发器 - 控制执行次数和执行时间
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger1", "group1") // 同上
.startNow() // 立刻启动
.startAt(startData)
.endAt(endData)
.build();
// 调度器关联触发器,并启动
scheduler.scheduleJob(job,trigger);
scheduler.start();
}
}
helloJobTrigger:
package com.sugar.quartz.utils;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.PersistJobDataAfterExecution;
import java.text.SimpleDateFormat;
import java.util.Date;
@PersistJobDataAfterExecution
public class helloJobTrigger implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
// 获取当前时间,并格式化
Date date = new Date();
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateSrting = format.format(date);
// 业务功能模拟
System.out.println("---------------------------------------------------");
System.out.println("开始备份数据库,时间:" + dateSrting);
// 获取 JobKey,StartTime,EndTime
System.out.println("JobKey : " + context.getTrigger().getJobKey());
System.out.println("StartTime : " + format.format(context.getTrigger().getStartTime()));
System.out.println("EndTime : " + format.format(context.getTrigger().getEndTime()));
System.out.println("---------------------------------------------------");
}
}
// 运行结果
---------------------------------------------------
开始备份数据库,时间:2021-12-13 23:25:06
JobKey : group1.job1
StartTime : 2021-12-13 23:25:06
EndTime : 2021-12-13 23:25:13
---------------------------------------------------
下文将 SimpleTripper 简称为 ST
ST
:特定时间范围启动/结束,且以一个时间间隔重复 n 次 Job 所设计。到此这篇关于Java 任务调度框架 Quartz实操的文章就介绍到这了,更多相关Java 任务调度框架 Quartz
内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网!
--结束END--
本文标题: Java 任务调度框架 Quartz实操
本文链接: https://www.lsjlt.com/news/159866.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
下载Word文档到电脑,方便收藏和打印~
2024-03-01
2024-03-01
2024-03-01
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
2024-02-29
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
0