什么是分布式任務(wù)調(diào)度？怎樣實現(xiàn)任務(wù)調(diào)度

通常任務(wù)調(diào)度的程序是集成在應(yīng)用中的，比如：優(yōu)惠卷服務(wù)中包括了定時發(fā)放優(yōu)惠卷的的調(diào)度程序，結(jié)算服務(wù)中包括了定期生成報表的任務(wù)調(diào)度程序，由于采用分布式架構(gòu)，一個服務(wù)往往會部署多個冗余實例來運行我們的業(yè)務(wù)，在這種分布式系統(tǒng)環(huán)境下運行任務(wù)調(diào)度，我們稱之為分布式任務(wù)調(diào)度，如下圖：

不管是任務(wù)調(diào)度程序集成在應(yīng)用程序中，還是單獨構(gòu)建的任務(wù)調(diào)度系統(tǒng)，如果采用分布式調(diào)度任務(wù)的方式就相當(dāng)于將任務(wù)調(diào)度程序分布式構(gòu)建，這樣就可以具有分布式系統(tǒng)的特點，并且提高任務(wù)的調(diào)度處理能力：

1、并行任務(wù)調(diào)度

并行任務(wù)調(diào)度實現(xiàn)靠多線程，如果有大量任務(wù)需要調(diào)度，此時光靠多線程就會有瓶頸了，因為一臺計算機CPU的處理能力是有限的。

如果將任務(wù)調(diào)度程序分布式部署，每個結(jié)點還可以部署為集群，這樣就可以讓多臺計算機共同去完成任務(wù)調(diào)度，我們可以將任務(wù)分割為若干個分片，由不同的實例并行執(zhí)行，來提高任務(wù)調(diào)度的處理效率。

2、高可用

若某一個實例宕機，不影響其他實例來執(zhí)行任務(wù)。

3、彈性擴(kuò)容

當(dāng)集群中增加實例就可以提高并執(zhí)行任務(wù)的處理效率。

4、任務(wù)管理與監(jiān)測

對系統(tǒng)中存在的所有定時任務(wù)進(jìn)行統(tǒng)一的管理及監(jiān)測。讓開發(fā)人員及運維人員能夠時刻了解任務(wù)執(zhí)行情況，從而做出快速的應(yīng)急處理響應(yīng)。

5、避免任務(wù)重復(fù)執(zhí)行

當(dāng)任務(wù)調(diào)度以集群方式部署，同一個任務(wù)調(diào)度可能會執(zhí)行多次，比如在上面提到的電商系統(tǒng)中到點發(fā)優(yōu)惠券的例子，就會發(fā)放多次優(yōu)惠券，對公司造成很多損失，所以我們需要控制相同的任務(wù)在多個運行實例上只執(zhí)行一次。

public static void main(String[] args) {    
    //任務(wù)執(zhí)行間隔時間
    final long timeInterval = 1000;
    Runnable runnable = new Runnable() {
        public void run() {
            while (true) {
                //TODO：something
                try {
                    Thread.sleep(timeInterval);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    };
    Thread thread = new Thread(runnable);
    thread.start();
}

上面的代碼實現(xiàn)了按一定的間隔時間執(zhí)行任務(wù)調(diào)度的功能。

Jdk也為我們提供了相關(guān)支持，如Timer、ScheduledExecutor，下邊我們了解下。

Timer方式實現(xiàn)：

public static void main(String[] args){  
    Timer timer = new Timer();  
    timer.schedule(new TimerTask(){
        @Override  
        public void run() {  
           //TODO：something
        }  
    }, 1000, 2000);  //1秒后開始調(diào)度，每2秒執(zhí)行一次
}

Timer 的優(yōu)點在于簡單易用，每個Timer對應(yīng)一個線程，因此可以同時啟動多個Timer并行執(zhí)行多個任務(wù)，同一個Timer中的任務(wù)是串行執(zhí)行。

ScheduledExecutor方式實現(xiàn)：

public static void main(String [] agrs){
    ScheduledExecutorService service = Executors.newScheduledThreadPool(10);
    service.scheduleAtFixedRate(
            new Runnable() {
                @Override
                public void run() {
                    //TODO：something
                    System.out.println("todo something");
                }
            }, 1,
            2, TimeUnit.SECONDS);
}

Java 5 推出了基于線程池設(shè)計的 ScheduledExecutor，其設(shè)計思想是，每一個被調(diào)度的任務(wù)都會由線程池中一個線程去執(zhí)行，因此任務(wù)是并發(fā)執(zhí)行的，相互之間不會受到干擾。

Timer 和 ScheduledExecutor 都僅能提供基于開始時間與重復(fù)間隔的任務(wù)調(diào)度，不能勝任更加復(fù)雜的調(diào)度需求。比如，設(shè)置每月第一天凌晨1點執(zhí)行任務(wù)、復(fù)雜調(diào)度任務(wù)的管理、任務(wù)間傳遞數(shù)據(jù)等等。

第三方Quartz方式實現(xiàn)，項目地址：https://github.com/quartz-scheduler/quartz

Quartz 是一個功能強大的任務(wù)調(diào)度框架，它可以滿足更多更復(fù)雜的調(diào)度需求，Quartz 設(shè)計的核心類包括 Scheduler, Job 以及 Trigger。其中，Job 負(fù)責(zé)定義需要執(zhí)行的任務(wù)，Trigger 負(fù)責(zé)設(shè)置調(diào)度策略，Scheduler 將二者組裝在一起，并觸發(fā)任務(wù)開始執(zhí)行。Quartz支持簡單的按時間間隔調(diào)度、還支持按日歷調(diào)度方式，通過設(shè)置CronTrigger表達(dá)式(包括：秒、分、時、日、月、周、年)進(jìn)行任務(wù)調(diào)度。

下邊是一個例子代碼：

public static void main(String [] agrs) throws SchedulerException {
    //創(chuàng)建一個Scheduler
    SchedulerFactory schedulerFactory = new StdSchedulerFactory();
    Scheduler scheduler = schedulerFactory.getScheduler();
    //創(chuàng)建JobDetail
    JobBuilder jobDetailBuilder = JobBuilder.newJob(MyJob.class);
    jobDetailBuilder.withIdentity("jobName","jobGroupName");
    JobDetail jobDetail = jobDetailBuilder.build();
    //創(chuàng)建觸發(fā)的CronTrigger 支持按日歷調(diào)度
        CronTrigger trigger = TriggerBuilder.newTrigger()
                .withIdentity("triggerName", "triggerGroupName")
                .startNow()
                .withSchedule(CronScheduleBuilder.cronSchedule("0/2 * * * * ?"))
                .build();
    scheduler.scheduleJob(jobDetail,trigger);
    scheduler.start();
}

public class MyJob implements Job {
    @Override
    public void execute(JobExecutionContext jobExecutionContext){
        System.out.println("todo something");
    }
}

通過以上內(nèi)容我們學(xué)習(xí)了什么是任務(wù)調(diào)度，任務(wù)調(diào)度所解決的問題，以及任務(wù)調(diào)度的多種實現(xiàn)方式。