Spring中實現(xiàn)定時調(diào)度的幾種方法
1,內(nèi)容簡介
所謂的定時調(diào)度,是指在無人值守的時候系統(tǒng)可以在某一時刻執(zhí)行某些特定的功能采用的一種機制,對于傳統(tǒng)的開發(fā)而言,定時調(diào)度的操作分為兩種形式:
定時觸發(fā):到某一時間點上執(zhí)行某些處理操作;
間隔觸發(fā):每隔幾秒后進行某些操作的自動處理。
所有的處理都依賴于計算機系統(tǒng)底層的時鐘發(fā)生器,在java最初的實現(xiàn)過程里面,真對于定時處理專門提供有兩個類:Timer,TimerTask兩個類,其中TimerTask主要是定義任務(wù)的執(zhí)行,相當于啟動一個線程去執(zhí)行某些任務(wù)。
public class MyTask extends TimerTask{ @Override public void run() {//定義要執(zhí)行的任務(wù) // TODO Auto-generated method stub String currentTime=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(new Date()); System.out.println(currentTime); } } public class MyTaskTest { public static void main(String[] args) { Timer timer=new Timer(); timer.schedule(new MyTask(), 1000);//啟動任務(wù),延遲1秒后執(zhí)行。 } }
但是,如果要求要在每年的某月某時某分某秒執(zhí)行某個任務(wù),使用Timer和TimerTask就無能為力了。在項目開發(fā)中往往會有兩種定時控制的選擇:
quartz組件:企業(yè)及定時調(diào)度組件,需要單獨配置;
SpringTask:輕量級組件,配置簡單,可以利用Annotation實現(xiàn)配置處理。
2,Quartz定義定時調(diào)度
使用Quartz組件,我們需要導入quartz的開發(fā)包,在pom.xml中添加quartz的開發(fā)包。
<dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.2.3</version> </dependency>
引入包后,就可以進行定時調(diào)度的開發(fā)了。
有兩種實現(xiàn)模式:
去繼承QuartzJobBean父類;
直接利用配置就可以實現(xiàn)方法的調(diào)度控制。
1,繼承一個父類實現(xiàn)任務(wù)的處理。
public class MyTask2 extends QuartzJobBean{ @Override protected void executeInternal(JobExecutionContext context) throws JobExecutionException { // TODO Auto-generated method stub String currentTime=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(new Date()); System.out.println(currentTime); System.out.println("具體的任務(wù)實現(xiàn)?。?!"); } }
所有的定時調(diào)度的啟用都要在Spring的控制文件中完成,即,不需要去寫一個明確的類來進行定時任務(wù)啟用。
2,在applicationContext.xml文件中增加定時調(diào)度的配置,通過定時調(diào)度工廠類實現(xiàn)。
<bean id="taskFactory" class="org.springframework.scheduling.quartz.JobDetailFactoryBean"> <property name="jobClass" value="cn.wnh.timerSask.MyTask1" /> <property name="jobDataMap"> <map> <entry key="timeout" value="0" /> </map> </property> </bean>
隨后配置任務(wù)的觸發(fā)作業(yè),對于作業(yè)的配置有兩類:
使用間隔觸發(fā):若干時間之后重復執(zhí)行;
工廠類:org.springframework.scheduling.quartz.SimpleTriggerFactoryBean
<bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean"> <!-- 定義間隔觸發(fā)的執(zhí)行程序類 --> <property name="jobDetail" ref="taskFactory"></property> <!-- 設(shè)置定時觸發(fā)延遲時間 --> <property name="startDelay" value="0"></property> <!-- 單位是”毫秒“ --> <property name="repeatInterval" value="2000"></property> </bean>
設(shè)置間隔觸發(fā)調(diào)度器:org.springframework.scheduling.quartz.SchedulerFactoryBean
<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="triggers"> <list> <ref bean="simpleTrigger" /> </list> </property> </bean>
3,此時所有的間隔觸發(fā)控制都交由Spring管理了,現(xiàn)在只需要啟動Spring容器即可實現(xiàn)間隔觸發(fā)任務(wù)。
使用Cron實現(xiàn)定時觸發(fā)
Quartz不僅可以實現(xiàn)間隔觸發(fā),它還可以結(jié)合Cron實現(xiàn)定時觸發(fā),這也是它最重要的功能。
一般項目中使用最多的模式:小時觸發(fā),月初觸發(fā),年初觸發(fā)。
修改之前的間隔觸發(fā)配置,使用CronTriggerFactoryBean實現(xiàn)定時觸發(fā)。
<bean id="taskFactory" class="org.springframework.scheduling.quartz.JobDetailFactoryBean"> <property name="jobClass" value="cn.wnh.timerSask.MyTask1" /> <property name="jobDataMap"> <map> <entry key="timeout" value="0" /> </map> </property> </bean> <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"> <property name="jobDetail" ref="taskFactory" /> <!-- cron表達式,描述每分鐘觸發(fā)一次 --> <property name="cronExpression" value="0 * * * * ?" /> </bean> <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="triggers"> <list> <ref bean="cronTrigger" /> </list> </property> </bean>
啟動Spring容器即可實現(xiàn)。
2,不繼承任何類實現(xiàn)定時調(diào)度
在項目開發(fā)中,繼承直接會導致單繼承的局限控制,所以在這種情況下Spring中提供了一種可以不繼承任何類即可實現(xiàn)定時操作的任務(wù)處理。
定義一個任務(wù)執(zhí)行類,不繼承任何類。
public class MyTask2 { public void taskSelf(){ String task=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS").format(new java.util.Date()); System.out.println(task); System.out.println("執(zhí)行具體任務(wù)操作"); } }
在applicationContext.xml在配置工廠類:org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean
<bean id="taskFactory2" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <property name="targetObject"> <bean class="cn.wnh.timerSask.MyTask2" /> </property> <!--配置要執(zhí)行的方法 --> <property name="targetMethod" value="taskSelf" /> </bean>
隨后在任務(wù)調(diào)度配置上配置新的程序類
<bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"> <property name="jobDetail" ref="taskFactory2" /> <!-- cron表達式,描述每分鐘觸發(fā)一次 --> <property name="cronExpression" value="* * * * * ?" /> </bean>
啟動容器即可實現(xiàn)定時調(diào)度。
這種模式?jīng)]有類的繼承依賴,處理會更加靈活。
Spring Task實現(xiàn)定時調(diào)度
在Spring中自己有對定時調(diào)度的支持,使用起來感覺比Quartz還要好用。
它有兩種實現(xiàn)方式,1,在applicationContext.xml中配置實現(xiàn);2,使用Annotation實現(xiàn)。
不過使用什么模式,必須先有一個任務(wù)處理類。
定義任務(wù)處理類。
這里直接使用之前的MyTask2類,不再重復寫。
修改applicationContext.xml文件:
需要追加task處理的命名空間定義:
<beans xmlns:task="http://www.springframework.org/schema/task" http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.1.xsd >
1配置task操作的配置,實現(xiàn)間隔觸發(fā)。
<bean id="myTask" class="cn.wnh.timerSask.MyTask2" /> <task:scheduled-tasks> <task:scheduled ref="myTask" method="taskSelf" fixed-rate="2000" /> </task:scheduled-tasks>
使用cron實現(xiàn)定時觸發(fā)
<bean id="myTask" class="cn.wnh.timerSask.MyTask2" /> <task:scheduled-tasks> <task:scheduled ref="myTask" method="taskSelf" cron="* * * * * ?" /> </task:scheduled-tasks>
可見,SpringTask實現(xiàn)起來更加簡單。
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
- Java中Spring使用Quartz任務(wù)調(diào)度定時器
- spring利用squertz實現(xiàn)定時任務(wù)
- Spring整合Quartz實現(xiàn)動態(tài)定時器的示例代碼
- spring task 定時任務(wù)實現(xiàn)示例
- Spring整合TimerTask實現(xiàn)定時任務(wù)調(diào)度
- Spring整合Quartz實現(xiàn)定時任務(wù)調(diào)度的方法
- 最流行的java后臺框架spring quartz定時任務(wù)
- JAVA中 Spring定時器的兩種實現(xiàn)方式
- java中 spring 定時任務(wù) 實現(xiàn)代碼
相關(guān)文章
Spring?+?ECharts實現(xiàn)數(shù)據(jù)可視化的案例詳解
Apache?ECharts是一個基于?JavaScript?的開源可視化圖表庫,在網(wǎng)頁上實現(xiàn)數(shù)據(jù)的可視化,非常好用,本文將通過一個簡單的demo來給大家介紹一下Spring?+?ECharts如何數(shù)據(jù)可視化,需要的朋友可以參考下2023-07-07javaweb啟動時啟動socket服務(wù)端代碼實現(xiàn)
這篇文章主要介紹了javaweb啟動時啟動socket服務(wù)端代碼實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-11-11Mybatis攔截器實現(xiàn)數(shù)據(jù)分表
當數(shù)據(jù)量比較多時,放在一個表中的時候會影響查詢效率,本文主要介紹了Mybatis攔截器實現(xiàn)數(shù)據(jù)分表,文中通過示例代碼介紹的非常詳細,需要的朋友們下面隨著小編來一起學習學習吧2024-01-01RocketMQ?broker?消息投遞流程處理PULL_MESSAGE請求解析
這篇文章主要為大家介紹了RocketMQ?broker?消息投遞流程處理PULL_MESSAGE請求源碼解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-04-04