spring3.2.0 quartz-2.2.1 整合 實現動態定時任務

時間  2019-11-11
標籤 spring3.2.0 spring quartz 2.2.1 整合 實現 動態 定時 任務 欄目 Spring 简体版
原文   原文鏈接

spring3.2.0 quartz-2.2.1 實現動態定時任務java

    spring 和 quartz的整合很簡單，可是實現動態定時任務卻有一點麻煩，下面詳細介紹一下 spring3.2.0和quzrtz2.2.1 的整合 實現定時任務的的動態加載spring

類介紹

    

QuartzManager.java   任務的管理（添加、刪除、啓動、任務列表等），更多功能看官方文檔：http://www.quartz-scheduler.org/documentation/quartz-2.2.x/tutorials/app

MyJobFactory.java  job自動注入Spring容器ide

OverOrderJobExample.java/CloseOrderJobExample.java   job執行內容ui

源代碼

MyJobFactory.javathis

package chaomeiman.yueshou.job;

import org.quartz.spi.TriggerFiredBundle;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.AdaptableJobFactory;

@Configuration("myJobFactory")
public class MyJobFactory extends AdaptableJobFactory{

	@Autowired
	private AutowireCapableBeanFactory capableBeanFactory;

	@Override
	protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
		//調用父類的方法
		Object jobInstance = super.createJobInstance(bundle);
		capableBeanFactory.autowireBeanProperties(jobInstance, AutowireCapableBeanFactory.AUTOWIRE_BY_NAME, false);
		return jobInstance;
	}
}

配置applicationContext.xmlspa

<bean id="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="jobFactory" ref="myJobFactory"/>
    </bean>

QuartzManager.java3d

package chaomeiman.yueshou.job;


import chaomeiman.yueshou.model.main.JobInfo;
import org.quartz.*;
import org.quartz.impl.matchers.GroupMatcher;
import org.springframework.context.annotation.Configuration;

import static org.quartz.JobBuilder.newJob;

@Configuration
public class QuartzManager {

	/**
	 * 關閉全部定時任務
	 */
	public static void shutdownJobs(Scheduler sched) {
		try {
			if (! sched.isShutdown()) {
				sched.shutdown();
			}
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
	}

	/**
	 * 添加任務調度
	 * @param scheduler
	 * @param job
	 * @param classz
	 * @throws SchedulerException
	 */
	public void addJob(Scheduler scheduler, JobInfo job, Class classz) throws SchedulerException {
		TriggerKey triggerKey = TriggerKey.triggerKey(job.getJob_name(), job.getJob_group());
		CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
		if (null == trigger) {
			//不存在觸發器，建立一個
			JobDetail jobDetail = newJob(classz).withIdentity(job.getJob_name(), job.getJob_group()).build();
			jobDetail.getJobDataMap().put("jobInfo", job);
			//表達式調度構建器
			CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job.getJob_quartz_time());
			//按新的cronExpression表達式構建一個新的trigger
			trigger = TriggerBuilder.newTrigger().withIdentity(job.getJob_name(), job.getJob_group()).withSchedule(scheduleBuilder).build();
			scheduler.scheduleJob(jobDetail, trigger);
		} else {
			// Trigger已存在，那麼更新相應的定時設置
			//表達式調度構建器
			CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job.getJob_quartz_time());
			//按新的cronExpression表達式從新構建trigger
			trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
			//按新的trigger從新設置job執行
			scheduler.rescheduleJob(triggerKey, trigger);
		}
	}

	/**
	 * 刪除任務調度
	 * @param scheduler
	 * @param job
	 * @param classz
	 * @throws SchedulerException
	 */
	public void removeJob(Scheduler scheduler, JobInfo job, Class classz) throws SchedulerException {
		TriggerKey triggerKey = TriggerKey.triggerKey(job.getJob_name(), job.getJob_group());
		CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
		if (null == trigger) {
			//不存在觸發器，建立一個
			JobDetail jobDetail = newJob(classz).withIdentity(job.getJob_name(), job.getJob_group()).build();
			jobDetail.getJobDataMap().put("jobInfo", job);
			//表達式調度構建器
			CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job.getJob_time());
			//按新的cronExpression表達式構建一個新的trigger
			trigger = TriggerBuilder.newTrigger().withIdentity(job.getJob_name(), job.getJob_group()).withSchedule(scheduleBuilder).build();
			scheduler.scheduleJob(jobDetail, trigger);
		} else {
			// Trigger已存在，那麼更新相應的定時設置
			//表達式調度構建器
			CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job.getJob_time());
			//按新的cronExpression表達式從新構建trigger
			trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
			//按新的trigger從新設置job執行
			scheduler.rescheduleJob(triggerKey, trigger);
		}
	}

	/**
	 * 獲取任務調度列表
	 * @param scheduler
	 * @throws SchedulerException
	 */
	public void listJob(Scheduler scheduler) throws SchedulerException {
		for(String group: scheduler.getJobGroupNames()) {
			for(JobKey jobKey : scheduler.getJobKeys(GroupMatcher.groupEquals(group))) {
				System.out.println("Found job identified by: " + jobKey);
			}
		}
	}



	/**
	 * 啓動全部定時任務
	 */
	public void startJobs(Scheduler scheduler) {
		try {
			scheduler.start();
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
	}
}

