java程序员Java学习笔记

java中如何用Quartz框架来实现定时任务(一)

2017-07-24  本文已影响252人  程序员小哥哥

Quartz介绍:
Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,它可以与J2EE与J2SE应用程序相结合也可以单独使用。Quartz可以用来创建简单或为运行十个,百个,甚至是好几万个Jobs这样复杂的程序。而我们在写Java程序中经常会写一些定时执行的任务,比如某月的几号去执行一件事,每天的凌晨做些什么,或者每天执行一次什么方法,接下来我把简单的Quartz入门实例放进来,是可以直接运行,是对Quartz的增删改查系列,可以对于初学者,有个大概的了解。
QuartzManager(增删改查方法):

package com.joyce.quartz;  
  
import org.quartz.CronTrigger;  
import org.quartz.JobDetail;  
import org.quartz.Scheduler;  
import org.quartz.SchedulerFactory;  
import org.quartz.impl.StdSchedulerFactory;  
  
public class QuartzManager {  
    private static SchedulerFactory gSchedulerFactory = new StdSchedulerFactory();  
    private static String JOB_GROUP_NAME = "EXTJWEB_JOBGROUP_NAME";  
    private static String TRIGGER_GROUP_NAME = "EXTJWEB_TRIGGERGROUP_NAME";  
  
