Spring與Quartz的整合實現定時任務調度

• Java Web

1. <?xml version="1.0" encoding="UTF-8"?>
2. <project xmlns="http://maven.apache.org/POM/4.0.0"
3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5. <modelVersion>4.0.0</modelVersion>
7. <groupId>QtzTest</groupId>
8. <artifactId>QtzTest</artifactId>
9. <version>1.0</version>
11. <properties>
12. <springframework.version>3.0.5.RELEASE</springframework.version>
13. </properties>
15. <dependencies>
16. <dependency>
17. <groupId>org.springframework</groupId>
18. <artifactId>spring-context</artifactId>
19. <version>${springframework.version}</version>
20. </dependency>
22. <dependency>
23. <groupId>org.springframework</groupId>
24. <artifactId>spring-context-support</artifactId>
25. <version>${springframework.version}</version>
26. </dependency>
28. <dependency>
29. <groupId>org.springframework</groupId>
30. <artifactId>spring-tx</artifactId>
31. <version>${springframework.version}</version>
32. </dependency>
34. <dependency>
35. <groupId>org.springframework</groupId>
36. <artifactId>spring-web</artifactId>
37. <version>${springframework.version}</version>
38. </dependency>
40. <dependency>
41. <groupId>org.quartz-scheduler</groupId>
42. <artifactId>quartz</artifactId>
43. <version>1.8.5</version>
44. </dependency>
45. </dependencies>
47. <build>
48. <finalName>${project.artifactId}</finalName>
49. <plugins>
50. <plugin>
51. <groupId>org.mortbay.jetty</groupId>
52. <artifactId>jetty-maven-plugin</artifactId>
53. <version>7.5.4.v20111024</version>
54. <configuration>
55. <scanIntervalSeconds>10</scanIntervalSeconds>
56. <webApp>
57. <contextPath>/${project.artifactId}</contextPath>
58. </webApp>
59. </configuration>
60. </plugin>
61. </plugins>
62. </build>
63. </project>

1. package com.ncs.hj;
3. import org.quartz.JobExecutionContext;
4. import org.quartz.JobExecutionException;
5. import org.springframework.scheduling.quartz.QuartzJobBean;
7. public class SpringQtz extends QuartzJobBean{
8. private static int counter = 0;
9. protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
10. System.out.println();
11. long ms = System.currentTimeMillis();
12. System.out.println("\t\t" + new Date(ms));
13. System.out.println(ms);
14. System.out.println("(" + counter++ + ")");
15. String s = (String) context.getMergedJobDataMap().get("service");
16. System.out.println(s);
17. System.out.println();
18. }
19. }

1. package com.ncs.hj;
3. import org.quartz.JobExecutionContext;
4. import org.quartz.JobExecutionException;
5. import org.springframework.scheduling.quartz.QuartzJobBean;
7. import java.util.Date;
9. public class SpringQtz {
10. private static int counter = 0;
11. protected void execute() {
12. long ms = System.currentTimeMillis();
13. System.out.println("\t\t" + new Date(ms));
14. System.out.println("(" + counter++ + ")");
15. }
16. }

1. <!------------ 配置調度程序quartz ，其中配置JobDetail有兩種方式-------------->
2. <!--方式一：使用JobDetailBean，任務類必須實現Job接口 -->
3. <bean id="myjob" class="org.springframework.scheduling.quartz.JobDetailBean">
4. <property name="name" value="exampleJob"></property>
5. <property name="jobClass" value="com.ncs.hj.SpringQtz"></property>
6. <property name="jobDataAsMap">
7. <map>
8. <entry key="service"><value>simple is the beat</value></entry>
9. </map>
10. ;/property>
11. </bean>
12. <!--運行時請將方式一註釋掉！ -->
13. <!-- 方式二：使用MethodInvokingJobDetailFactoryBean，任務類可以不實現Job接口，通過targetMethod指定調用方法-->
14. <!-- 定義目標bean和bean中的方法 -->
15. <bean id="SpringQtzJob" class="com.ncs.hj.SpringQtz"/>
16. <bean id="SpringQtzJobMethod" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
17. <property name="targetObject">
18. <ref bean="SpringQtzJob"/>
19. </property>
20. <property name="targetMethod"> <!-- 要執行的方法名稱 -->
21. <value>execute</value>
22. </property>
23. </bean>
25. <!-- ======================== 調度觸發器 ======================== -->
26. <bean id="CronTriggerBean" class="org.springframework.scheduling.quartz.CronTriggerBean">
27. <property name="jobDetail" ref="SpringQtzJobMethod"></property>
28. <property name="cronExpression" value="0/5 * * * * ?"></property>
29. </bean>
31. <!-- ======================== 調度工廠 ======================== -->
32. <bean id="SpringJobSchedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
33. <property name="triggers">
34. <list>
35. <ref bean="CronTriggerBean"/>
36. </list>
37. </property>
38. </bean>

1. <?xml version="1.0" encoding="UTF-8"?>
2. <web-app xmlns="http://java.sun.com/xml/ns/javaee"
3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4. xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
5. http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"
6. version="2.5">
7. <welcome-file-list>
8. <welcome-file>index.html</welcome-file>
9. </welcome-file-list>
11. <context-param>
12. <param-name>contextConfigLocation</param-name>
13. <param-value>/WEB-INF/spring-config.xml</param-value>
14. </context-param>
16. <listener>
17. <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
18. </listener>
19. </web-app>

Spring與Quartz的整合實現定時任務調度