OverOrderJobExample.javacode

package chaomeiman.yueshou.job;

import chaomeiman.yueshou.service.OrderService;
import code.ResultCodeUtil;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.beans.factory.annotation.Autowired;
import util.LogUtil;

public class OverOrderJobExample extends ResultCodeUtil implements Job {

	@Autowired
	private OrderService orderService;

	@Override
	public void execute(JobExecutionContext arg0) throws JobExecutionException {
		LogUtil.loger("---------開始執行完成訂單任務-------");
//		JobDataMap jobDataMap = arg0.getJobDetail().getJobDataMap();
		if (orderService != null) {
			try {
				//自動完成訂單
				//天天零點執行，將支付成功並已接單的訂單自動完成
				orderService.jobOverOrderInfo();
			} catch (Exception e) {
				e.printStackTrace();
			}
		} else {
			// TODO: 2017/2/25 獲取任務調度信息失敗
			LogUtil.loger("執行完成訂單任務失敗，orderService獲取失敗");
		}
		LogUtil.loger("---------執行完成訂單任務結束-------");
	}
}

test.javaorm

@Resource
	private Scheduler scheduler ;

	public Scheduler getScheduler() {
		return scheduler;
	}

	public void setScheduler(Scheduler scheduler) {
		this.scheduler = scheduler;
	}

	@Test
	public void testJob() throws Exception {

		String jobTime = "2017-02-27 16:54";
		DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm");
		LocalDateTime localDateTime = LocalDateTime.parse(jobTime, formatter);
		int H = localDateTime.getHour();
		int m = localDateTime.getMinute();
		int s = localDateTime.getSecond();
		int d = localDateTime.getDayOfMonth();
		int M = localDateTime.getMonthValue();
		int y = localDateTime.getYear();
		/** 秒 是 0-59 , - * /
		 分 是 0-59 , - * /
		 時 是 0-23 , - * /
		 日 是 1-31 , - * ? / L W C
		 月 是 1-12 或 JAN-DEC , - * /
		 周 是 1-7 或 SUN-SAT , - * ? / L C #
		 年 否 空 或 1970-2099 , - * /
		 **/
		String jobQuartzTime = s + " " + m + " " + " " + H + " " + d + " " + M + " " + "?" + " " + y;
		String uuid = UUIDUtil.getUUID();
		JobInfo jobInfo = new JobInfo();
		jobInfo.setUuid("a05eb41e833d499b883768ae1f25be69");
		jobInfo.setUuid2(CoderUtil.encryptMD5(System.currentTimeMillis()+uuid, CoderUtil.ENCODING_FORMAT_UTF_8));
		jobInfo.setJob_name("201702271437220000000581");
		jobInfo.setJob_quartz_time(jobQuartzTime);
		jobInfo.setJob_time("2017-02-27 14:45:00");
		jobInfo.setJob_group("closeOrder");
		jobInfo.setOrder_number("201702271437220000000581");
		jobInfo.setUser_uuid("93cd68fcb95043febd28d6ad86666029");
//		jobInfoMapper.insert(jobInfo);
		QuartzManager quartzManager = new QuartzManager();
		quartzManager.startJobs(scheduler);
		quartzManager.addJob(scheduler, jobInfo, CloseOrderJobExample.class);
		quartzManager.startJobs(scheduler);
		Thread.sleep(310000);
	}

結果：

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程