Spring Quartz Scheduler示例
在本教程中,我们将看到如何使用Spring Quartz调度或者如何Spring石英集成调度作业。
我们已经看到了如何使用计时器和timertask安排作业。
有两种方法,通过它可以指定石英工作。
MethodInvokingJobdetailFactoryBeanJobdetailFactoryBean.
JobDetailFactoryBean用于复杂任务。
我们需要创建扩展QuartzjobBean的作业类。
项目结构:
使用JobDetailFactoryBean创建Spring Quartz Scheduler示例的步骤是:
步骤1:
使用名称"springquartzschedulerexampleusingquartzjobbean"创建简单的Java Maven项目。
步骤2:更新POM.xml以放置Spring Core和Spring Quartz依赖项。
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.igi.theitroad</groupId> <artifactId>SpringQuartzSchedulerExample</artifactId> <version>0.0.1-SNAPSHOT</version> <name>SpringQuartzSchedulerExample</name> <description>It provide spring quartz scheduler example using MethodInvokingJobDetailFactoryBean</description> <dependencies> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>3.8.1</version> <scope>test</scope> </dependency> <dependency> <groupId>javax.servlet</groupId> <artifactId>javax.servlet-api</artifactId> <version>3.1.0</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</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> <!-- Quartz framework dependencies --> <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.2.0</version> </dependency> </dependencies> <build> <finalName>SpringQuartzSchedulerExample</finalName> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>3.1</version> <configuration> <source>${jdk.version}</source> <target>${jdk.version}</target> </configuration> </plugin> </plugins> </build> <properties> <spring.version>4.2.1.RELEASE</spring.version> <jdk.version>1.7</jdk.version> </properties> </project>
第3步:
中创建一个包com.igi.theitroad.spring中的src/main/java的所谓的"SendEmailTask.java"级。
它是我们想要在特定时间或者时间间隔重复执行的代码的类。
package com.igi.theitroad.spring; import java.util.Calendar; public class SendEmailTask { public void sendEmail() { //You Jan want to put some condition for sending email //Actual email send logic System.out.println("Sending email at "+ Calendar.getInstance().getTime()); } }
第4步:在Package com.igi.theitroad.spring中创建名为"nobscheduler.java"的类名为"nobscheduler.java"..spring ..此类将扩展Quartzjobbean和ExecuteInternal方法将在触发中指定的特定时间调用。
package com.igi.theitroad.spring; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.springframework.scheduling.quartz.QuartzJobBean; public class JobScheduler extends QuartzJobBean { SendEmailTask sendEmailTask; public void setSendEmailTask(SendEmailTask sendEmailTask) { this.sendEmailTask = sendEmailTask; } @Override protected void executeInternal(JobExecutionContext arg0) throws JobExecutionException { sendEmailTask.sendEmail(); } }
步骤5:在此步骤中,我们需要在SRC/Main/Resources中创建"Quartz-config.xml"。
Quartz-config.xml将拥有计划任务所需的所有配置。
我们需要在此处放入四个条目
- 需要指定任务(sendemailtask)。
- 需要指定JobDetailFactoryBean
- 需要为触发器进行条目,该触发器指定时间间隔并启动延迟时间。
- 需要指定schedulefactorybean以将触发器和作业绑定到一起。
石英-config.xml中
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd"> <!--Specify Task bean --> <bean id="sendEmailTask" class="com.igi.theitroad.spring.SendEmailTask" <!-- Spring Quartz --> <bean name="emailJob" class="org.springframework.scheduling.quartz.JobDetailFactoryBean"> <property name="jobClass" value="com.igi.theitroad.spring.JobScheduler" <property name="jobDataAsMap"> <map> <entry key="sendEmailTask" value-ref="sendEmailTask" </map> </property> <property name="durability" value="true" </bean> <!-- simple trigger specify repeat interval and delay time --> <bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean"> <property name="jobDetail" ref="emailJob" <property name="repeatInterval" value="10000" <property name="startDelay" value="1000" </bean> <!-- scheduler factory bean to bind,the executing code and time intervals together --> <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="jobDetails"> <list> <ref bean="emailJob" </list> </property> <property name="triggers"> <list> <ref bean="simpleTrigger" </list> </property> </bean> </beans>
步骤6:最后我们将创建主类来执行此功能。
我们将创建ClassPathxMlApplicationContext的对象加载Quartz-config.xml在package com.igi.theitroad.spring中的src/main/java中创建类名名称application.java
package com.igi.theitroad.spring; /** * @author igi Mandliya * */ import org.springframework.context.support.ClassPathXmlApplicationContext; public class Application { public static void main(String[] args) throws Exception { new ClassPathXmlApplicationContext("quartz-config.xml"); } }
第7步:在上面的程序运行时,我们将获取以下输出。
Jan 24, 2015 1:09:13 AM org.springframework.context.support.ClassPathXmlApplicationContext prepareRefresh INFO: Refreshing org.springframework.context.support.ClassPathXmlApplicationContext@1441e2aa: startup date [Sun Jan 24 01:09:13 IST 2015]; root of context hierarchy Jan 24, 2015 1:09:13 AM org.springframework.beans.factory.xml.XmlBeanDefinitionReader loadBeanDefinitions INFO: Loading XML bean definitions from class path resource [quartz-config.xml] SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder". SLF4J: Defaulting to no-operation (NOP) logger implementation SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details. Jan 24, 2015 1:09:14 AM org.springframework.context.support.DefaultLifecycleProcessor start INFO: Starting beans in phase 2147483647 Jan 24, 2015 1:09:14 AM org.springframework.scheduling.quartz.SchedulerFactoryBean startScheduler INFO: Starting Quartz Scheduler now Sending email at Sun Jan 24 01:09:15 IST 2015 Sending email at Sun Jan 24 01:09:25 IST 2015 Sending email at Sun Jan 24 01:09:35 IST 2015 Sending email at Sun Jan 24 01:09:45 IST 2015 Sending email at Sun Jan 24 01:09:55 IST 2015