宋现锋 2018/2/6html
在开发测试平台的时候，有不少状况下须要用到定时任务，如接口或是服务的监控，页面定时扫描，自动化测试用例定时执行等等。一般的作法是利用Jenkins作定时调用，也能够借助于Linux的定时任务crontab来设置要执行的任务。先前我使用python开发测试平台的时候，就是直接操做/var/spool/cron/root进行定时任务的添加，删除，开启和暂停的。但是最近用java借助于公司的SCF+WF框架进行测试平台的开发的时候，发现存在着问题：前端
1， 直接经过命令行方式执行java文件比较麻烦，由于须要执行的文件要调用不少包。java
2， 而任何对定时任务的操做，如增长和删除都是比较麻烦的，须要先编译才能执行。python
因此直接执行java文件的方法行不通，因而去网上搜索java处理定时任务的方法。这一搜仍是挺多的，具体对考文章：http://www.javashuo.com/article/p-fdbhgovy-bs.html，为了更加灵活地知足动态操做定时任务的须要，我决定使用Quartz。下面我将具体的使用详细介绍一下：web
一， 添加maven依赖
将下面的依赖添加到你的maven工程的pom.xml文件中：框架
<dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.3.0</version> </dependency>
二， 编写定时任务操做类
下面的类中我添加了对定时任务操做的增，删，改，开启，中止等操做，代码中的注释比较全，很容易读懂的。maven
package com.bj58.qa.comtestplatform.web.bll.Admonitorbll; import java.util.List; import org.quartz.CronScheduleBuilder; import org.quartz.CronTrigger; import org.quartz.Job; import org.quartz.JobBuilder; import org.quartz.JobDetail; import org.quartz.JobKey; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.SchedulerFactory; import org.quartz.Trigger; import org.quartz.TriggerBuilder; import org.quartz.TriggerKey; import org.quartz.impl.StdSchedulerFactory; public class CronTabOperationsBll { private static SchedulerFactory schedulerFactory = new StdSchedulerFactory(); /** * @Description: 添加一个定时任务 * * @param jobName 任务名 * @param jobGroupName 任务组名 * @param triggerName 触发器名 * @param triggerGroupName 触发器组名 * @param jobClass 任务 * @param cron 时间设置，参考quartz说明文档 * @param clid:定时任务ID */ public static void addJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName, Class jobClass, String cron, String clid) { try { Scheduler sched = schedulerFactory.getScheduler(); JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName).build(); jobDetail.getJobDataMap().put("clid", clid); TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger(); triggerBuilder.withIdentity(triggerName, triggerGroupName); triggerBuilder.startNow(); triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron)); CronTrigger trigger = (CronTrigger)triggerBuilder.build(); sched.scheduleJob(jobDetail, trigger); if (!sched.isShutdown()) { sched.start(); } } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description: 编辑一个定时任务 * * @param jobName 任务名 * @param jobGroupName 任务组名 * @param triggerName 触发器名 * @param triggerGroupName 触发器组名 * @param cron 时间设置，参考quartz说明文档 * @param clid:定时任务ID */ public static void modifyJobTime(String jobName, String jobGroupName, String triggerName, String triggerGroupName, String cron, String clid) { try { Scheduler sched = schedulerFactory.getScheduler(); JobDetail jobDetail = sched.getJobDetail(JobKey.jobKey(jobName, jobGroupName)); Class<? extends Job> jobClass = jobDetail.getJobClass(); removeJob(jobName, jobGroupName, triggerName, triggerGroupName); addJob(jobName, jobGroupName, triggerName, triggerGroupName, jobClass, cron, clid); } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description: 删除一个定时任务 * * @param jobName 任务名 * @param jobGroupName 任务组名 * @param triggerName 触发器名 * @param triggerGroupName 触发器组名 */ public static void removeJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName) { try { Scheduler sched = schedulerFactory.getScheduler(); TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroupName); sched.pauseTrigger(triggerKey); sched.unscheduleJob(triggerKey); sched.deleteJob(JobKey.jobKey(jobName, jobGroupName)); } catch (Exception e) { throw new RuntimeException(e); } } /** * 启动全部定时任务 */ public static void startJobs() { try { Scheduler sched = schedulerFactory.getScheduler(); sched.start(); } catch (Exception e) { throw new RuntimeException(e); } } /** *关闭全部定时任务 */ public static void shutdownJobs() { try { Scheduler sched = schedulerFactory.getScheduler(); if (!sched.isShutdown()) { sched.shutdown(); } } catch (Exception e) { throw new RuntimeException(e); } } /** * 关闭定时任务 * @param jobName 任务名 * @param jobGroupName 任务组名 */ public static void ShutDownJob(String jobName, String jobGroupName) { try { Scheduler scheduler = schedulerFactory.getScheduler(); JobKey jobKey = JobKey.jobKey(jobName, jobGroupName); scheduler.pauseJob(jobKey); System.out.println("关闭定时任务：" + jobName); } catch (SchedulerException e) { e.printStackTrace(); } } /** * 开启一个定时任务 * @param jobName 任务名 * @param jobGroupName 任务组名 */ public static void StartJob(String jobName, String jobGroupName) { try { Scheduler scheduler = schedulerFactory.getScheduler(); JobKey jobKey = JobKey.jobKey(jobName, jobGroupName); scheduler.resumeJob(jobKey); System.out.println("开启定时任务：" + jobName); } catch (SchedulerException e) { e.printStackTrace(); } } /** * 获取定时任务中存在的任务 * @return */ public static String GetAllExcutingJobs() { String jobslist = "定时任务中存在的JobGroups:"; try { Scheduler scheduler = schedulerFactory.getScheduler(); List<String> jobgroups = scheduler.getJobGroupNames(); System.out.println("定时任务中存在的Jobs:" + jobgroups.size()); for (String jbgroup : jobgroups) { jobslist = jobslist + "JobGroup:" + jbgroup; } } catch (SchedulerException e) { e.printStackTrace(); } return jobslist; } /** * 获取定时任务的状态 * @param triggerName 触发器名 * @param triggerGroupName 触发器组名 * @return */ public static String GetJobStatus(String triggerName, String triggerGroupName) { String jobstatus = "定时任务" + triggerName + "的状态是："; try { Scheduler scheduler = schedulerFactory.getScheduler(); TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroupName); Trigger.TriggerState state = scheduler.getTriggerState(triggerKey); jobstatus = jobstatus + state; } catch (SchedulerException e) { e.printStackTrace(); } return jobstatus; } public static void main(String[] args) { try { System.out.println("【系统启动】开始(每1秒输出一次)..."); addJob("测试定时任务", "测试分组", "测试触发器", "测试触发器分组", CronTabTask.class, "0/1 * * * * ?", "9527"); addJob("测试定时任务1", "测试分组1", "测试触发器1", "测试触发器分组1", CronTabTask.class, "0/2 * * * * ?", "850318"); System.out.println(GetJobStatus("测试触发器", "测试触发器分组")); Thread.sleep(5000L); ShutDownJob("测试定时任务1", "测试分组1"); System.out.println(GetJobStatus("测试触发器1", "测试触发器分组1")); } catch (Exception e) { e.printStackTrace(); } } }
将这个类添加到公用包中，在须要操做定时任务的地方进行灵活调用，便可完成你的需求。注意说明的一点是：个人定时任务比较复杂，须要借助于”clid”来执行后续操做，因此在添加的时候须要传参数来给定时任务。传参数的语句以下：测试
jobDetail.getJobDataMap().put("clid", clid);ui
三， 定时任务执行类
经过编写下面的类来执行具体的定时任务：spa
package com.bj58.qa.comtestplatform.web.bll.Admonitorbll; import com.bj58.ershou.common.helper.LoggerHelper; import java.io.PrintStream; import java.util.Date; import org.quartz.Job; import org.quartz.JobDataMap; import org.quartz.JobDetail; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; public class CronTabTask implements Job { private static LoggerHelper loggerHelper = new LoggerHelper(CronTabTask.class); /** * 执行监控任务的定时任务 */ public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { String clid = jobExecutionContext.getJobDetail().getJobDataMap().getString("clid"); AdMonitorCronTab amct = new AdMonitorCronTab(); amct.AdMonitorTask(clid); System.out.println(new Date() + ": 执行广告监控任务，任务ID：" + clid); } }
而这个类中的AdMonitorCronTab才是我具体须要监控的内容，经过调用AdMonitorTask(clid)来执行具体的操做。由于涉及具体的业务，就不在此粘贴代码了。
四， 总结
在具体的开发工做中，经过在网上查找相应的文章，加上本身的调试总结。充分证实上面代码是的效可用的，借助于前端用户交互效果，能很好地完成对定时任务的灵活操做，在此将相关的内容总结一下，但愿对有须要的同窗一点儿提示。