Quartz 单独启动任务调度器案例举例

news/2024/11/29 7:56:20/

Quartz 配置文件，如果是基于maven 的项目只需要放置到src/main/resources目录下

#quartz setting File
# quartz instance Name
org.quartz.scheduler.instanceName = MySchedulerVincent# quarts thread pool size =3 ;  maximum of 3 jobs can be run simultaneously.
org.quartz.threadPool.threadCount = 3#  All of Quartz’s data, such as details of jobs and triggers, is held in memory
org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

quartz Pom配置

   <!-- quartz 定时任务开始--><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><!-- quartz 定时任务结束-->

定义Quartz 的Job

package common.quartz.task001;import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;/*** @Package: common.quartz <br/>* @Description： Quartz 任务调度程序一个 Job，实现Job 接口 <br/>* @author: PengRong <br/>* @Date: Created in 2018/1/9 20:52 <br/>* @Company: PLCC <br/>* @Copyright: Copyright (c) 2017 <br/>* @Version: 1.0 <br/>* @Modified By: <br/>* @Created by PengRong on 2018/1/9. <br/>*/public class QuartzJob implements Job {/*** execute 是被调度器scheduler 到时间点调度的方法。* @param jobExecutionContext* @throws JobExecutionException*/@Overridepublic void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {System.out.println("quartzJob task 001.....");}
}

基于不同的触发器不同测试类

