java調度任務在項目中的應用

前言

任務調度是指基于給定時間點，給定時間間隔或者給定執行次數自動執行任務。項目中有很獨特的應用的場景，比如每天凌晨同步數據，定時操作業務等等。

• Timer
• scheduler
• quartz

1 Timer

java.util.Timer，可以實現一些簡單的定時任務，使用 Timer 實現任務調度的核心類是 Timer 和 TimerTask。其中 Timer 負責設定 TimerTask 的起始與間隔執行時間。使用者只需要創建一個 TimerTask 的繼承類，實現自己的 run 方法，然后將其丟給 Timer 去執行即可。
Timer 將接收到的任務丟到自己的 TaskList 中，TaskList 按照 Task 的最初執行時間進行排序。TimerThread 在創建 Timer 時會啟動成為一個守護線程。這個線程會輪詢所有任務，找到一個最近要執行的任務，然后休眠，當到達最近要執行任務的開始時間點，TimerThread 被喚醒并執行該任務。之后 TimerThread 更新最近一個要執行的任務，繼續休眠如下。
Timer 的優點在于簡單易用，但由于所有任務都是由同一個線程來調度，因此所有任務都是串行執行的，同一時間只能有一個任務在執行，前一個任務的延遲或異常都將會影響到之后的任務：

public class TimerTest extends TimerTask {
    private String jobName = "";

    public TimerTest(String jobName) {
        super();
        this.jobName = jobName;
    }

    @Override
    public void run() {
        System.out.println("execute " + jobName);
    }

    public static void main(String[] args) {
        Timer timer = new Timer();
        long delay1 = 1 * 1000;
        long period1 = 1000;
        // 從現在開始 1 秒鐘之后，每隔 1 秒鐘執行一次 job1
        timer.schedule(new TimerTest("job1"), delay1, period1);
        long delay2 = 2 * 1000;
        long period2 = 2000;
        // 從現在開始 2 秒鐘之后，每隔 2 秒鐘執行一次 job2
        timer.schedule(new TimerTest("job2"), delay2, period2);

    }
}

scheduler 單機服務常用的調度任務策略。

2.xml配置

                <beans xmlns:task="http://www.springframework.org/schema/task"xsi:schemaLocation="http://www.springframework.org/schema/task ? http://www.springframework.org/schema/task/spring-task-3.1.xsd">

                <task:executor id="executor" pool-size="15" />  
                <task:scheduler id="scheduler" pool-size="30" />  
                <task:annotation-driven executor="executor" scheduler="scheduler" />

2.corn 表達式時間設定，可參考corn表達式——用于設置定時任務

                @Scheduled(cron = "*/5 * * * * *")
                public void test1() throws InterruptedException {
                log.info("test1, 5秒執行一次，每次執行sleep 8s");
                }

3.注意事項：

• 3.1 同一定時任務，第二次觸發時間到了，第一次還沒有執行完成時會執行嗎？不會，會等前一次執行完成才執行下一次
• 3.2 不同的定時任務，相互之間是否有影響？取決于可用的定時任務線程數，如果線程數足夠則不會影響；如果可用定時任務線程數少于要執行定時任務數量，未能獲取到線程的自然要等到有空閑線程時才能執行。

quartz 集群發布web服務器任務策略

可以解決如果是集群發布web服務器，就會導致每個服務器都跑一遍這個定時器，會出現定時器被多次執行方法。quartz可以解決這個問題，quartz是用javaweb服務器和數據庫等配合完成的一個定時器選擇服務器執行的機制實現的，這樣每次到執行的時候只選擇一個合適的web服務器去執行定時任務。

1.配置maven依賴

                <!-- 定時任務 -->
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
        </dependency>

2.Scheduler 調度程序配置

<description>Quartz的定時集群任務配置</description>
    <bean name="quartzScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <!--必須，QuartzScheduler 延時啟動，應用啟動后 QuartzScheduler 再啟動 -->
        <property name="startupDelay" value="60"/>
        <!-- 普通觸發器 ：觸發器列表 -->
        <property name="triggers">
            <list>                
                <ref local="syncFacTimerTrigger"/>
            </list>
        </property>
        <property name="quartzProperties">
            <props>
                <!-- 主要是這個參數 -->
                <prop key="org.quartz.scheduler.skipUpdateCheck">true</prop>
                <prop key="org.terracotta.quartz.skipUpdateCheck">true</prop>
            </props>
        </property>
    </bean>

3.Trigger 觸發器的配置

<!--Cron表達式觸發器-->
    <bean id="syncFacTimerTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail">
            <ref bean="QuartzSyncFacJob"/> <!-- 觸發器觸發的 執行定時任務的bean -->
        </property>
        <property name="cronExpression">
             <value>0 0/30 * * * ?</value>  <!--30分鐘一次-->
            <!--  <value>0 0/1 * * * ?</value> --> <!-- 1分鐘一次 -->
            <!--<value>0 0 2 * * ?</value> <!–每天2點 –>-->
            <!--<value>0 0/1 * * * ?</value> 1分鐘一次 -->
        </property>
    </bean>

4.Job 調度任務配置

<bean id="QuartzSyncFacJob" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
        <!-- durability 表示任務完成之后是否依然保留到數據庫，默認false -->
        <property name="durability" value="true"/>
        <!-- 目標類 /wmuitp/src/test/SpringQuartz.java -->
        <property name="jobClass" value="com.hec.dup.web.schedule.QuartzSyncFacJob"/><!--任務類-->
        <property name="applicationContextJobDataKey" value="applicationContext"/>
        <property name="jobDataAsMap"><!-- 非常重要，用來向JobDetail傳參 -->
            <map>
                <entry key="dupMgrOrgReviseDoService" value-ref="dupMgrOrgReviseDoService"/><!--注入的servise名稱-->
            </map>
        </property>
    </bean>

5 Job類，用于處理相關業務邏輯

public class QuartzSyncFacJob extends QuartzJobBean {
    private static Logger logger = LoggerFactory.getLogger(QuartzJobBean.class);

    @Override
    public void executeInternal(JobExecutionContext context) throws JobExecutionException {
        syncData(context);
    }

    public void syncData(JobExecutionContext context) {
        //通過bean注入到jobDataAsMap中，再獲取
        IDupMgrOrgReviseDoService dupMgrOrgReviseDoService = (IDupMgrOrgReviseDoService) context.getJobDetail().getJobDataMap().get("dupMgrOrgReviseDoService");
                //處理相關邏輯
        dupMgrOrgReviseDoService.syncSaveOrUpMdcFactory(); 
    }

}

以上是日常用到任務調度，當然spring提供了多種方式的調度注入方式，除了bean，還有各種@注入方式，有興趣的可以自己研究。