前言

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

武穴網(wǎng)站制作公司哪家好，找創(chuàng)新互聯(lián)公司！從網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、成都響應(yīng)式網(wǎng)站建設(shè)公司等網(wǎng)站項(xiàng)目制作，到程序開發(fā)，運(yùn)營維護(hù)。創(chuàng)新互聯(lián)公司從2013年創(chuàng)立到現(xiàn)在10年的時(shí)間，我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn)，來保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)公司。

• Timer
• scheduler
• quartz

1 Timer

java.util.Timer，可以實(shí)現(xià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ù)的開始時(shí)間點(diǎn)，TimerThread 被喚醒并執(zhí)行該任務(wù)。之后 TimerThread 更新最近一個(gè)要執(zhí)行的任務(wù)，繼續(xù)休眠如下。
Timer 的優(yōu)點(diǎn)在于簡單易用，但由于所有任務(wù)都是由同一個(gè)線程來調(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)在開始 1 秒鐘之后，每隔 1 秒鐘執(zhí)行一次 job1
        timer.schedule(new TimerTest("job1"), delay1, period1);
        long delay2 = 2 * 1000;
        long period2 = 2000;
        // 從現(xiàn)在開始 2 秒鐘之后，每隔 2 秒鐘執(zhí)行一次 job2
        timer.schedule(new TimerTest("job2"), delay2, period2);

    }
}

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

2.xml配置

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í)間到了，第一次還沒有執(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è)問題，quartz是用javaweb服務(wù)器和數(shù)據(jù)庫等配合完成的一個(gè)定時(shí)器選擇服務(wù)器執(zhí)行的機(jī)制實(shí)現(xiàn)的，這樣每次到執(zhí)行的時(shí)候只選擇一個(gè)合適的web服務(wù)器去執(zhí)行定時(shí)任務(wù)。

1.配置maven依賴

                
        
            org.quartz-scheduler
            quartz
        

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

Quartz的定時(shí)集群任務(wù)配置
    
        
        
        
        
                            
                
            
        
        
            
                
                true
                true
            
        
    

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

    
        
             
        
        
             0 0/30 * * * ?  
             
            
            
        
    

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

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) {
        //通過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，還有各種@注入方式，有興趣的可以自己研究。