    /** 
     * 添加一个定时任务,使用默认的任务组名,触发器名,触发器组名 
     * @param jobName 任务名 
     * @param cls 任务 
     * @param time 时间设置 
     */  
    @SuppressWarnings("rawtypes")  
    public static void addJob(String jobName, Class cls, String time) {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();  
            // 任务名,任务组,任务执行类  
            JobDetail jobDetail = new JobDetail(jobName, JOB_GROUP_NAME, cls);  
            //可以传递参数  
            jobDetail.getJobDataMap().put("param", "railsboy");  
            // 触发器  
            CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME);  
            // 触发器名,触发器组  
            trigger.setCronExpression(time);  
            // 触发器时间设定  
            sched.scheduleJob(jobDetail, trigger);  
            // 启动  
            if (!sched.isShutdown()) {  
                sched.start();  
            }  
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
    /** 
     * 修改一个任务的触发时间(使用默认的任务组名,触发器名,触发器组名) 
     * @param jobName 
     * @param time 
     */  
    @SuppressWarnings("rawtypes")  
    public static void modifyJobTime(String jobName, String time) {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();  
            CronTrigger trigger = (CronTrigger) sched.getTrigger(jobName,TRIGGER_GROUP_NAME);  
            if (trigger == null) {  
                return;  
            }  
            String oldTime = trigger.getCronExpression();  
            if (!oldTime.equalsIgnoreCase(time)) {  
                JobDetail jobDetail = sched.getJobDetail(jobName,JOB_GROUP_NAME);  
                Class objJobClass = jobDetail.getJobClass();  
                removeJob(jobName);  
                addJob(jobName, objJobClass, time);  
            }  
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
  
  
    /** 
     * 移除一个任务(使用默认的任务组名,触发器名,触发器组名) 
     * @param jobName 
     */  
    public static void removeJob(String jobName) {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();  
            sched.pauseTrigger(jobName, TRIGGER_GROUP_NAME);// 停止触发器  
            sched.unscheduleJob(jobName, TRIGGER_GROUP_NAME);// 移除触发器  
            sched.deleteJob(jobName, JOB_GROUP_NAME);// 删除任务  
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
  
    /** 
     * 启动所有定时任务 
     */  
    public static void startJobs() {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();  
            sched.start();  
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
  
    /** 
     * 关闭所有定时任务 
     */  
    public static void shutdownJobs() {  
        try {  
            Scheduler sched = gSchedulerFactory.getScheduler();  
            if (!sched.isShutdown()) {  
                sched.shutdown();  
            }  
        } catch (Exception e) {  
            throw new RuntimeException(e);  
        }  
    }  
}  

QuartzJob(任务执行类):

package com.joyce.quartz;  
  
import java.text.SimpleDateFormat;  
import java.util.Date;  
  
import org.quartz.Job;  
import org.quartz.JobDataMap;  
import org.quartz.JobExecutionContext;  
import org.quartz.JobExecutionException;  
  
/** 
 * 任务执行类 
 */  
public class QuartzJob implements Job {  
  
    @Override  
    public void execute(JobExecutionContext content) throws JobExecutionException {  
        System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+ "★★★★★★★★★★★");    
        String jobName = content.getJobDetail().getName();  
        JobDataMap dataMap = content.getJobDetail().getJobDataMap();  
        String param = dataMap.getString("param");  
        System.out.println("传递的参数是="+param +"任务名字是="+jobName);  
    }  
}  

QuartzTest(定时任务测试类):

package com.joyce.quartz.main;  
  
import java.text.SimpleDateFormat;  
import java.util.Date;  
  
import com.joyce.quartz.QuartzJob;  
import com.joyce.quartz.QuartzManager;  
  
public class QuartzTest {  
    public static void main(String[] args) {  
        try {  
            String job_name = "动态任务调度";  
            System.out.println("【任务启动】开始(每10秒输出一次)...");    
            QuartzManager.addJob(job_name, QuartzJob.class, "0/10 * * * * ?");  
            Thread.sleep(5000);  
            System.out.println("【修改时间】开始(每2秒输出一次)...");    
            QuartzManager.modifyJobTime(job_name, "10/2 * * * * ?");    
            Thread.sleep(6000);    
            System.out.println("【移除定时】开始...");    
            QuartzManager.removeJob(job_name);    
            System.out.println("【移除定时】成功");    
            System.out.println("【再次添加定时任务】开始(每10秒输出一次)...");    
            QuartzManager.addJob(job_name, QuartzJob.class, "*/10 * * * * ?");    
            Thread.sleep(60000);    
            System.out.println("【移除定时】开始...");    
            QuartzManager.removeJob(job_name);    
            System.out.println("【移除定时】成功");  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
    }  
      
    public static String formatDateByPattern(Date date,String dateFormat){    
        SimpleDateFormat sdf = new SimpleDateFormat(dateFormat);    
        String formatTimeStr = null;    
        if (date != null) {    
            formatTimeStr = sdf.format(date);    
        }    
        return formatTimeStr;    
    }    
    public static String getCron(java.util.Date  date){    
        String dateFormat="ss mm HH dd MM ? yyyy";    
        return formatDateByPattern(date, dateFormat);    
     }    
}  

效果:

mylife.png

使用quartz执行定时任务需要的jar包下载地址:http://download.csdn.net/detail/i__am__sai/9719500
常用的时间配置:
格式: [秒] [分] [小时] [日] [月] [周] [年]0 0 12 * * ?
每天12点触发 0 15 10 ? * *
每天10点15分触发 0 15 10 * * ?
每天10点15分触发 0 15 10 * * ? *
每天10点15分触发 0 15 10 * * ? 2005
2005年每天10点15分触发 0 * 14 * * ?
每天下午的 2点到2点59分每分触发 0 0/5 14 * * ?
每天下午的 2点到2点59分(整点开始,每隔5分触发) 0 0/5 14,18 * * ?
每天下午的 18点到18点59分(整点开始,每隔5分触发)0 0-5 14 * * ?
每天下午的 2点到2点05分每分触发 0 10,44 14 ? 3 WED
3月分每周三下午的 2点10分和2点44分触发 0 15 10 ? * MON-FRI
从周一到周五每天上午的10点15分触发 0 15 10 15 * ?
每月15号上午10点15分触发 0 15 10 L * ?
每月最后一天的10点15分触发 0 15 10 ? * 6L
每月最后一周的星期五的10点15分触发 0 15 10 ? * 6L 2002-2005
从2002年到2005年每月最后一周的星期五的10点15分触发0 15 10 ? * 6#3 每月的第三周的星期五开始触发 0 0 12 1/5 * ?
每月的第一个中午开始每隔5天触发一次 0 11 11 11 11 ?
每年的11月11号 11点11分触发(光棍节)


下一节写下quartz复杂的动态执行任务,也是我在实际商业项目中用到的。

上一篇下一篇

猜你喜欢

热点阅读