public class PsmsCleanJob implements Job {
public void execute(JobExecutionContext arg0) throws JobExecutionException {
JobDataMap map = context.getMergedJobDataMap();
Object obj = map.get("params");
}
}
package com.lec.util.job;
import java.text.ParseException;
import java.util.Date;
import java.util.HashMap;
import org.quartz.CronTrigger;
import org.quartz.Job;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;
/**
* CronTrigger任务调度器
* @author lcy
* Dec 1, 2011
*/
public class CronTriggerRunner {
private static SchedulerFactory sf = new StdSchedulerFactory();
/**
* 根据任务名和任务组名查询一个任务
* @param jobName
* @param jobGroupName
* @return
* @throws SchedulerException
*/
public static JobDetail getJob(String jobName,String jobGroupName) throws SchedulerException{
Scheduler sched = sf.getScheduler();
JobDetail jobDetail=sched.getJobDetail(jobName, jobGroupName);
if(jobDetail != null){
return jobDetail;
}
return null;
}
/**
* 添加一个CronTrigger定时任务
* @param jobName 任务名
* @param jobGroupName 任务组名
* @param triggerName 触发器名
* @param triggerGroupName 触发器组名
* @param job 任务
* @param time 时间设置，参考quartz说明文档
* @param params 传递参数
* @throws SchedulerException
* @throws ParseException
*/
public static void addJob(String jobName,String jobGroupName,String triggerName,
String triggerGroupName,String time,HashMap<String,Object> params,
Job jobClass) throws SchedulerException, ParseException{
Scheduler sched = sf.getScheduler();
JobDetail jobDetail = new JobDetail(jobName, jobGroupName, jobClass.getClass());//任务名，任务组，任务执行类
if(params != null){
jobDetail.getJobDataMap().put("params",params);
}
//触发器
CronTrigger trigger = new CronTrigger(triggerName, triggerGroupName);//触发器名,触发器组
trigger.setCronExpression(time);//触发器时间设定
sched.scheduleJob(jobDetail,trigger);
if(!sched.isShutdown())
sched.start();
}
/**
* 添加一个SimpleTrigger定时任务
* @param jobName 任务名
* @param jobGroupName 任务组名
* @param triggerName 触发器名
* @param triggerGroupName 触发器组名
* @param startTime 开始时间
* @param repeatInterval 间隔时间
* @param repeatCount 调用次数
* @param jobClass 任务
* @param params 传递参数
* @throws SchedulerException
*/
public static void addJob(String jobName,String jobGroup,
String triggerName,String triggerGroup,Date startTime,
Integer repeatInterval,Integer repeatCount,Job jobClass,
HashMap<String,Object> params) throws
SchedulerException{
JobDetail jobDetail = new JobDetail(jobName, jobGroup, jobClass.getClass());
if(params != null){
jobDetail.getJobDataMap().put("params",params);
}
//触发器
SimpleTrigger simpleTrigger = new SimpleTrigger(triggerName, triggerGroup);
//设置开始时间
simpleTrigger.setStartTime(startTime);
//设置间隔时间
simpleTrigger.setRepeatInterval(repeatInterval);
//设置调用次数
simpleTrigger.setRepeatCount(repeatCount);
Scheduler sched = sf.getScheduler();
sched.scheduleJob(jobDetail,simpleTrigger);
if(!sched.isShutdown())
sched.start();
}
/**
* 根据任务名和任务组名修改任务的触发时间
* @param jobName 任务名
* @param jobGroupName 任务组名
* @param time
* @throws SchedulerException
* @throws ParseException
*/
public static void modifyJobTime(String jobName,String jobGroupName,String time)
throws SchedulerException, ParseException{
Scheduler sched = sf.getScheduler();
Trigger[] trigger = sched.getTriggersOfJob(jobName,jobGroupName);
if(trigger != null){
for(int i=0;i<trigger.length;i++){
((CronTrigger)trigger[i]).setCronExpression(time);
sched.resumeTrigger(trigger[i].getName(),trigger[i].getGroup());
}
}
}
/**
* 根据触发器名修改一个任务的触发时间
* @param triggerName触发器名
* @param triggerGroupName触发器组名
* @param time
* @throws SchedulerException
* @throws ParseException
*/
public static void modifyTriggerTime(String triggerName,String triggerGroupName,
String time) throws SchedulerException, ParseException{
Scheduler sched = sf.getScheduler();
Trigger trigger = sched.getTrigger(triggerName,triggerGroupName);
if(trigger != null){
//修改时间
((CronTrigger)trigger).setCronExpression(time);
//重启触发器
sched.resumeTrigger(triggerName,triggerGroupName);
}
}
/**
* 移除任务
* @param jobName任务名
* @param jobGroupName任务组名
* @param triggerGroupName触发器组名
* @throws SchedulerException
*/
public static void removeJob(String jobName,String jobGroupName,String triggerGroupName)
throws SchedulerException{
Scheduler sched = sf.getScheduler();
String[] triggerNames = sched.getTriggerNames(triggerGroupName);
if(triggerNames!=null){
for(int i=0;i<triggerNames.length;i++){
sched.pauseTrigger(triggerNames[i],triggerGroupName);//停止触发器
sched.unscheduleJob(triggerNames[i],triggerGroupName);//移除触发器
}
}
sched.deleteJob(jobName,jobGroupName);//删除任务
}
/**
* 移除一个任务
* @param jobName任务名
* @param jobGroupName任务组名
* @param triggerName触发器名
* @param triggerGroupName触发器组名
* @throws SchedulerException
*/
public static void removeJob(String jobName,String jobGroupName,
String triggerName,String triggerGroupName)
throws SchedulerException{
Scheduler sched = sf.getScheduler();
sched.pauseTrigger(triggerName,triggerGroupName);//停止触发器
sched.unscheduleJob(triggerName,triggerGroupName);//移除触发器
sched.deleteJob(jobName,jobGroupName);//删除任务
}
/**
* 计算时间表达式
* @param second 秒
* @param minute 分
* @param hour 时
* @param day 日期
* @param month 月份
* @param week 星期
* @param year 年份
* @param isContactYear 是否包括年份
* @return
*/
public static String getCexpress(String second,String minute,String hour,
String day,String month,String week,String year,boolean isContactYear) {
String cexpress="";
//秒，默认为"0" 取值范围：0-59
if(second != null && !"".equals(second)){
cexpress+=second+" ";
}else{
cexpress+="0 ";
}
/**
* 分 取值范围：0-59
* 默认为"*" 表示每一分钟
* 如果是0 12 表示整12:00触发
* 如果是0/5 12 表示在每天下午12点到12:55期间的每5分钟触发 ，
* 如果是0-5 12 表示12:00到12:05期间的每1分钟触发
* 如果是10,15 12 表示12:10和12:15触发
*/
if(minute != null && !"".equals(minute)){
cexpress+=minute+" ";
}else{
cexpress+="* ";
}
/**
* 小时 取值范围：0-23
* 默认为"*" 表示每一个小时
* 如果是0 表示凌晨触发
* 如果是0-5 表示凌晨到5:00期间
* 如果是10,15 表示10:00和15:00触发
*/
if(hour != null && !"".equals(hour)){
cexpress+=hour+" ";
}else{
cexpress+="* ";
}
/**
* 日期 取值范围：1-31
* 默认为"*" 表示每天
* 如果是15 表示每个月的15号
* 如果是L 表示每个月最后一天
* 注：在指定了星期的时候，把日期这里设置为"?"
*/
if(day != null && !"".equals(day)){
cexpress+=day+" ";
}else{
cexpress+="* ";
}
/**
* 月份 取值范围：1-12
* 默认为"*" 表示每个月
* 如果是 12 表示12月份
*/
if(month != null && !"".equals(month)){
cexpress+=month+" ";
}else{
cexpress+="* ";
}
/**
* 星期 取值范围：1-7 MON,TUE,WED,THU,FRI,SAT,SUN 其中1表示星期日，以此类推
* 默认为"?"
* 如果是WED 表示每个星期三
* 如果是MON-FRI 表示星期一到星期五
* 如果是6L 表示每月最后一个星期五
* 如果是6#3 表示每月第三个星期五
*/
if(week != null && !"".equals(week)){
cexpress+=week+" ";
}else{
cexpress+="? ";
}
//如果包括年份
if(isContactYear){
/**
* 年份 取值范围：1970-2099
* 默认值为空
* 如果是2010 表示只有2010年触发时间
* 如果是2010,2020 表示只有2010
*/
if(year != null && !"".equals(year)){
cexpress+=year;
}
}
return cexpress;
}
public static void main(String [] args){
try {
// JobDetail jobDetail = new JobDetail(ResTypeDTO.PSMSCFG_JOBNAME,
// ResTypeDTO.PSMSCFG_JOBGROUPNAME,PsmsCleanJob.class);
// // ①-1：创建CronTrigger，指定组及名称
// CronTrigger cronTrigger = new CronTrigger(ResTypeDTO.PSMSCFG_TRIGGERNAME,
// ResTypeDTO.PSMSCFG_TRIGGERGROUPNAME);
// // ①-2：定义Cron表达式
// String timeexp = "";
// String second = "0";
// String minute = "15";
// String hour = "0";
// String day = "L";//当月的最后一天
// String month = "";
// String week = "?";
// month = "6,12";
// timeexp = getCexpress(second, minute, hour, day, month, week, null, false);
//
// if(!"0 * * * * ?".equals(timeexp)){//如果没有设置时间则不执行
// CronExpression cexp = new CronExpression(timeexp);
// // ①-3：设置Cron表达式
// cronTrigger.setCronExpression(cexp);
// Scheduler scheduler = sf.getScheduler();
// scheduler.scheduleJob(jobDetail, cronTrigger);
// scheduler.start();
// }
// Date startDate = entity.getStartDate();
// String startTime = entity.getStarttime();
// Integer delaytime = entity.getDelaytime();
// String unit = entity.getUnit();
String jobName = "cal_job_name_";
String jobGroupName = "cal_job_group_name";
String triggerName = "cal_trigger_name_";
String triggerGroupName = "cal_trigger_group_name";
Date beginTime = new Date(System.currentTimeMillis() + 60000L);//当前时间过60秒钟后开始
Integer repeatInterval = 5000;//以毫秒为单位
Integer repeatCount = 0;
try {
CronTriggerRunner.addJob(jobName,jobGroupName,triggerName,
triggerGroupName,beginTime,repeatInterval,
repeatCount,new CalendarJob(),new HashMap<String,Object>());
} catch (SchedulerException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
分享到：
相关推荐
《.NET Quartz 任务调度平台源码解析与应用》 .NET Quartz 是一款强大的任务调度框架，它为.NET开发者提供了一种高效、灵活的方式来安排和执行周期性任务。Quartz.NET 是开源项目Quartz的.NET版本，它允许开发人员...
Quartz任务调度器是一款强大的开源任务调度框架，广泛应用于Java应用程序中，用于自动化定时任务的执行。它提供了灵活的任务调度机制，使得开发者可以方便地定义、安排和执行各种任务。在与Spring框架整合后，Quartz...
**C#基于Quartz任务调度系统** 在软件开发中，任务调度是一项重要的功能，它允许开发者安排任务在特定时间执行，比如数据同步、定时备份、报告生成等。Quartz是一款强大的开源任务调度库，广泛应用于Java和.NET生态...
Quartz任务调度是一款开源的Java定时任务框架，广泛应用于企业级应用系统中，用于执行周期性的后台任务。这款工具提供了一种灵活的方式来安排和管理任务，使得开发者无需在业务代码中处理时间相关的逻辑，而是通过...
本“quartz任务调度框架简单实用小demo”旨在帮助开发者快速理解和应用Quartz。 1. **Quartz基本概念** - **Job**: 任务的基本单元，代表一个需要执行的工作。 - **Trigger**: 触发器，决定Job何时被执行。 - **...
### Quartz任务调度管理 #### 一、任务调度基础概念 任务调度是指系统按照预先设定的时间规则来自动执行特定任务的功能。这种机制广泛应用于各种场景，例如数据备份、定期检查资源状态、发送邮件通知等。 ##### ...
基于Spring Boot的Quartz任务调度系统 项目概述 本项目是一个基于Spring Boot和Quartz的任务调度系统，旨在提供灵活的任务管理和调度功能。系统支持多种任务类型，包括Cron表达式任务和单次时间任务，并提供了丰富...
里面包含了两个工程项目： 1.Java project工程（含jar包，JDK1.6）。 是spring+quartz的任务调度实例。 2.Java web工程（含jar包，JDK1.7）。 spring+mybatis+quartz任务调度实例
本项目"spring+quartz任务调度代码版"显然是一个结合了这两者的实践案例，旨在展示如何在Spring环境下集成和使用Quartz进行任务调度。 Spring框架是一个开源的应用框架，它提供了丰富的功能，包括依赖注入、AOP...
标题“Spring quartz任务调度”指的是在Java开发中利用Spring框架集成Quartz库来实现应用程序的任务调度功能。Quartz是一款开源的作业调度框架，它允许开发者安排任务在特定时间执行，而Spring框架则提供了与Quartz...
Quartz任务调度--详细教程,讲的非常详细
Spring框架作为一个全面的企业级应用开发解决方案，提供了强大的任务调度支持，而Quartz则是一个流行的开源作业调度库，能够与Spring很好地集成。现在，我们就来深入探讨"spring quartz 任务调度"这一主题。 首先，...
Quartz任务调度框架教程中文版 chm格式
**Spring Quartz 任务调度** Spring Quartz 是一个基于 Java 的任务调度框架，它允许开发者定义定时任务并在应用程序中灵活地调度这些任务。这个框架是 Spring 和 Quartz Scheduler 的集成，提供了与 Spring 框架的...
总的来说，这个 Quartz 任务调度的运行示例为你提供了一个动手实践的机会，加深对 Quartz 工作原理的理解。通过学习和应用这个示例，你将能够自如地在 Java 应用程序中实现复杂的定时任务调度。
本篇将通过一个简单的Quartz任务调度实例，来深入理解其核心概念和用法。 首先，我们需要了解Quartz的主要组件： 1. **Job**：工作接口，代表一个具体的任务，实现`org.quartz.Job`接口，定义了`execute...
Quartz任务调度是一种广泛使用的开源任务调度框架，它允许开发者创建、调度和管理定时任务。初学者通过学习Quartz，可以提升其编程技能，尤其是在Java应用程序中实现复杂定时任务的能力。 1. **Quartz框架**： - ...
### Quartz任务调度快速入门知识点详解 #### 一、Quartz框架简介 Quartz是一个功能强大的开源作业调度框架，被广泛应用于Java应用中实现任务的定时调度。Quartz通过对任务调度领域的核心问题进行高度抽象，提炼出...
Quartz任务调度框架是Java开发中的一个强大工具，用于在应用程序中实现定时任务的自动执行。它是一个开源的作业调度库，可以与Java应用程序无缝集成，允许开发人员定义和调度复杂的作业执行计划。Quartz提供了丰富的...