package common.quartz.task001;import org.junit.Test;
import org.quartz.CalendarIntervalScheduleBuilder;
import org.quartz.CalendarIntervalTrigger;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.DateBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.SimpleTrigger;
import org.quartz.TriggerBuilder;
import org.quartz.TriggerKey;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.spi.MutableTrigger;import java.util.Date;/*** QuartzJob Tester.* https://www.w3cschool.cn/quartz_doc/quartz_doc-2put2clm.html 英翻译中 教程* 该类包含一些常见调度规则配置案例；作为一个教程配置* @author <PengRong>* @version 1.0*/
public class QuartzJobTest {/*** Method: execute(JobExecutionContext jobExecutionContext)* 周期执行，每隔固定时间调度器调度Job执行*/@Testpublic void testMutableTrigger() throws Exception {//调度器工厂SchedulerFactory factory = new StdSchedulerFactory();// Job调度器Scheduler scheduler = factory.getScheduler();//job 任务的唯一标识JobKey key = new JobKey("job-quartz-task-001", "vincent");JobDataMap map = new JobDataMap();map.put("name", "vincent");map.put("copyright", "PLCC");map.put("key1", "123456");map.put("key2", "sdfds");//创建 jobDetail 实例，绑定Job实例； 真正执行的任务并不是Job接口的实例，而是用反射的方式实例化的一个JobDetail实例JobDetail detail = JobBuilder.newJob(QuartzJob.class).withIdentity(key).setJobData(map).build();//triggerKey 唯一标识触发器的TriggerKey triggerKey = new TriggerKey("trigger-quartz-task-001", "vincent");//设置触发器的时刻安排表;  SimpleScheduleBuilderSimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1).// 间隔一秒调度一次withRepeatCount(8);//设置调度次数// TriggerBuilder创建 MutableTrigger futureDate
//SimpleTrigger主要用于一次性执行的Job（只在某个特定的时间点执行一次），
// 或者Job在特定的时间点执行，重复执行N次，每次执行间隔T个时间单位。MutableTrigger trigger = (MutableTrigger) TriggerBuilder.newTrigger().withDescription("MutalbeTrigger instance").withIdentity(triggerKey).startAt(DateBuilder.evenMinuteDate(new Date())). //DateBuilder.evenMinuteDate(new Date())  设置启动日期时间为启动时间的下一分钟。withSchedule(scheduleBuilder).build();scheduler.scheduleJob(detail, trigger);scheduler.start();Thread.sleep(100000);}@Testpublic void testDate() {Date date = DateBuilder.evenMinuteDate(new Date(2018, 1, 10, 22, 20, 10));System.out.println(date.getMinutes());}/*** 在测试案例启动后一分钟后触发器启动，任务指定时间点执行，到指定时间点（00 01 00）调度** @throws SchedulerException* @throws InterruptedException*/@Testpublic void testCornTrigger() throws SchedulerException, InterruptedException {//调度器工厂SchedulerFactory factory = new StdSchedulerFactory();// Job调度器Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();//job 任务的唯一标识JobKey key = new JobKey("job-quartz-task-001", "vincent");// 设置 JobDataMap，可以携带一些执行定时任务的参数，带到job 执行的方法execute方法里面。JobDataMap map = new JobDataMap();map.put("name", "vincent");map.put("copyright", "PLCC");map.put("key1", "123456");map.put("key2", "sdfds");//创建 jobDetail 实例，绑定Job实例JobDetail detail = JobBuilder.newJob(QuartzJob.class).withIdentity(key).withDescription("CornTrigger Tester").setJobData(map).build();//triggerKey 唯一标识触发器的TriggerKey triggerKey = new TriggerKey("trigger-cron-quartz-task-001", "vincent");// 定义调度触发规则，每天23：25分调度运行 QuartzJob 作业；// CronScheduleBuilder 定义Quartz 的时间规则CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0 01 00 * * ? *");//定义触发器规则//CronTrigger在基于日历的调度上非常有用，如“每个星期五的正午”，或者“每月的第十天的上午10:15”等CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(cronScheduleBuilder).startAt(DateBuilder.futureDate(1, DateBuilder.IntervalUnit.MINUTE)). //设置在执行时间后一分钟启动任务build();//将任务和触发器注册到调度器中scheduler.scheduleJob(detail, trigger);//启动调度器scheduler.start();Thread.sleep(1000000);scheduler.shutdown();}/*** Trigger That Executes Every Day* 测试启动后一分钟启动触发器；Using CronTrigger 设置每天 11点触发任务调度执行；*/@Testpublic void testExecutesEveryDayCronTrigger() throws SchedulerException, InterruptedException {// Job调度器Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();//job 任务的唯一标识JobKey key = new JobKey("job-quartz-task-001", "vincent");// 设置 JobDataMap，可以携带一些执行定时任务的参数，带到job 执行的方法execute方法里面。JobDataMap map = new JobDataMap();map.put("name", "vincent");map.put("copyright", "PLCC");map.put("key1", "123456");map.put("key2", "sdfds");//创建 jobDetail 实例，绑定Job实例JobDetail detail = JobBuilder.newJob(QuartzJob.class).withIdentity(key).withDescription("CornTrigger Tester").setJobData(map).build();//triggerKey 唯一标识触发器的TriggerKey triggerKey = new TriggerKey("trigger-cron-quartz-task-001", "vincent");// 定义调度触发规则，每天23：25分调度运行 QuartzJob 作业；// CronScheduleBuilder 定义Quartz 的时间规则,在每天的 11点开跑 Using CronTriggerCronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.dailyAtHourAndMinute(11, 0);//定义触发器规则//CronTrigger在基于日历的调度上非常有用，如“每个星期五的正午”，或者“每月的第十天的上午10:15”等CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(cronScheduleBuilder).startAt(DateBuilder.futureDate(1, DateBuilder.IntervalUnit.MINUTE)). //设置在执行时间后一分钟启动并调度任务。但是如果调度指定了调度时间这个设置没有用build();//将任务和触发器注册到调度器中scheduler.scheduleJob(detail, trigger);//启动调度器scheduler.start();Thread.sleep(1000000);scheduler.shutdown();}/*** @throws SchedulerException* @throws InterruptedException* 在每天固定时间出发，Using SimpleTrigger 设置 启动后开跑，但是第二次开跑间距为 24小时（一天）(startAt 设置有效)*/@Testpublic void testExecutesEveryDaySimpleTrigger() throws SchedulerException, InterruptedException {// Job调度器Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();//job 任务的唯一标识JobKey key = new JobKey("job-quartz-task-001", "vincent");// 设置 JobDataMap，可以携带一些执行定时任务的参数，带到job 执行的方法execute方法里面。JobDataMap map = new JobDataMap();map.put("name", "vincent");map.put("copyright", "PLCC");map.put("key1", "123456");map.put("key2", "sdfds");//创建 jobDetail 实例，绑定Job实例JobDetail detail = JobBuilder.newJob(QuartzJob.class).withIdentity(key).withDescription("SimpleTrigger Tester").setJobData(map).build();//triggerKey 唯一标识触发器的TriggerKey triggerKey = new TriggerKey("trigger-cron-quartz-task-001", "vincent");// 定义调度触发规则，每天23：25分调度运行 QuartzJob 作业；// CronScheduleBuilder 定义Quartz 的时间规则,在每天的 11点开跑 Using SimpleTriggerSimpleScheduleBuilder simpleScheduleBuilder = SimpleScheduleBuilder.simpleSchedule().withIntervalInHours(24).repeatForever();//定义触发器规则//CronTrigger在基于日历的调度上非常有用，如“每个星期五的正午”，或者“每月的第十天的上午10:15”等SimpleTrigger trigger = (SimpleTrigger) TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(simpleScheduleBuilder).startAt(DateBuilder.futureDate(1, DateBuilder.IntervalUnit.MINUTE)). //设置在一分钟后启动build();//将任务和触发器注册到调度器中scheduler.scheduleJob(detail, trigger);//启动调度器scheduler.start();Thread.sleep(1000000);scheduler.shutdown();}/*** 基于 CalendarIntervalTrigger 触发器创建基于时间的周期性调用；改案例是在测试启动后十秒每隔五秒调用一次。(startAt 设置有效)* @throws SchedulerException* @throws InterruptedException*/@Testpublic void testExecutesEveryDayCalendarIntervalTrigger() throws SchedulerException, InterruptedException {// Job调度器Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();//job 任务的唯一标识JobKey key = new JobKey("job-quartz-task-001", "vincent");// 设置 JobDataMap，可以携带一些执行定时任务的参数，带到job 执行的方法execute方法里面。JobDataMap map = new JobDataMap();map.put("name", "vincent");map.put("copyright", "PLCC");map.put("key1", "123456");map.put("key2", "sdfds");//创建 jobDetail 实例，绑定Job实例JobDetail detail = JobBuilder.newJob(QuartzJob.class).withIdentity(key).withDescription("SimpleTrigger Tester").setJobData(map).build();//triggerKey 唯一标识触发器的TriggerKey triggerKey = new TriggerKey("trigger-cron-quartz-task-001", "vincent");// 定义调度触发规则，每天23：25分调度运行 QuartzJob 作业；// Using CalendarIntervalTrigger 定义Quartz 的时间规则,CalendarIntervalScheduleBuilder calendarIntervalScheduleBuilder = CalendarIntervalScheduleBuilder.calendarIntervalSchedule().withIntervalInSeconds(5);//定义触发器规则// CalendarIntervalTrigger 在基于日历的调度上非常有用，如“每个星期五的正午”，或者“每月的第十天的上午10:15”等CalendarIntervalTrigger trigger =  TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(calendarIntervalScheduleBuilder).startAt(DateBuilder.futureDate(10, DateBuilder.IntervalUnit.SECOND)). //设置在一分钟后启动build();//将任务和触发器注册到调度器中scheduler.scheduleJob(detail, trigger);//启动调度器scheduler.start();Thread.sleep(1000000);scheduler.shutdown();}/*** 设置一个调度案例，在测试案例启动后一分钟调度任务一次，然后按照每两天的调度间隔进行调度 (startAt 设置有效)* @throws SchedulerException* @throws InterruptedException*/@Testpublic  void  test2DayInvoke() throws SchedulerException, InterruptedException {// Job调度器Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();//job 任务的唯一标识JobKey key = new JobKey("job-quartz-task-001", "vincent");// 设置 JobDataMap，可以携带一些执行定时任务的参数，带到job 执行的方法execute方法里面。JobDataMap map = new JobDataMap();map.put("name", "vincent");map.put("copyright", "PLCC");map.put("key1", "123456");map.put("key2", "sdfds");//创建 jobDetail 实例，绑定Job实例JobDetail detail = JobBuilder.newJob(QuartzJob.class).withIdentity(key).withDescription("SimpleTrigger Tester").setJobData(map).build();//triggerKey 唯一标识触发器的TriggerKey triggerKey = new TriggerKey("trigger-cron-quartz-task-001", "vincent");// 定义调度触发规则，每天23：25分调度运行 QuartzJob 作业；// Using CalendarIntervalTrigger 定义Quartz 的时间规则,CalendarIntervalScheduleBuilder calendarIntervalScheduleBuilder = CalendarIntervalScheduleBuilder.calendarIntervalSchedule().withIntervalInDays(2);//定义触发器规则// CalendarIntervalTrigger 在基于日历的调度上非常有用，如“每个星期五的正午”，或者“每月的第十天的上午10:15”等CalendarIntervalTrigger trigger =  TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(calendarIntervalScheduleBuilder).startAt(DateBuilder.futureDate(10, DateBuilder.IntervalUnit.SECOND)). //设置在10秒钟后启动build();//将任务和触发器注册到调度器中scheduler.scheduleJob(detail, trigger);//启动调度器scheduler.start();Thread.sleep(1000000);scheduler.shutdown();}/*** 设置 在每周三15 点调度任务（CronTrigger 调度器）（CronTrigger 触发器下 ，startAt 设置无效。因为指定了跑的时间）* @throws SchedulerException* @throws InterruptedException*/@Testpublic void testWeekInvoke() throws SchedulerException, InterruptedException {// Job调度器Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();//job 任务的唯一标识JobKey key = new JobKey("job-quartz-task-001", "vincent");// 设置 JobDataMap，可以携带一些执行定时任务的参数，带到job 执行的方法execute方法里面。JobDataMap map = new JobDataMap();map.put("name", "vincent");map.put("copyright", "PLCC");map.put("key1", "123456");map.put("key2", "sdfds");//创建 jobDetail 实例，绑定Job实例JobDetail detail = JobBuilder.newJob(QuartzJob.class).withIdentity(key).withDescription("SimpleTrigger Tester").setJobData(map).build();//triggerKey 唯一标识触发器的TriggerKey triggerKey = new TriggerKey("trigger-cron-quartz-task-001", "vincent");// 定义调度触发规则，每天23：25分调度运行 QuartzJob 作业；// Using CronScheduleBuilder 定义Quartz 的时间规则,每周三下午 15 点跑CronScheduleBuilder builder=CronScheduleBuilder.weeklyOnDayAndHourAndMinute(DateBuilder.WEDNESDAY,15,0);//定义触发器规则// CalendarIntervalTrigger 在基于日历的调度上非常有用，如“每个星期五的正午”，或者“每月的第十天的上午10:15”等CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(builder).startAt(DateBuilder.futureDate(10, DateBuilder.IntervalUnit.SECOND)). //设置在启动后10秒后调用一次build();//将任务和触发器注册到调度器中scheduler.scheduleJob(detail, trigger);//启动调度器scheduler.start();Thread.sleep(1000000);scheduler.shutdown();}/*** 设置一个触发器，他是每隔三天在下午 20180112T15:47:50点触发; 并能监听scheduler*/@Testpublic  void test3Day15Time() throws SchedulerException, InterruptedException {// Job调度器Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();//job 任务的唯一标识JobKey key = new JobKey("job-quartz-task-001", "vincent");// 设置 JobDataMap，可以携带一些执行定时任务的参数，带到job 执行的方法execute方法里面。JobDataMap map = new JobDataMap();map.put("name", "vincent");map.put("copyright", "PLCC");map.put("key1", "123456");map.put("key2", "sdfds");//创建 jobDetail 实例，绑定Job实例JobDetail detail = JobBuilder.newJob(QuartzJob.class).withIdentity(key).withDescription("SimpleTrigger Tester").setJobData(map).build();//triggerKey 唯一标识触发器的TriggerKey triggerKey = new TriggerKey("trigger-cron-quartz-task-001", "vincent");// 定义调度触发规则，每天23：25分调度运行 QuartzJob 作业；// Using CronScheduleBuilder 定义Quartz 的时间规则,每隔三天调用一次。CalendarIntervalScheduleBuilder builder=CalendarIntervalScheduleBuilder.calendarIntervalSchedule().withIntervalInDays(3);//定义触发器规则// CalendarIntervalTrigger 在基于日历的调度上非常有用，如“每个星期五的正午”，或者“每月的第十天的上午10:15”等CalendarIntervalTrigger trigger = (CalendarIntervalTrigger) TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(builder).startAt(DateBuilder.dateOf(15,47,50,12,1,2018)). //设置在启动后10秒后调用一次build();//将任务和触发器注册到调度器中scheduler.scheduleJob(detail, trigger);//加入监听Schedulerscheduler.getListenerManager().addSchedulerListener(new MyOtherSchedulerListener());//启动调度器scheduler.start();Thread.sleep(1000000);scheduler.shutdown();}}

参考：


http://www.ppmy.cn/news/338375.html

相关文章

Spring常用注解（收藏大全）

Spring常用注解（收藏大全）

点击上方“程序员大咖”&#xff0c;选择“置顶公众号” 关键时刻&#xff0c;第一时间送达&#xff01; 作者&#xff1a;IT_faquirhttps://blog.csdn.net/IT_faquir/article/details/78025203 程序员大咖整理发布&#xff0c;转载请联系作者获得授权 Spring部分 1.声明bean的…
阅读更多...
Java 并发编程之任务取消（五）

Java 并发编程之任务取消（五）

停止基于线程的服务 正确的封装原则是&#xff1a;除非拥有某个线程&#xff0c;否则不能对该线程进行操控。例如中断线程或修改线程的优先级等 。那么什么 是拥有某个线程呢&#xff0c;就是创建该线程的类&#xff0c;一般来说线程池是其工作线程的所有者&#xff0c;所以要…
阅读更多...
12eqfsdfds

12eqfsdfds

public void aaa(){System.out.println("hello"); }
阅读更多...
ces

ces

#include<iostream> using namespace std; int main() { int s,f; cin>>s>>f; if (((s>8) && (s<16))||((s17) && (f00))) { cout<<"YES"; } else { cout<<"NO"; } }
阅读更多...
Ubuntu下sqlite3的安装及使用

Ubuntu下sqlite3的安装及使用

转载Ubuntu下sqlite3的安装及使用 Sqlite是一款轻型的数据库&#xff0c;实现了多数SQL-92标准&#xff0c;包括事务&#xff08;原子性&#xff0c;一致性&#xff0c;隔离性和持久性 ACID&#xff09;&#xff0c;触发器与多数复杂查询。对于一个移动手持设备的应用开发者&am…
阅读更多...
【Android】通过CustomTarget释放Glide在ViewHolder 所占用的图片内存，避免内存泄漏

【Android】通过CustomTarget释放Glide在ViewHolder 所占用的图片内存，避免内存泄漏

在上述代码中&#xff0c;Glide 加载图片所占用的内存是通过 CustomTarget 的 onResourceReady 方法返回的 Drawable 对象来表示的。因此&#xff0c;在 onViewRecycled 方法中&#xff0c;我们可以通过将 Drawable 对象的引用置为 null 来释放所占用的内存。 具体来说&#x…
阅读更多...
共享电动车APP开发

共享电动车APP开发

当前用户的出行主要是为了日常的工作或者是节假日的一些休闲娱乐活动&#xff0c;所以说抓住 这一类用户的需求&#xff0c;能够有效发展平台的整体用户粘性;要知道用户的出行图的就是一个 便捷&#xff0c;虽然说日常生活中有公交地铁这样的公共交通设备&#xff0c;但是这样…
阅读更多...
电动车防盗管理系统

电动车防盗管理系统

第一章 引言. 第一章 引言 1.1 文档说明 此文档旨在解释说明电动车防盗管理系统的原理与构成、系统功能和相关案例。未经授权&#xff0c;不得以任何形式转载篡改&#xff0c;奔骝科技不对篡改后的文档负责。 1.2 读者对象集成商销售 依据本解决方案&#xff0c;集成商销售可…
阅读更多...
最新文章

Copyright @ 2022~2023