使用spring整合quartz实现—定时器（maven项目做演示）
不基于特定的基类的方法
一，开发环境以及依赖的jar包
spring 4.2.6.release
maven 3.3.9
jdk 1.7
idea 15.04
二，不可少的jar依赖（添加在maven项目里面的pom.xml文件里面）
|
1
2
3
4
5
6
7
8
9
10
|
<dependency><groupid>org.springframework</groupid><artifactid>spring-context-support</artifactid><version>4.2.6.release</version></dependency><dependency><groupid>org.quartz-scheduler</groupid><artifactid>quartz</artifactid><version>2.2.1</version></dependency> |
三，实现定时器时使用到的文件：
planworkexcute.java --定时器执行的类
spring-plan.xml --配置定时器信息的xml
四，实现定时器步骤：
1，创建 planworkexcute.java文件 ，在 cc.royao.plantask 包下。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
package cc.royao.plantask;import java.text.simpledateformat;import java.util.date;import java.util.hashmap;import java.util.list;import java.util.map;import java.util.concurrent.executorservice;import java.util.concurrent.executors;import org.apache.log4j.logger;//可以删除import org.springframework.beans.factory.annotation.autowired;public class planworkexecute { logger logger = logger.getlogger(this.getclass());//logger打印日志，可以去掉 /** * 定时器执行的方法 */ public synchronized void withdrawnoaudittask() { simpledateformat outformat = new simpledateformat("yyyy年mm月dd日 hh:mm:ss"); system.out.println("开始提现免审核任务-------------------------------" + outformat.format(new date())); logger.info("开始提现免审核任务-------------------------------"); system.out.println("结束提现免审核任务-------------------------------" + outformat.format(new date())); logger.info("结束提现免审核任务-------------------------------"); }} |
2，创建spring-plan.xml 配置文件 注：创建一个定时器的配置文件就行，如果需要多个定时器，直接在spring-plan.xml添加 bean和定义定时器类的方法就行，不需要创建多个xml，
· 关于那个定时器多久执行的 cron表达式 可以参考：http://www.zzvips.com/article/94843.html
·有在线生成表达式的网址：http://cron.qqe2.com/
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
|
<?xml version="1.0" encoding="utf-8"?><beans xmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/xmlschema-instance"xsi:schemalocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd"default-lazy-init="false"><bean id="job1" class="cc.royao.plantask.planworkexecute" /><!-- 修改为你的定时类的路径 --><!-- 可以创建多个定时bean --><bean id="jobdetail_1" class="org.springframework.scheduling.quartz.methodinvokingjobdetailfactorybean"> <property name="targetobject"> <ref bean="job1" /> </property> <property name="targetmethod"> <value>withdrawnoaudittask</value><!-- 定时器类的方法名--> </property></bean><bean id="crontrigger_1" class="org.springframework.scheduling.quartz.crontriggerfactorybean"> <property name="jobdetail"> <ref bean="jobdetail_1" /> <!-- 这里对应上面bean--> </property> <property name="cronexpression"> <value>0/2 * * * * ?</value><!-- 0 10 0 * * ? 每天0:10执行 --> </property></bean><bean class="org.springframework.scheduling.quartz.schedulerfactorybean"> <property name="triggers"> <list> <ref local="crontrigger_1" /> <!-- 每加一个定时器这里也要加--> </list> </property></bean></beans> |
3，需要在 applicationcontext.xml 中引入 spring-plan.xml 以下代码重点在最下
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
<?xml version="1.0" encoding="utf-8"?><beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/xmlschema-instance" xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:cache="http://www.springframework.org/schema/cache" xsi:schemalocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-3.2.xsd" default-lazy-init="true"> <!-- 加载系统properties文件配置 --> <bean id="propertyconfigurer" class="org.springframework.beans.factory.config.propertyplaceholderconfigurer"> <property name="locations"> <list> <value>web-inf/jdbc.properties</value> <!-- <value>web-inf/sms.properties</value> --> </list> </property> </bean> <bean id="datasource" class="org.apache.commons.dbcp.basicdatasource"> <property name="driverclassname"> <value>${jdbc.driverclass}</value> </property> <!--<property name="defaultautocommit" value="false"/>--> <property name="url"> <value>jdbc:mysql://192.168.14.239:3306/test?useunicode=true&characterencoding=utf-8</value> </property> <property name="username"> <value>${jdbc.username}</value> </property> <property name="password"> <value>${jdbc.password}</value> </property> <property name="maxactive"> <value>20</value> </property> <property name="maxidle"> <value>60</value> </property> <property name="maxwait"> <value>20000</value> <!-- 0 --> </property> <property name="removeabandoned"> <value>true</value> </property> <property name="removeabandonedtimeout"> <value>6000000</value> <!-- 180 --> </property> <!-- add --> <property name="validationquery" value="select 1"></property> <property name="testwhileidle" value="true"></property> <property name="testonborrow" value="true"></property> <property name="timebetweenevictionrunsmillis" value="3600000"></property> <property name="numtestsperevictionrun" value="50"></property> <property name="minevictableidletimemillis" value="120000"></property> <!-- add --> </bean> <!-- sqlsessionfactory --> <bean id="sqlsessionfactory" class="org.mybatis.spring.sqlsessionfactorybean"> <property name="datasource" ref="datasource"/> </bean> <bean id="threadpooltaskexecutor" class="org.springframework.scheduling.concurrent.threadpooltaskexecutor"> <property name="corepoolsize" value="1"/> <property name="maxpoolsize" value="10"/> <property name="keepaliveseconds" value="300"/> <property name="queuecapacity" value="50"/> <property name="waitfortaskstocompleteonshutdown" value="true"/> </bean> <bean id="transactionmanager" class="org.springframework.jdbc.datasource.datasourcetransactionmanager"> <property name="datasource" ref="datasource"></property> </bean> <!--<!– 自动扫描service实现 –>--> <!--<context:component-scan base-package="com.royao">--> <!--<context:include-filter type="regex"--> <!--expression="com.royao.services.*" />--> <!--</context:component-scan>--> <aop:config proxy-target-class="true"> <aop:pointcut id="serviceoperation" expression="execution(* cc.royao.mana.auth.service.*.impl.*serviceimpl.*(..))"/> <aop:advisor pointcut-ref="serviceoperation" advice-ref="txadvice"/> </aop:config> <!-- 配置事务通知 --> <tx:advice id="txadvice" transaction-manager="transactionmanager"> <tx:attributes> <tx:method name="*" rollback-for="exception"/> </tx:attributes> </tx:advice> <tx:advice id="transactionmanageradivice" transaction-manager="transactionmanager"> <tx:attributes> <tx:method name="*insert*" propagation="required"/> <tx:method name="*add*" propagation="required"/> <tx:method name="*update*" propagation="required"/> <tx:method name="*update*" propagation="required"/> <tx:method name="*del*" propagation="required"/> <tx:method name="*create*" propagation="required"/> <tx:method name="doapproved" propagation="required"/> <tx:method name="batchdelfm" propagation="required"/> <tx:method name="edittemplate" propagation="required"/> <tx:method name="dummydelete" propagation="required"/> <tx:method name="batchdeluser" propagation="required"/> <!--<tx:method name="*" propagation="required"/>--> </tx:attributes> </tx:advice> <bean class="org.mybatis.spring.mapper.mapperscannerconfigurer"> <property name="basepackage"> <value>cc.royao.mana.auth.mapper.*</value> </property> <property name="sqlsessionfactorybeanname" value="sqlsessionfactory"/> </bean> <import resource="application-servlet.xml"/> <!-- 重点在这里 ，我把整个xml文件内容复制出来，怕你们不知道插入在哪里--> <import resource="spring-plan.xml"/></beans> |
总结
以上所述是小编给大家介绍的使用spring整合quartz实现—定时器功能，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对服务器之家网站的支持！
原文链接：https://www.cnblogs.com/thirteen-zxh/archive/2018/04/25/8943765.html
