使用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]+ " " + "*"//這裡就是設定定時的表達式，我這裡將時間按「：」分割成str數組

+ " " + 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();

}

}

}

這上面只使用了CronTrigger的方式，還有一種更簡單點的方式SimpleTrigger，該方式沒有cronTrigger方式更精確。在本文下面有CronTrigger表達式的配置格式。

job執行類，該類需要實現quratz的job介面，並實現execute方法，你要定時調用的功能就在該execute方法中調用。

<span stylex="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配置格式:

格式: [秒] [分] [小時] [日] [月] [周] [年]

序號 說明 是否必填 允許填寫的值 允許的通配符

1 秒 是 0-59 , - * /

2 分 是 0-59 , - * /

3 小時 是 0-23 , - * /

4 日 是 1-31 , - * ? / L W

5 月 是 1-12 or JAN-DEC , - * /

6 周 是 1-7 or SUN-SAT , - * ? / L #

7 年 否 empty 或 1970-2099 , - * /

常用示例:

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 * * ? 每天下午的 2點到2點59分(整點開始，每隔5分觸發) 每天下午的 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分觸發(光棍節)

喜歡這篇文章嗎？立刻分享出去讓更多人知道吧！