quartz定时任务操作job-java非web项目

Posted on | In , |   本文总阅读量 次

命题

最近有一个需求是： 实现一个java
standalone应用，定时处理一些数据，并且记录日志，假如定时任务停掉，就会报警
先实现各定时任务在java项目main运行，后边的再慢慢研究

实现 思路

  • 创建我的job类
  • 创建test用于写测试调用job的代码

具体实现

我的job类:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
package cn.northpark.test.jobtask;

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

import cn.northpark.utils.TimeUtils;

public class myjob implements Job {



	public myjob() {
		// TODO Auto-generated constructor stub
	}

	@Override
	public void execute(JobExecutionContext arg0) throws JobExecutionException {
		// TODO Auto-generated method stub
		System.out.println(TimeUtils.nowTime());
	}

}

测试执行类：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
package cn.northpark.test.jobtask;

import java.util.Date;

import org.quartz.CronScheduleBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;


public class testjob {

	//将每隔20秒执行一次 
	public static String cronExpression = "0/20 * * * * ?";
	
	

	public static void main(String[] args) throws Exception { 
		//CronTrigger用于处理quartz表达式任务 比如每天的几点执行
		//SimpleTrigger   主要用于处理格时间重复调度

		// 首先，必需要取得一个Scheduler的引用 
		Scheduler scheduler = new StdSchedulerFactory().getScheduler();
		scheduler.start();

		//定义一个job
		JobKey jobKey  = new JobKey("test", "test-1");
		JobDetail jobDetail = JobBuilder.newJob(myjob.class).withIdentity(jobKey).build();

		//定义一个重复触发器 //2秒一次
		Trigger trigger = TriggerBuilder.newTrigger()
				.withIdentity("test","test")
				.startAt(new Date(System.currentTimeMillis()+1000))
				.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever())
				.build();




		//定义一个job
		JobKey jobKey2  = new JobKey("test2", "test-2");
		JobDetail jobDetail2 = JobBuilder.newJob(myjob.class).withIdentity(jobKey2).build();
		//定义一个quartz表达式任务 比如每天的几点执行
		Trigger crontrigger = TriggerBuilder.newTrigger()
				.withIdentity("test2","test2")
				.startAt(new Date(System.currentTimeMillis()+1000))
				.withSchedule(CronScheduleBuilder.cronSchedule(cronExpression))
				.build();

		scheduler.scheduleJob(jobDetail, trigger);
		scheduler.scheduleJob(jobDetail2, crontrigger);

		//Thread.sleep(5000); 


	}

}

说明与总结：

2017年11月15日

  • 运行testjob.java ，即可开启定时任务

  • myjob为定义的job类

  • Job(接口)

  • JobDetail： 真正的任务内容，任务本身是集成Job接口的，但是真正的任务是JobBuilder通过反射的方式实例化的，

  • Trigger： 触发器，定义任务应当开始的时间，主要分为两类SimpleTrigger,CronTrigger;CronTrigger主要用于处理quartz表达式定义的任务，比如每个月20号，每个星期一之类的。

CronTrigger用于处理quartz表达式任务 比如每天的几点执行
SimpleTrigger 主要用于处理格时间重复调度

  • Scheduler：任务调度器, 计划执行者，现在我们有了要做的内容(jobdetail)，有了要做的时间(trigger)，接下来，就把这两个内容填充到计划任务Scheduler对象里面，到了时间它就可以自动运行了
生活不止苟且,还有我喜爱的海岸.