码迷,mamicode.com
首页 > 其他好文 > 详细

任务调度 -----> quartz 不同时间间隔调度任务

时间:2018-01-06 19:06:00      阅读:231      评论:0      收藏:0      [点我收藏+]

标签:interrupt   版本   hid   scheduler   throw   pid   return   get   ide   

Quartz


 

  Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,它可以与J2EE与J2SE应用程序相结合也可以单独使用。Quartz可以用来创建简单或为运行十个,百个,甚至是好几万个Jobs这样复杂的程序。Jobs可以做成标准的Java组件或 EJBs。Quartz的最新版本为Quartz 2.3.0。

  目的:最近在想弄一下不同的时间段调度任务,不是以往那样在相同的间隔调度,而是不同的间隔时间,参考了一下Quartz官网和一些前辈的,加上自己总结的改进的方法  

  参考文章:Quartz使用总结

  Quartz的API: http://www.quartz-scheduler.org/api/2.1.7/index.html

  jar下载地址:http://www.quartz-scheduler.org/downloads/

  Maven:

<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>  

  主要思想:将你要想要调度的时间隔间传入,但是是使用一个实列 

代码:

package com.test.util;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.TriggerBuilder.newTrigger;

/**
 * @author zhouguanglin
 * @date 2018/1/6 11:17
 */
public class QuartzTest{
    private  static volatile  Scheduler scheduler=null;
    private static List<Integer> list=new ArrayList<Integer>();
    static {
        list.add(5);
        list.add(10);
        list.add(5);
        list.add(10);
    }
    //单列模式创建scheduler
    public static Scheduler getScheduler(){
        if (scheduler==null) {
            synchronized (QuartzTest.class) {
                try {
                    if (scheduler==null) {
                        scheduler = StdSchedulerFactory.getDefaultScheduler();
                    }
                } catch (SchedulerException e) {
                    e.printStackTrace();
                }
            }
        }
        return scheduler;
    }
    //任务调度
    public static Scheduler getSchedulerTask(String taskName,int time){
        Scheduler scheduler=getScheduler();

        try {
            //看是否启动
            if (!scheduler.isStarted()){
                scheduler.start();
            }
            //运行一段时间后关闭
            Thread.sleep(time*1000);
            //定义一个Trigger
            Trigger trigger = newTrigger().withIdentity("trigger", "group") //定义name/group
                    .startAt(new Date(time))//在这个时间之后发生
            //这里还可以用withwithSchedule()来控制调度情况 其中添加simpleSchedule()来控制间隔多少执行一次,执行多少次,还是一直执行
                    .build();
            //定义一个JobDetail
            JobDetail job = newJob(QuartzTask.class) //定义Job类为QuartzTask类,这是真正的执行逻辑所在
                    .withIdentity("job", "group") //定义name/group
                    .usingJobData("name", taskName) //定义属性
                    .usingJobData("zhou","zhouguanglin")
                    .build();
            //加入这个调度
            scheduler.scheduleJob(job, trigger);
        } catch (Exception e) {
            e.printStackTrace();
        }
        return scheduler;
    }
    public static void main(String[] args) throws SchedulerException, InterruptedException {

       for (int j=0;j<list.size();j++) {
           getSchedulerTask("任务:"+j,list.get(j));
       }
       //最后将scheduler关闭
        if (!scheduler.isShutdown()) {
           scheduler.shutdown();
        }
    }
}

 

真正的调度的任务逻辑在这:

package com.test.util;

import org.quartz.Job;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

/**
 * @author zhouguanglin
 * @date 2018/1/6 15:09
 */
public class QuartzTask implements Job {
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        //这里是读取上下文,得到其中的东西,只可意会不可言传,,,就好像Spring的感觉差不错
        JobDetail detail = jobExecutionContext.getJobDetail();
        String name = detail.getJobDataMap().getString("name");
       String zhou=detail.getJobDataMap().getString("zhou");
        System.out.println("任务开始。。。-------name:"+name+"   zhou:"+zhou);
        System.out.println(System.currentTimeMillis());
    }
}

 

                 【版本声明】本文为博主原创文章,转载请注明出处

 

任务调度 -----> quartz 不同时间间隔调度任务

标签:interrupt   版本   hid   scheduler   throw   pid   return   get   ide   

原文地址:https://www.cnblogs.com/zhouguanglin/p/8214918.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!