`
随心而行
  • 浏览: 13501 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

spring4+quartz2基本配置及应用

阅读更多
1、新建maven工程,添加spring4.0及quartz2.2依赖,pom.xml文件内容如下
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>com.qerooy</groupId>
	<artifactId>spring-quartz</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>war</packaging>

	<properties>
		<spring.version>4.0.2.RELEASE</spring.version>
		<log4j.version>1.2.17</log4j.version>
		<quartz.version>2.2.1</quartz.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-core</artifactId>
			<version>${spring.version}</version>
		</dependency>

		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context</artifactId>
			<version>${spring.version}</version>
		</dependency>

		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context-support</artifactId>
			<version>${spring.version}</version>
		</dependency>

		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-tx</artifactId>
			<version>${spring.version}</version>
		</dependency>

		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-web</artifactId>
			<version>${spring.version}</version>
		</dependency>

		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-webmvc</artifactId>
			<version>${spring.version}</version>
		</dependency>

		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-jdbc</artifactId>
			<version>${spring.version}</version>
		</dependency>

		<dependency>
			<groupId>log4j</groupId>
			<artifactId>log4j</artifactId>
			<version>${log4j.version}</version>
		</dependency>

		<dependency>
			<groupId>org.quartz-scheduler</groupId>
			<artifactId>quartz</artifactId>
			<version>${quartz.version}</version>
		</dependency>
		
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>4.11</version>
			<scope>test</scope>
		</dependency>

		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-test</artifactId>
			<version>3.2.3.RELEASE</version>
			<scope>test</scope>
		</dependency>

	</dependencies>

	<build />
</project>


2、新建一个简单Job(本例演示继承QuartzJobBean),其简单实现如下
public class QueryJob extends QuartzJobBean{
	
	Logger log = Logger.getLogger(getClass());
	
	public void query(){
		log.info(" log "+new Date());
	}

	@Override
	protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
		query();
	}
}


3、增加spring配置,同时增加log4j日志
spring配置文件applicationContext.xml如下
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
	xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xmlns:context="http://www.springframework.org/schema/context" xmlns:tx="http://www.springframework.org/schema/tx"
	xmlns:util="http://www.springframework.org/schema/util"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd  
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
        http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd">


	<bean id="jobDetail" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
		<property name="jobClass" value="com.qerooy.job.QueryJob"></property>
		<property name="durability" value="true" />
		
	</bean>
	
	<bean id="cronTriggerBean" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail" ref="jobDetail"></property>
        <property name="cronExpression" value="* * * * * ?"></property>
    </bean>

    <bean id="trigger" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
                <ref bean="cronTriggerBean"/>
            </list>
        </property>
    </bean>  
    

</beans>


log4j简单配置日志log4j.properties文件如下
log4j.rootLogger=INFO,Console
log4j.appender.Console=org.apache.log4j.ConsoleAppender
log4j.appender.Console.layout=org.apache.log4j.PatternLayout
log4j.appender.Console.layout.ConversionPattern=%-5r [%-17t] %-5p %c %x - %m%n


4、最后编写一个junit测试类,观察job运行情况
package com.qerooy;

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration({"classpath*:*applicationContext.xml"})
public class SchedulerTest {
	
	@Test
	public void test() throws Exception{
		Thread.sleep(20*1000);
	}
	
}
分享到:
评论
1 楼 atgoingguoat 2015-08-11  
----貌似跑的有问题。
一下子就停了。

2015-08-11 11:46:20.512 [main] [INFO ]  org.quartz.core.QuartzScheduler {QuartzScheduler.java:2311} - JobFactory set to: org.springframework.scheduling.quartz.AdaptableJobFactory@5bbee265
2015-08-11 11:46:20.530 [main] [INFO ]  org.springframework.context.support.DefaultLifecycleProcessor {DefaultLifecycleProcessor.java:341} - Starting beans in phase 2147483647
2015-08-11 11:46:20.531 [main] [INFO ]  org.springframework.scheduling.quartz.SchedulerFactoryBean {SchedulerFactoryBean.java:649} - Starting Quartz Scheduler now
2015-08-11 11:46:20.531 [main] [INFO ]  org.quartz.core.QuartzScheduler {QuartzScheduler.java:575} - Scheduler trigger_$_NON_CLUSTERED started.
2015-08-11 11:46:20.532 [trigger_QuartzSchedulerThread] [DEBUG]  org.quartz.core.QuartzSchedulerThread {QuartzSchedulerThread.java:276} - batch acquisition of 1 triggers
2015-08-11 11:46:20.535 [trigger_Worker-1] [DEBUG]  org.quartz.core.JobRunShell {JobRunShell.java:201} - Calling execute on job DEFAULT.jobDetail
2015-08-11 11:46:20.535 [trigger_QuartzSchedulerThread] [DEBUG]  org.quartz.core.QuartzSchedulerThread {QuartzSchedulerThread.java:276} - batch acquisition of 1 triggers
2015-08-11 11:46:20.535 [trigger_Worker-1] [INFO ]  com.viathink.sys.job.QueryJob {QueryJob.java:17} -  ### bzq log Tue Aug 11 11:46:20 CST 2015
2015-08-11 11:46:21.508 [Timer-0] [DEBUG]  org.quartz.utils.UpdateChecker {UpdateChecker.java:54} - Checking for available updated version of Quartz...
2015-08-11 11:46:25.562 [main] [INFO ]  org.springframework.test.context.transaction.TransactionalTestExecutionListener {TransactionalTestExecutionListener.java:276} - Began transaction (1) for test context [DefaultTestContext@79d2af80 testClass = SysDictionaryDaoImplTest, testInstance = com.viathink.sys.dao.impl.SysDictionaryDaoImplTest@77003afb, testMethod = testSelectById@SysDictionaryDaoImplTest, testException = [null], mergedContextConfiguration = [MergedContextConfiguration@302071c6 testClass = SysDictionaryDaoImplTest, locations = '{classpath:/spring-config.xml}', classes = '{}', contextInitializerClasses = '[]', activeProfiles = '{}', contextLoader = 'org.springframework.test.context.support.DelegatingSmartContextLoader', parent = [null]]]; transaction manager [org.springframework.jdbc.datasource.DataSourceTransactionManager@220d96d9]; rollback [true]
2015-08-11 11:46:25.631 [main] [INFO ]  org.springframework.test.context.transaction.TransactionalTestExecutionListener {TransactionalTestExecutionListener.java:298} - Rolled back transaction after test execution for test context [DefaultTestContext@79d2af80 testClass = SysDictionaryDaoImplTest, testInstance = com.viathink.sys.dao.impl.SysDictionaryDaoImplTest@77003afb, testMethod = testSelectById@SysDictionaryDaoImplTest, testException = [null], mergedContextConfiguration = [MergedContextConfiguration@302071c6 testClass = SysDictionaryDaoImplTest, locations = '{classpath:/spring-config.xml}', classes = '{}', contextInitializerClasses = '[]', activeProfiles = '{}', contextLoader = 'org.springframework.test.context.support.DelegatingSmartContextLoader', parent = [null]]]
2015-08-11 11:46:25.641 [Thread-4] [INFO ]  org.springframework.context.support.GenericApplicationContext {AbstractApplicationContext.java:873} - Closing org.springframework.context.support.GenericApplicationContext@553fd068: startup date [Tue Aug 11 11:46:19 CST 2015]; root of context hierarchy
2015-08-11 11:46:25.643 [Thread-4] [INFO ]  org.springframework.context.support.DefaultLifecycleProcessor {DefaultLifecycleProcessor.java:356} - Stopping beans in phase 2147483647
2015-08-11 11:46:25.645 [Thread-4] [INFO ]  org.quartz.core.QuartzScheduler {QuartzScheduler.java:613} - Scheduler trigger_$_NON_CLUSTERED paused.
2015-08-11 11:46:25.645 [Thread-4] [INFO ]  org.springframework.scheduling.quartz.SchedulerFactoryBean {SchedulerFactoryBean.java:767} - Shutting down Quartz Scheduler
2015-08-11 11:46:25.646 [Thread-4] [INFO ]  org.quartz.core.QuartzScheduler {QuartzScheduler.java:694} - Scheduler trigger_$_NON_CLUSTERED shutting down.
2015-08-11 11:46:25.646 [Thread-4] [INFO ]  org.quartz.core.QuartzScheduler {QuartzScheduler.java:613} - Scheduler trigger_$_NON_CLUSTERED paused.
2015-08-11 11:46:25.646 [Thread-4] [DEBUG]  org.quartz.simpl.SimpleThreadPool {SimpleThreadPool.java:328} - Shutting down threadpool...
2015-08-11 11:46:25.647 [Thread-4] [DEBUG]  org.quartz.simpl.SimpleThreadPool {SimpleThreadPool.java:395} - Shutdown of threadpool complete.
2015-08-11 11:46:25.647 [Thread-4] [INFO ]  org.quartz.core.QuartzScheduler {QuartzScheduler.java:771} - Scheduler trigger_$_NON_CLUSTERED shutdown complete.
2015-08-11 11:46:25.649 [Thread-4] [WARN ]  org.springframework.beans.factory.support.DisposableBeanAdapter {DisposableBeanAdapter.java:360} - Invocation of destroy method 'close' failed on bean with name 'sqlSession': java.lang.UnsupportedOperationException: Manual close is not allowed over a Spring managed SqlSession

相关推荐

Global site tag (gtag.js) - Google Analytics