前言

任務(wù)調(diào)度是指基于給定時(shí)間點(diǎn)，給定時(shí)間間隔或者給定執(zhí)行次數(shù)自動(dòng)執(zhí)行任務(wù)。項(xiàng)目中有很獨(dú)特的應(yīng)用的場(chǎng)景，比如每天凌晨同步數(shù)據(jù)，定時(shí)操作業(yè)務(wù)等等。

創(chuàng)新互聯(lián)建站-專業(yè)網(wǎng)站定制、快速模板網(wǎng)站建設(shè)、高性價(jià)比湄潭網(wǎng)站開(kāi)發(fā)、企業(yè)建站全套包干低至880元,成熟完善的模板庫(kù),直接使用。一站式湄潭網(wǎng)站制作公司更省心,省錢,快速模板網(wǎng)站建設(shè)找我們，業(yè)務(wù)覆蓋湄潭地區(qū)。費(fèi)用合理售后完善，10年實(shí)體公司更值得信賴。

• Timer
• scheduler
• quartz

1 Timer

java.util.Timer，可以實(shí)現(xiàn)一些簡(jiǎn)單的定時(shí)任務(wù)，使用 Timer 實(shí)現(xiàn)任務(wù)調(diào)度的核心類是 Timer 和 TimerTask。其中 Timer 負(fù)責(zé)設(shè)定 TimerTask 的起始與間隔執(zhí)行時(shí)間。使用者只需要?jiǎng)?chuàng)建一個(gè) TimerTask 的繼承類，實(shí)現(xiàn)自己的 run 方法，然后將其丟給 Timer 去執(zhí)行即可。
Timer 將接收到的任務(wù)丟到自己的 TaskList 中，TaskList 按照 Task 的最初執(zhí)行時(shí)間進(jìn)行排序。TimerThread 在創(chuàng)建 Timer 時(shí)會(huì)啟動(dòng)成為一個(gè)守護(hù)線程。這個(gè)線程會(huì)輪詢所有任務(wù)，找到一個(gè)最近要執(zhí)行的任務(wù)，然后休眠，當(dāng)?shù)竭_(dá)最近要執(zhí)行任務(wù)的開(kāi)始時(shí)間點(diǎn)，TimerThread 被喚醒并執(zhí)行該任務(wù)。之后 TimerThread 更新最近一個(gè)要執(zhí)行的任務(wù)，繼續(xù)休眠如下。
Timer 的優(yōu)點(diǎn)在于簡(jiǎn)單易用，但由于所有任務(wù)都是由同一個(gè)線程來(lái)調(diào)度，因此所有任務(wù)都是串行執(zhí)行的，同一時(shí)間只能有一個(gè)任務(wù)在執(zhí)行，前一個(gè)任務(wù)的延遲或異常都將會(huì)影響到之后的任務(wù)：

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;
        // 從現(xiàn)在開(kāi)始 1 秒鐘之后，每隔 1 秒鐘執(zhí)行一次 job1
        timer.schedule(new TimerTest("job1"), delay1, period1);
        long delay2 = 2 * 1000;
        long period2 = 2000;
        // 從現(xiàn)在開(kāi)始 2 秒鐘之后，每隔 2 秒鐘執(zhí)行一次 job2
        timer.schedule(new TimerTest("job2"), delay2, period2);

    }
}

scheduler 單機(jī)服務(wù)常用的調(diào)度任務(wù)策略。

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 表達(dá)式時(shí)間設(shè)定，可參考corn表達(dá)式——用于設(shè)置定時(shí)任務(wù)

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

3.注意事項(xiàng)：

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

quartz 集群發(fā)布web服務(wù)器任務(wù)策略

可以解決如果是集群發(fā)布web服務(wù)器，就會(huì)導(dǎo)致每個(gè)服務(wù)器都跑一遍這個(gè)定時(shí)器，會(huì)出現(xiàn)定時(shí)器被多次執(zhí)行方法。quartz可以解決這個(gè)問(wèn)題，quartz是用javaweb服務(wù)器和數(shù)據(jù)庫(kù)等配合完成的一個(gè)定時(shí)器選擇服務(wù)器執(zhí)行的機(jī)制實(shí)現(xiàn)的，這樣每次到執(zhí)行的時(shí)候只選擇一個(gè)合適的web服務(wù)器去執(zhí)行定時(shí)任務(wù)。

1.配置maven依賴

    <!-- 定時(shí)任務(wù) -->
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
        </dependency>

2.Scheduler 調(diào)度程序配置

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

3.Trigger 觸發(fā)器的配置

<!--Cron表達(dá)式觸發(fā)器-->
    <bean id="syncFacTimerTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail">
            <ref bean="QuartzSyncFacJob"/> <!-- 觸發(fā)器觸發(fā)的 執(zhí)行定時(shí)任務(wù)的bean -->
        </property>
        <property name="cronExpression">
             <value>0 0/30 * * * ?</value>  <!--30分鐘一次-->
            <!--  <value>0 0/1 * * * ?</value> --> <!-- 1分鐘一次 -->
            <!--<value>0 0 2 * * ?</value> <!–每天2點(diǎn) –>-->
            <!--<value>0 0/1 * * * ?</value> 1分鐘一次 -->
        </property>
    </bean>

4.Job 調(diào)度任務(wù)配置

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

5 Job類，用于處理相關(guān)業(yè)務(wù)邏輯

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) {
        //通過(guò)bean注入到j(luò)obDataAsMap中，再獲取
        IDupMgrOrgReviseDoService dupMgrOrgReviseDoService = (IDupMgrOrgReviseDoService) context.getJobDetail().getJobDataMap().get("dupMgrOrgReviseDoService");
                //處理相關(guān)邏輯
        dupMgrOrgReviseDoService.syncSaveOrUpMdcFactory(); 
    }

}

以上是日常用到任務(wù)調(diào)度，當(dāng)然spring提供了多種方式的調(diào)度注入方式，除了bean，還有各種@注入方式，有興趣的可以自己研究。

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

新聞標(biāo)題：java調(diào)度任務(wù)在項(xiàng)目中的應(yīng)用-創(chuàng)新互聯(lián)
網(wǎng)頁(yè)地址：http://www.rwnh.cn/article40/pcjho.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站設(shè)計(jì)、面包屑導(dǎo)航、網(wǎng)站維護(hù)、App設(shè)計(jì)、云服務(wù)器、企業(yè)網(wǎng)站制作

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)