文档章节

JFinal QuartzPlugin

绝望的八皮
 绝望的八皮
发布于 2012/07/20 00:10
字数 369
阅读 3522
收藏 10

前段时间折腾了个cron4j plugin,用了一段时间发现还是要把周期控制到秒级,所以又来弄个quartz的,以前从来没用过原生的quartz,对这玩意儿也不熟悉,下了最新的2.1.5的包,从例子中拷了些代码出来把基本功能实现了。

完成了上次没做到的配置enable参数决定是否开启任务的功能。目前是用配置文件的形式实现的。

 

package com.jfinal.plugin.quartz;



import static org.quartz.CronScheduleBuilder.cronSchedule;

import static org.quartz.JobBuilder.newJob;

import static org.quartz.TriggerBuilder.newTrigger;



import java.io.IOException;

import java.io.InputStream;

import java.util.Date;

import java.util.Enumeration;

import java.util.Properties;



import org.quartz.CronTrigger;

import org.quartz.JobDetail;

import org.quartz.Scheduler;

import org.quartz.SchedulerException;

import org.quartz.SchedulerFactory;

import org.quartz.impl.StdSchedulerFactory;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;



import com.jfinal.plugin.IPlugin;



public class QuartzPlugin implements IPlugin {

	private Logger logger = LoggerFactory.getLogger(getClass());

	private SchedulerFactory sf = null;

	private Scheduler sched = null;

	private String config = "job.properties";

	private Properties properties;



	public QuartzPlugin(String config) {

		this.config = config;

	}



	public QuartzPlugin() {

	}



	@Override

	public boolean start() {

		sf = new StdSchedulerFactory();

		try {

			sched = sf.getScheduler();

		} catch (SchedulerException e) {

			new RuntimeException(e);

		}

		loadProperties();

		Enumeration enums = properties.keys();

		while (enums.hasMoreElements()) {

			String key = enums.nextElement() + "";

			if (!key.endsWith("job")) {

				continue;

			}

			String cronKey = key.substring(0, key.indexOf("job")) + "cron";

			String enable = key.substring(0, key.indexOf("job")) + "enable";

			if (isDisableJob(enable)) {

				continue;

			}

			String jobClassName = properties.get(key) + "";

			String jobCronExp = properties.getProperty(cronKey) + "";

			Class clazz;

			try {

				clazz = Class.forName(jobClassName);

			} catch (ClassNotFoundException e) {

				throw new RuntimeException(e);

			}

			JobDetail job = newJob(clazz).withIdentity(jobClassName,

					jobClassName).build();

			CronTrigger trigger = newTrigger()

					.withIdentity(jobClassName, jobClassName)

					.withSchedule(cronSchedule(jobCronExp)).build();

			Date ft = null;

			try {

				ft = sched.scheduleJob(job, trigger);

				sched.start();

			} catch (SchedulerException e) {

				new RuntimeException(e);

			}

			logger.info(job.getKey() + " has been scheduled to run at: " + ft

					+ " and repeat based on expression: "

					+ trigger.getCronExpression());

		}

		return true;

	}



	private boolean isDisableJob(String enable) {

		return Boolean.valueOf(properties.get(enable) + "") == false;

	}



	private void loadProperties() {

		properties = new Properties();

		InputStream is = QuartzPlugin.class.getClassLoader()

				.getResourceAsStream(config);

		try {

			properties.load(is);

		} catch (IOException e) {

			throw new RuntimeException(e);

		}

	}



	@Override

	public boolean stop() {

		try {

			sched.shutdown();

		} catch (SchedulerException e) {

			logger.error("shutdown error", e);

			return false;

		}

		return true;

	}



}

smsup.job=com.xx.xx.job.SmsUpReceiveJob 
smsup.cron=*/10 * * * * ? 
smsup.enable=true

© 著作权归作者所有

共有 人打赏支持
绝望的八皮

绝望的八皮

粉丝 392
博文 22
码字总数 10505
作品 2
其它
CTO(技术副总裁)
私信 提问
加载中

评论(7)

因为帅所以自卑
因为帅所以自卑
感谢分享,可以用了
azura111
azura111
@绝望的八皮您好,quartz和jfinal如何做定时任务的动态控制?比如暂停啊,添加啊之类。
绝望的八皮
绝望的八皮

引用来自“孙青彪”的评论

