Skip to content

Latest commit

 

History

History

nutz-integration-quartz

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
demo
demo
 
 
src
src
 
 
.gitignore
.gitignore
 
 
README.md
README.md
 
 
pom.xml
pom.xml
 
 

README.md

Nutz集成Quartz的插件

简介(可用性:生产,维护者:wendal)

集成Quartz(计划任务/定时任务)的不二选择

  • 一个预定义的IocLoader,包含Quartz启动所需要的2个bean的定义
  • 一个任务加载类(可选)

使用方法

  • 添加quartz的jar, 支持2.2.1或以上的版本,建议用最新版
  • 在src或maven的resources目录下添加一个 quartz.properties
  • 在MainModule的IocBy中引用QuartzIocLoader
  • 在需要使用quartz的类中引用Scheduler即可

供参考的quartz.properties,也是quartz最简单的配置

org.quartz.scheduler.instanceName = NutzbookScheduler 
org.quartz.threadPool.threadCount = 3 
org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore
org.quartz.scheduler.skipUpdateCheck=true

示例IocBy配置

@IocBy(type=ComboIocProvider.class, args={"*js", "ioc/",
									   "*anno", "net.wendal.nutzbook",
									   "*quartz"})

在Module或Service中引用Scheduler

Quartz的核心类Scheduler, 得到它,你几乎可以操作Quartz的一切

// 注入的方式

@Inject Scheduler scheduler;

// 或主动获取的方式

Scheduler scheduler = ioc.get(Scheduler.class);

任务加载类NutQuartzCronJobFactory(可选的)

本插件额外提供了一个简单的任务加载类,可以从conf这个ioc bean中读取cron开头的属性来启动任务

启用方式,在SetupBy的init方法中

nc.getIoc().get(NutQuartzCronJobFactory.class)

配置文件的内容cron.properties, 通过用户自行定义的名为conf的PropertiesProxy实例加载.

cron.net.wendal.nutzbook.quartz.job.CleanNonActiveUserJob=0 0/2 * * * ?

扫描注解的方式(Scheduled注解)

cron.pkgs=net.wendal.nutzbook.quartz.job

详细用法可以参考nutzbook中的相关描述

示例conf bean定义

可以单独一个js或者放在dao.js

单独一个conf.js文件

var ioc = {
        conf : {
            type : "org.nutz.ioc.impl.PropertiesProxy",
            fields : {
                paths : ["custom/"]
            }
        }
};

放置到dao.js中, 因为一般来说都有dao.js,而且dao这个bean通常也需要conf配置信息

示例来至nutzbook

var ioc = {
		conf : {
			type : "org.nutz.ioc.impl.PropertiesProxy",
			fields : {
				paths : ["custom/"]
			}
		},
	    dataSource : {
	        type : "com.alibaba.druid.pool.DruidDataSource",
	        events : {
	        	create : "init",
	            depose : 'close'
	        },
	        fields : {
	            url : {java:"$conf.get('db.url')"},
	            username : {java:"$conf.get('db.username')"},
	            password : {java:"$conf.get('db.password')"},
	            testWhileIdle : true,
	            validationQuery : {java:"$conf.get('db.validationQuery')"},
	            maxActive : {java:"$conf.get('db.maxActive')"},
	            filters : "mergeStat",
	            connectionProperties : "druid.stat.slowSqlMillis=2000"
	        }
	    },
		dao : {
			type : "org.nutz.dao.impl.NutDao",
			args : [{refer:"dataSource"}]
		}
};

Quartz Cron表达式简介

请参考 http://www.blogjava.net/javagrass/archive/2011/07/12/354134.html