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());
}
}
【版本声明】本文为博主原创文章，转载请注明出处