1. 程式人生 > >spring quartz定時器--SimpleTriggerFactoryBean與CronTriggerFactoryBean

spring quartz定時器--SimpleTriggerFactoryBean與CronTriggerFactoryBean

需求:
1.執行後,將mysql的資料同步到redis和(Spring建立)記憶體中的map
2.定時器每秒將redis修改的資料同步到map和mysql

一開始用監聽器(ContextLoaderListener)來調同步方法完成需求1,
由於監聽器無法使用註解,比較麻煩,啟動過程中也有各種問題,於是改為使用兩個定時器。

但是這兩個定時器存在著嚴格的先後順序,不然map會報空指標,需要設定其中一個定時器的啟動時間。

CronTriggerFactoryBean:基於時間刻度(可以設定具體時間)

SimpleTriggerFactoryBean:基於排程間隔時間
(但是延遲啟動的功能,好像只有SimpleTriggerFactoryBean具備)

定時器有三個要素:
1. job:具體需要定時執行的方法
2. trigger:觸發點(與job一一對應)
3. schedule:排程器(可以排程多個trigger,經檢驗可以包括不同類的trigger)

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns="http://www.springframework.org/schema/beans"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd"
>
<!--排程器工廠--> <bean id="testScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="triggers"> <list> <!--兩個定時器--> <!--從mysql同步到redis和memory--> <ref
bean="initSyncJob">
</ref> <!--從redis同步到memeory到mysql --> <ref bean="triggerSyncJob"></ref> </list> </property> <property name="autoStartup" value="true"></property> </bean>

第一個定時器

<!--觸發點-->

    <bean id="initSyncJob"
          class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">
        <property name="jobDetail" ref="initSyncCheck">
        </property>
        <property name="repeatInterval">
            <!-- 2秒一次-->
            <value>2000</value>
        </property>
        <property name="startDelay"><value>0</value></property>
        <!--重複次數:0-->
        <!--去掉的話按結束時間算
        -->
        <property name="repeatCount">
            <value>0</value>
        </property>
    </bean>
<!--定時器具體作業-->

    <bean id="initSyncCheck"          class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject" ref="initJob">
        </property>
        <property name="targetMethod" value="job"></property>

        <property name="concurrent" value="false"/>
    </bean>
    <bean id="initJob" class="com.test.InitTask"/>
</beans>

第二個定時器

<!--觸發點-->

    <bean id="triggerSyncJob" class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">
        <property name="jobDetail" ref="syncCheck" />

        <property name="startDelay" value="5000" /><!-- 排程工廠例項化後,經過5秒開始執行排程 -->

        <property name="repeatInterval" value="2000" /><!-- 每2秒排程一次 -->

    </bean> 
<!--定時器具體作業-->

<bean id="syncCheck"          class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject" ref="syncJob">
        </property>
        <property name="targetMethod" value="job"></property>

        <property name="concurrent" value="false"/>
    </bean>
    <bean id="syncJob" class="com.test.SyncTask"/>

如果使用CronTriggerFactoryBean作為觸發點

<!--觸發點-->

    <bean id="initSyncJob"
          class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail" ref="initSyncCheck">
        </property>
        <property name="cronExpression">
            <!--每隔一分鐘執行一次 -->
            <!--<value>0 */1 * * * ?</value>-->
            <!--每隔1秒執行一次 -->
            <value>*/1 * * * * ?</value>
        </property>
    </bean>

具體的cron表達方法還是百度吧,記也記不清。