700字范文 > Quartz实现动态定时任务

Quartz实现动态定时任务

时间：2020-03-12 01:13:51

相关推荐

Quartz实现动态定时任务

一、说明

由于最近工作要实现定时任务的执行，而且要求定时周期是不固定的，所以就用到了quartz来实现这个功能；

spring3.1以下的版本必须使用quartz1.x系列，3.1以上的版本才支持quartz 2.x，不然会出错。至于原因，则是spring对于quartz的支持实现，org.springframework.scheduling.quartz.CronTriggerBean继承了org.quartz.CronTrigger，在quartz1.x系列中org.quartz.CronTrigger是个类，而在quartz2.x系列中org.quartz.CronTrigger变成了接口，从而造成无法用spring的方式配置quartz的触发器(trigger)。

我使用的quartz版本是2.2.1 。

最终实现的功能：

1) 项目启动时，可执行的定时任务启动，按时执行相应的逻辑；

2) 可添加新任务，删除任务，更新任务，暂停任务，恢复任务；

二、添加quartz包

我使用Gradle构建项目，加包时只需下面一行即可：

compile "org.quartz-scheduler:quartz:2.2.1"

三、配置及使用

1. 配置任务调度器 (对应的文件名为quartz-task.xml)

<?xmlversion="1.0"encoding="UTF-8"?> <beansxmlns="/schema/beans"xmlns:xsi="/2001/XMLSchema-instance" xsi:schemaLocation="/schema/beans/schema/beans/spring-beans-3.0.xsd" default-lazy-init="false">  <beanname="schedulerFactoryBean"class="org.springframework.scheduling.quartz.SchedulerFactoryBean">  <propertyname="applicationContextSchedulerContextKey"> <value>applicationContext</value> </property> </bean>  <beanid="loadTask"class="com.quartz.LoadTask"init-method="initTask"/> </beans>

2. 服务器启动时加载，在web.xml文件里配置

<context-param> <param-name>contextConfigLocation</param-name> <param-value>classpath:quartz-task.xml</param-value> </context-param>

3. 加载可执行任务的类LoadTask.java

publicclassLoadTask{publicvoidinitTask()throwsException{ Schedulerscheduler=schedulerFactoryBean.getScheduler(); //可执行的任务列表 Collection<Task>taskList=taskService.findTask(); for(Tasktask:taskList){ //任务名称和任务组设置规则： //名称：task_1.. //组：group_1.. TriggerKeytriggerKey=TriggerKey.triggerKey( "task_"+task.getId(),"group_"+task.getId()); CronTriggertrigger=(CronTrigger)scheduler .getTrigger(triggerKey); //不存在，创建一个 if(null==trigger){ JobDetailjobDetail=JobBuilder .newJob(QuartzJobFactory.class) .withIdentity("task_"+task.getId(), "group_"+task.getId()).build(); jobDetail.getJobDataMap().put("scheduleJob",task); //表达式调度构建器 CronScheduleBuilderscheduleBuilder=CronScheduleBuilder .cronSchedule(getCronExpression()); //按新的表达式构建一个新的trigger trigger=TriggerBuilder .newTrigger() .withIdentity("task_"+task.getId(), "group_"+task.getId()) .withSchedule(scheduleBuilder).build(); scheduler.scheduleJob(jobDetail,trigger); }else{ //trigger已存在，则更新相应的定时设置 CronScheduleBuilderscheduleBuilder=CronScheduleBuilder .cronSchedule(taskService.getCronExpression()); //按新的cronExpression表达式重新构建trigger trigger=trigger.getTriggerBuilder().withIdentity(triggerKey) .withSchedule(scheduleBuilder).build(); //按新的trigger重新设置job执行 scheduler.rescheduleJob(triggerKey,trigger); } } } @Autowired privateSchedulerFactoryBeanschedulerFactoryBean; @Autowired privateTaskServicetaskService; }

4. 调度任务的入口

publicclassQuartzTaskFactoryimplementsJob{ @Override publicvoidexecute(JobExecutionContextcontext) throwsJobExecutionException{ //TODOAuto-generatedmethodstub try{ System.out.println("任务运行..."); Tasktask=(Task)context.getMergedJobDataMap().get( "scheduleJob"); System.out.println("任务名称:["+task.getTaskName()+"]"); //在这里执行你的任务... }catch(Exceptione){ e.printStackTrace(); } } }

5. 暂停任务

Schedulerscheduler=schedulerFactoryBean.getScheduler();JobKeyjobKey=JobKey.jobKey(scheduleJob.getJobName(),scheduleJob.getJobGroup());scheduler.pauseJob(jobKey);

6. 恢复任务

Schedulerscheduler=schedulerFactoryBean.getScheduler();JobKeyjobKey=JobKey.jobKey(scheduleJob.getJobName(),scheduleJob.getJobGroup());scheduler.resumeJob(jobKey);

7. 删除任务

Schedulerscheduler=schedulerFactoryBean.getScheduler();JobKeyjobKey=JobKey.jobKey(scheduleJob.getJobName(),scheduleJob.getJobGroup());scheduler.deleteJob(jobKey);

8. 立即运行任务

Schedulerscheduler=schedulerFactoryBean.getScheduler();JobKeyjobKey=JobKey.jobKey(scheduleJob.getJobName(),scheduleJob.getJobGroup());scheduler.triggerJob(jobKey);

9. 更新任务(时间表达式)

Schedulerscheduler=schedulerFactoryBean.getScheduler();TriggerKeytriggerKey=TriggerKey.triggerKey(scheduleJob.getJobName(),scheduleJob.getJobGroup());//获取trigger，即在spring配置文件中定义的beanid="myTrigger"CronTriggertrigger=(CronTrigger)scheduler.getTrigger(triggerKey);//表达式调度构建器CronScheduleBuilderscheduleBuilder=CronScheduleBuilder.cronSchedule(scheduleJob.getCronExpression());//按新的cronExpression表达式重新构建triggertrigger=trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();//按新的trigger重新设置job执行 scheduler.rescheduleJob(triggerKey,trigger);

四、时间表达式说明

字段允许值允许的特殊字符

秒 0-59 , – * /

分 0-59 , – * /

小时 0-23 , – * /

日期 1-31 , – * ? / L W C

月份 1-12 或者 JAN-DEC , – * /

星期 1-7 或者 SUN-SAT , – * ? / L C #

年(可选) 留空, 1970-2099 , – * /

表达式意义

"0 0 12 * * ?" 每天中午12点触发

"0 15 10 ? * *" 每天上午10:15触发