使用quratz定时调用

标签：quratz   任务调度   

最近在工作上需要定时调用的功能，定时调用在web中应用还是蛮多的，比如说课表提醒，每天晚上提醒一遍有什么课要上啦，或者就像目前我需要完成的功能，定时的一个数据库的数据导入到另一个数据库中。

而quratz是一个完全由java编写的开源作业调度框架。尽管Quartz框架整合了许多额外功能， 但就其简易形式看，你会发现它易用得简直让人受不了！使用起来确实特别方便，也很实用。

废话不多说，直接上！

首先需要quratz相关jar包，我使用的是quartz-2.2.1.jar。

接下来就需要一个job执行类和一个任务调度类。

任务调度类，在该类中制定corn表达式，通过该表达式来按你的要求来实现定时方式，比如每天某个时间运行。

package com.gisquest.djgx.modules.services;

import java.util.Properties;

import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;  
import org.quartz.Scheduler;  
import org.quartz.SchedulerFactory;  
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;  
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import com.gisquest.djgx.modules.sys.entity.WsDefine;
import com.gisquest.djgx.modules.sys.utils.DictUtils;

@Component
@Transactional(readOnly = true)
public class InvokeService {

    SchedulerFactory sf = null;
    Scheduler sched = null;

	// 点击启动按钮调用的方法
	public void scheduler(WsDefine wsDefine,String basePath,String id) {
		String deftime = wsDefine.getDeftime();
		String month = "*";
		String year = "?";

		String schedName = "schedu"+id;
		String jobName = "job"+id;
		String groupName = "group"+id;
		String triggerName = "trigger"+id;
		String schedString="";
		try {
			Properties props = new Properties();
			props.put("org.quartz.scheduler.instanceName", schedName);
			props.put("org.quartz.threadPool.threadCount", "100");
			sf = new StdSchedulerFactory(props);
			if(sf.getScheduler(schedName) != null){
				sched = sf.getScheduler(schedName);  // 初始化调度器
			}else{
				sched = sf.getScheduler();  // 初始化调度器
			}
			JobDetail job = JobBuilder.newJob(QuartzJob.class)
					.withIdentity(jobName, groupName).build(); // 设置作业，具体操作在QuartzJob类里
			job.getJobDataMap().put("wsurl", basePath+wsDefine.getUrl());//添加调用功能需要的熟悉
			job.getJobDataMap().put("jobid", wsDefine.getJobid());
			job.getJobDataMap().put("wsname", wsDefine.getName());
String[] str = deftime.split(":");
			 schedString = str[2] + " " + str[1] + " " +str[0]+ " " + "*"
					+ " " + month + " " + year;
			
			System.out.println(schedString);
			System.out.println(sched);
			CronTrigger trigger = (CronTrigger) TriggerBuilder
					.newTrigger()
					.withIdentity(triggerName, groupName)
					.withSchedule(CronScheduleBuilder.cronSchedule(schedString))
					.build(); // 设置触发器
			sched.scheduleJob(job, trigger); // 设置调度作业
			sched.start(); // 开启调度任务，执行作业
		} catch (Exception ex) {
			ex.printStackTrace();
		}
	}

	// 点击停止按钮调用的方法
	public void stopService(String id) {
		String schedName = "schedu"+id;
		try {
			if (sf.getScheduler(schedName) != null) {
				sf.getScheduler(schedName).shutdown();
			}
		} catch (Exception ex) {
			ex.printStackTrace();
		}
	}
}

job执行类，该类需要实现quratz的job接口，并实现execute方法，你要定时调用的功能就在该execute方法中调用。

<span style="font-size:18px;">package com.gisquest.djgx.modules.services;

import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

@Component
@Transactional(readOnly = true)
public class QuartzJob implements Job {
	private static final Logger log = LoggerFactory.getLogger(QuartzJob.class);
	
	@Override
	public void execute(JobExecutionContext context)
			throws JobExecutionException {
		try {
			JobDataMap dataMap = context.getJobDetail().getJobDataMap();
			String wsurl = dataMap.getString("wsurl");
			String jobid = String.valueOf(dataMap.getInt("jobid"));//从之前在任务调度中传入的属性
			String wsname = dataMap.getString("wsname");
			System.out.println(wsurl+jobid+wsname);
			WsService wsService = new WsService();
			System.out.println(wsService);
			wsService.callWebService(null,wsurl,"pushData",jobid,wsname);//定时调用的方法
		} catch (Exception e) {
			e.printStackTrace();
			log.error(e.getLocalizedMessage());
		}
	}

}</span>

CronTrigger配置格式:
格式: [秒] [分] [小时] [日] [月] [周] [年]

常用示例:

使用quratz定时调用

标签：quratz   任务调度   

原文地址：http://blog.csdn.net/nethackatschool/article/details/47395797