这种任务调度,弄一个框架配置下就好,例如spring与它的集成
如果是基于spring的项目可以
写下带不走的风
写下带不走的风
这种任务调度,弄一个框架配置下就好,例如spring与它的集成
jerri
jerri

引用来自“绝望的八皮”的评论

引用来自“jackjie”的评论

在执行job的时候,在job中使用jfinal获得数据库的connection获取不到(threadpool.get()方法获得的connection为空),用原生的jdbc就可以获取到,这是为什么呢

你没有用c3p0或者druid的plugin吧

这个我都用了,但获取的connection为空
绝望的八皮
绝望的八皮

引用来自“jackjie”的评论

在执行job的时候,在job中使用jfinal获得数据库的connection获取不到(threadpool.get()方法获得的connection为空),用原生的jdbc就可以获取到,这是为什么呢

你没有用c3p0或者druid的plugin吧
jerri
jerri
在执行job的时候,在job中使用jfinal获得数据库的connection获取不到(threadpool.get()方法获得的connection为空),用原生的jdbc就可以获取到,这是为什么呢
JFinal 整合Quartz

项目中要加入调度和计划任务等功能,所以选择Quartz调度插件,原先都是在S2SH上整合的。现在项目用JFinal框架,不得不说JFinal框架的定制性真好,可以自己根据项目要求进行修改,并且很节省时...

超级大富
2014/03/09
0
20
JFinal Extensions 1.0 发布,JFinal 扩展

Jfinal-ext是对java极速web框架 jfinal 的一个扩充,主要利用jfinal的plugin机制集成各种第三方框架,像spring一样,简化开发者的学习应用成本,使用时请将jfinal.jar先引入工程。 Jfinal-e...

绝望的八皮
2012/10/14
1K
13
JFinal Extensions 3.1.3 发布,JFinal 扩展

JFinal Extensions 3.1.3 发布,这次是一个小版本更新,主要是功能的小改进和bug修复。 Quartzplugin 兼容quartz 1.X 和 2.X 两大版本 Quartzplugin 支持原生quartz.properties配置文件 PoiR...

绝望的八皮
2015/02/03
6.2K
32
JFinal Extensions 1.1 发布,JFinal 扩展

Jfinal-ext是对java极速web框架 jfinal 的一个扩充,主要利用jfinal的plugin机制集成各种第三方框架,像spring一样,简化开发者的学习应用成本,使用时请将jfinal.jar先引入工程。 changelo...

绝望的八皮
2012/10/26
681
12
jfinal QuartzPlugin

@JFinal 你好,想跟你请教个问题: 请问jfinal里面的.QuartzPlugin 插件,,,我想启动工程的时候就去执行一次对的job,,怎么做呢.麻烦告诉一下,谢谢哦.

keen123
2015/08/05
390
2

没有更多内容

加载失败,请刷新页面

加载更多

cxf框架的介绍

小小小施爷
26分钟前
3
0
35K成功入职:蚂蚁金服面试Java后端经历!

上个月4号通过阿里工作的学长进行内推,7天简历评估,11号接到电话面试,尽管猝不及防回答仓促,但好在前期准备充分,通过。3天后进行现场面试,通知时间为早上10点。当日设了七点闹钟,结果...

别打我会飞
27分钟前
3
0
【HAVENT原创】让 IE6 ~ IE8 浏览器也支持 map 和 filter 方法

Array.prototype 扩展可以让 IE6 ~ IE8 浏览器也支持 map 的方法: if (typeof Array.prototype.map != "function") { Array.prototype.map = function (fn, context) { var arr = [......

HAVENT
27分钟前
2
0
SMSSDK的Unity3D的两种集成方式

SMSSDK的Unity3D插件主要为用户提供了两种集成的方式,一种是通过桥接文件直接调用SMSSDK的原生API,另外一种是集成SMSSDK_Demo中的UI,这两种方式的集成,方便用户根据自己的需要进行不同的...

佳妮
36分钟前
1
0
云计算、大数据、编程语言学习指南下载,100+技术课程免费学!这份诚意满满的新年技术大礼包,你Get了吗?

开发者认证、云学院、技术社群,更多精彩,尽在开发者会场 近年来,新技术发展迅速。互联网行业持续高速增长,平均薪资水平持续提升,互联网技术学习已俨然成为学生、在职人员都感兴趣的“业...

zhaowei121
38分钟前
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部