Quartz使用總結、Cron表達式

前些天發現了一個巨牛的人工智能學習網站,通俗易懂,風趣幽默,忍不住分享一下給大家。點擊跳轉到教程。

Quartz可以用來做什么?

Quartz是一個任務調度框架。比如你遇到這樣的問題

  • 想每月25號,信用卡自動還款
  • 想每年4月1日自己給當年暗戀女神發一封匿名賀卡
  • 想每隔1小時,備份一下自己的愛情動作片 學習筆記到云盤

這些問題總結起來就是:在某一個有規律的時間點干某件事。并且時間的觸發的條件可以非常復雜(比如每月最后一個工作日的17:50),復雜到需要一個專門的框架來干這個事。 Quartz就是來干這樣的事,你給它一個觸發條件的定義,它負責到了時間點,觸發相應的Job起來干活。

一個簡單的示例

這里面的所有例子都是基于Quartz 2.2.1

package com.test.quartz;import static org.quartz.DateBuilder.newDate;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.SimpleScheduleBuilder.simpleSchedule;
import static org.quartz.TriggerBuilder.newTrigger;import java.util.GregorianCalendar;import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.calendar.AnnualCalendar;public class QuartzTest {public static void main(String[] args) {try {//創建schedulerScheduler scheduler = StdSchedulerFactory.getDefaultScheduler();//定義一個TriggerTrigger trigger = newTrigger().withIdentity("trigger1", "group1") //定義name/group.startNow()//一旦加入scheduler,立即生效.withSchedule(simpleSchedule() //使用SimpleTrigger.withIntervalInSeconds(1) //每隔一秒執行一次.repeatForever()) //一直執行,奔騰到老不停歇.build();//定義一個JobDetailJobDetail job = newJob(HelloQuartz.class) //定義Job類為HelloQuartz類,這是真正的執行邏輯所在.withIdentity("job1", "group1") //定義name/group.usingJobData("name", "quartz") //定義屬性.build();//加入這個調度scheduler.scheduleJob(job, trigger);//啟動之scheduler.start();//運行一段時間后關閉Thread.sleep(10000);scheduler.shutdown(true);} catch (Exception e) {e.printStackTrace();}}
}
package com.test.quartz;import java.util.Date;import org.quartz.DisallowConcurrentExecution;
import org.quartz.Job;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;public class HelloQuartz implements Job {public void execute(JobExecutionContext context) throws JobExecutionException {JobDetail detail = context.getJobDetail();String name = detail.getJobDataMap().getString("name");System.out.println("say hello to " + name + " at " + new Date());}
}

這個例子很好的覆蓋了Quartz最重要的3個基本要素:

  • Scheduler:調度器。所有的調度都是由它控制。
  • Trigger: 定義觸發的條件。例子中,它的類型是SimpleTrigger,每隔1秒中執行一次(什么是SimpleTrigger下面會有詳述)。
  • JobDetail & Job: JobDetail 定義的是任務數據,而真正的執行邏輯是在Job中,例子中是HelloQuartz。 為什么設計成JobDetail + Job,不直接使用Job?這是因為任務是有可能并發執行,如果Scheduler直接使用Job,就會存在對同一個Job實例并發訪問的問題。而JobDetail & Job 方式,sheduler每次執行,都會根據JobDetail創建一個新的Job實例,這樣就可以規避并發訪問的問題。

Quartz API

Quartz的API的風格在2.x以后,采用的是DSL風格(通常意味著fluent interface風格),就是示例中newTrigger()那一段東西。它是通過Builder實現的,就是以下幾個。(** 下面大部分代碼都要引用這些Builder ** )

//job相關的builder
import static org.quartz.JobBuilder.*;//trigger相關的builder
import static org.quartz.TriggerBuilder.*;
import static org.quartz.SimpleScheduleBuilder.*;
import static org.quartz.CronScheduleBuilder.*;
import static org.quartz.DailyTimeIntervalScheduleBuilder.*;
import static org.quartz.CalendarIntervalScheduleBuilder.*;//日期相關的builder
import static org.quartz.DateBuilder.*;

DSL風格寫起來會更加連貫,暢快,而且由于不是使用setter的風格,語義上會更容易理解一些。對比一下:

JobDetail jobDetail=new JobDetailImpl("jobDetail1","group1",HelloQuartz.class);
jobDetail.getJobDataMap().put("name", "quartz");SimpleTriggerImpl trigger=new SimpleTriggerImpl("trigger1","group1");
trigger.setStartTime(new Date());
trigger.setRepeatInterval(1);
trigger.setRepeatCount(-1);

關于name和group

JobDetail和Trigger都有name和group。

name是它們在這個sheduler里面的唯一標識。如果我們要更新一個JobDetail定義,只需要設置一個name相同的JobDetail實例即可。

group是一個組織單元,sheduler會提供一些對整組操作的API,比如 scheduler.resumeJobs()。

Trigger

在開始詳解每一種Trigger之前,需要先了解一下Trigger的一些共性。

StartTime & EndTime

startTime和endTime指定的Trigger會被觸發的時間區間。在這個區間之外,Trigger是不會被觸發的。

** 所有Trigger都會包含這兩個屬性 **

優先級(Priority)

當scheduler比較繁忙的時候,可能在同一個時刻,有多個Trigger被觸發了,但資源不足(比如線程池不足)。那么這個時候比剪刀石頭布更好的方式,就是設置優先級。優先級高的先執行。

需要注意的是,優先級只有在同一時刻執行的Trigger之間才會起作用,如果一個Trigger是9:00,另一個Trigger是9:30。那么無論后一個優先級多高,前一個都是先執行。

優先級的值默認是5,當為負數時使用默認值。最大值似乎沒有指定,但建議遵循Java的標準,使用1-10,不然鬼才知道看到【優先級為10】是時,上頭還有沒有更大的值。

Misfire(錯失觸發)策略

類似的Scheduler資源不足的時候,或者機器崩潰重啟等,有可能某一些Trigger在應該觸發的時間點沒有被觸發,也就是Miss Fire了。這個時候Trigger需要一個策略來處理這種情況。每種Trigger可選的策略各不相同。

這里有兩個點需要重點注意:

  • MisFire的觸發是有一個閥值,這個閥值是配置在JobStore的。比RAMJobStore是org.quartz.jobStore.misfireThreshold。只有超過這個閥值,才會算MisFire。小于這個閥值,Quartz是會全部重新觸發。

所有MisFire的策略實際上都是解答兩個問題:

  1. 已經MisFire的任務還要重新觸發嗎?
  2. 如果發生MisFire,要調整現有的調度時間嗎?

比如SimpleTrigger的MisFire策略有:

  • MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY

    這個不是忽略已經錯失的觸發的意思,而是說忽略MisFire策略。它會在資源合適的時候,重新觸發所有的MisFire任務,并且不會影響現有的調度時間。

    比如,SimpleTrigger每15秒執行一次,而中間有5分鐘時間它都MisFire了,一共錯失了20個,5分鐘后,假設資源充足了,并且任務允許并發,它會被一次性觸發。

    這個屬性是所有Trigger都適用。

  • MISFIRE_INSTRUCTION_FIRE_NOW

    忽略已經MisFire的任務,并且立即執行調度。這通常只適用于只執行一次的任務。

  • MISFIRE_INSTRUCTION_RESCHEDULE_NOW_WITH_EXISTING_REPEAT_COUNT

    將startTime設置當前時間,立即重新調度任務,包括的MisFire的

  • MISFIRE_INSTRUCTION_RESCHEDULE_NOW_WITH_REMAINING_REPEAT_COUNT

    類似MISFIRE_INSTRUCTION_RESCHEDULE_NOW_WITH_EXISTING_REPEAT_COUNT,區別在于會忽略已經MisFire的任務

  • MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_EXISTING_COUNT

    在下一次調度時間點,重新開始調度任務,包括的MisFire的

  • MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_REMAINING_COUNT

    類似于MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_EXISTING_COUNT,區別在于會忽略已經MisFire的任務。

  • MISFIRE_INSTRUCTION_SMART_POLICY

    所有的Trigger的MisFire默認值都是這個,大致意思是“把處理邏輯交給聰明的Quartz去決定”。基本策略是,

    1. 如果是只執行一次的調度,使用MISFIRE_INSTRUCTION_FIRE_NOW
    2. 如果是無限次的調度(repeatCount是無限的),使用MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_REMAINING_COUNT
    3. 否則,使用MISFIRE_INSTRUCTION_RESCHEDULE_NOW_WITH_EXISTING_REPEAT_COUNT

MisFire的東西挺繁雜的,可以參考這篇

Calendar

這里的Calendar不是jdk的java.util.Calendar,不是為了計算日期的。它的作用是在于補充Trigger的時間。可以排除或加入某一些特定的時間點。

以”每月25日零點自動還卡債“為例,我們想排除掉每年的2月25號零點這個時間點(因為有2.14,所以2月一定會破產)。這個時間,就可以用Calendar來實現。

例子:

AnnualCalendar cal = new AnnualCalendar(); //定義一個每年執行Calendar,精度為天,即不能定義到2.25號下午2:00
java.util.Calendar excludeDay = new GregorianCalendar();
excludeDay.setTime(newDate().inMonthOnDay(2, 25).build());
cal.setDayExcluded(excludeDay, true);  //設置排除2.25這個日期
scheduler.addCalendar("FebCal", cal, false, false); //scheduler加入這個Calendar//定義一個Trigger
Trigger trigger = newTrigger().withIdentity("trigger1", "group1") .startNow()//一旦加入scheduler,立即生效.modifiedByCalendar("FebCal") //使用Calendar !!.withSchedule(simpleSchedule().withIntervalInSeconds(1) .repeatForever()) .build();

Quartz體貼地為我們提供以下幾種Calendar,注意,所有的Calendar既可以是排除,也可以是包含,取決于:

  • HolidayCalendar。指定特定的日期,比如20140613。精度到天。
  • DailyCalendar。指定每天的時間段(rangeStartingTime, rangeEndingTime),格式是HH:MM[:SS[:mmm]]。也就是最大精度可以到毫秒。
  • WeeklyCalendar。指定每星期的星期幾,可選值比如為java.util.Calendar.SUNDAY。精度是天。
  • MonthlyCalendar。指定每月的幾號。可選值為1-31。精度是天
  • AnnualCalendar。 指定每年的哪一天。使用方式如上例。精度是天。
  • CronCalendar。指定Cron表達式。精度取決于Cron表達式,也就是最大精度可以到秒。

Trigger實現類

Quartz有以下幾種Trigger實現:

SimpleTrigger

指定從某一個時間開始,以一定的時間間隔(單位是毫秒)執行的任務。

它適合的任務類似于:9:00 開始,每隔1小時,執行一次。

它的屬性有:

  • repeatInterval 重復間隔
  • repeatCount 重復次數。實際執行次數是 repeatCount+1。因為在startTime的時候一定會執行一次。** 下面有關repeatCount 屬性的都是同理。 **

例子:

simpleSchedule().withIntervalInHours(1) //每小時執行一次.repeatForever() //次數不限.build();simpleSchedule().withIntervalInMinutes(1) //每分鐘執行一次.withRepeatCount(10) //次數為10次.build();

CalendarIntervalTrigger

類似于SimpleTrigger,指定從某一個時間開始,以一定的時間間隔執行的任務。 但是不同的是SimpleTrigger指定的時間間隔為毫秒,沒辦法指定每隔一個月執行一次(每月的時間間隔不是固定值),而CalendarIntervalTrigger支持的間隔單位有秒,分鐘,小時,天,月,年,星期。

相較于SimpleTrigger有兩個優勢:1、更方便,比如每隔1小時執行,你不用自己去計算1小時等于多少毫秒。 2、支持不是固定長度的間隔,比如間隔為月和年。但劣勢是精度只能到秒。

它適合的任務類似于:9:00 開始執行,并且以后每周 9:00 執行一次

它的屬性有:

  • interval 執行間隔
  • intervalUnit 執行間隔的單位(秒,分鐘,小時,天,月,年,星期)

例子:

calendarIntervalSchedule().withIntervalInDays(1) //每天執行一次.build();calendarIntervalSchedule().withIntervalInWeeks(1) //每周執行一次.build();

DailyTimeIntervalTrigger

指定每天的某個時間段內,以一定的時間間隔執行任務。并且它可以支持指定星期。

它適合的任務類似于:指定每天9:00 至 18:00 ,每隔70秒執行一次,并且只要周一至周五執行。

它的屬性有:

  • startTimeOfDay 每天開始時間
  • endTimeOfDay 每天結束時間
  • daysOfWeek 需要執行的星期
  • interval 執行間隔
  • intervalUnit 執行間隔的單位(秒,分鐘,小時,天,月,年,星期)
  • repeatCount 重復次數

例子:

dailyTimeIntervalSchedule().startingDailyAt(TimeOfDay.hourAndMinuteOfDay(9, 0)) //第天9:00開始.endingDailyAt(TimeOfDay.hourAndMinuteOfDay(16, 0)) //16:00 結束 .onDaysOfTheWeek(MONDAY,TUESDAY,WEDNESDAY,THURSDAY,FRIDAY) //周一至周五執行.withIntervalInHours(1) //每間隔1小時執行一次.withRepeatCount(100) //最多重復100次(實際執行100+1次).build();dailyTimeIntervalSchedule().startingDailyAt(TimeOfDay.hourAndMinuteOfDay(9, 0)) //第天9:00開始.endingDailyAfterCount(10) //每天執行10次,這個方法實際上根據 startTimeOfDay+interval*count 算出 endTimeOfDay.onDaysOfTheWeek(MONDAY,TUESDAY,WEDNESDAY,THURSDAY,FRIDAY) //周一至周五執行.withIntervalInHours(1) //每間隔1小時執行一次.build();

CronTrigger

適合于更復雜的任務,它支持類型于Linux Cron的語法(并且更強大)。基本上它覆蓋了以上三個Trigger的絕大部分能力(但不是全部)—— 當然,也更難理解。

它適合的任務類似于:每天0:00,9:00,18:00各執行一次。

它的屬性只有:

  • Cron表達式。但這個表示式本身就夠復雜了。下面會有說明。

例子:

cronSchedule("0 0/2 8-17 * * ?") // 每天8:00-17:00,每隔2分鐘執行一次.build();cronSchedule("0 30 9 ? * MON") // 每周一,9:30執行一次
.build();weeklyOnDayAndHourAndMinute(MONDAY,9, 30) //等同于 0 30 9 ? * MON .build();

Cron表達式

位置時間域允許值特殊值
10-59, - * /
2分鐘0-59, - * /
3小時0-23, - * /
4日期1-31, - * ? / L W C
5月份1-12, - * /
6星期1-7, - * ? / L C #
7年份(可選)1-31, - * /

星號():可用在所有字段中,表示對應時間域的每一個時刻,例如,?在分鐘字段時,表示“每分鐘”;

問號(?):該字符只在日期和星期字段中使用,它通常指定為“無意義的值”,相當于點位符;

減號(-):表達一個范圍,如在小時字段中使用“10-12”,則表示從10到12點,即10,11,12;

逗號(,):表達一個列表值,如在星期字段中使用“MON,WED,FRI”,則表示星期一,星期三和星期五;

斜杠(/):x/y表達一個等步長序列,x為起始值,y為增量步長值。如在分鐘字段中使用0/15,則表示為0,15,30和45秒,而5/15在分鐘字段中表示5,20,35,50,你也可以使用*/y,它等同于0/y;

L:該字符只在日期和星期字段中使用,代表“Last”的意思,但它在兩個字段中意思不同。L在日期字段中,表示這個月份的最后一天,如一月的31號,非閏年二月的28號;如果L用在星期中,則表示星期六,等同于7。但是,如果L出現在星期字段里,而且在前面有一個數值X,則表示“這個月的最后X天”,例如,6L表示該月的最后星期五;

W:該字符只能出現在日期字段里,是對前導日期的修飾,表示離該日期最近的工作日。例如15W表示離該月15號最近的工作日,如果該月15號是星期六,則匹配14號星期五;如果15日是星期日,則匹配16號星期一;如果15號是星期二,那結果就是15號星期二。但必須注意關聯的匹配日期不能夠跨月,如你指定1W,如果1號是星期六,結果匹配的是3號星期一,而非上個月最后的那天。W字符串只能指定單一日期,而不能指定日期范圍;

LW組合:在日期字段可以組合使用LW,它的意思是當月的最后一個工作日;

井號(#):該字符只能在星期字段中使用,表示當月某個工作日。如6#3表示當月的第三個星期五(6表示星期五,#3表示當前的第三個),而4#5表示當月的第五個星期三,假設當月沒有第五個星期三,忽略不觸發;

C:該字符只在日期和星期字段中使用,代表“Calendar”的意思。它的意思是計劃所關聯的日期,如果日期沒有被關聯,則相當于日歷中所有日期。例如5C在日期字段中就相當于日歷5日以后的第一天。1C在星期字段中相當于星期日后的第一天。

Cron表達式對特殊字符的大小寫不敏感,對代表星期的縮寫英文大小寫也不敏感。

一些例子:

表示式說明
0 0 12 * * ?每天12點運行
0 15 10 ? * *每天10:15運行
0 15 10 * * ?每天10:15運行
0 15 10 * * ? *每天10:15運行
0 15 10 * * ? 2008在2008年的每天10:15運行
0 * 14 * * ?每天14點到15點之間每分鐘運行一次,開始于14:00,結束于14:59。
0 0/5 14 * * ?每天14點到15點每5分鐘運行一次,開始于14:00,結束于14:55。
0 0/5 14,18 * * ?每天14點到15點每5分鐘運行一次,此外每天18點到19點每5鐘也運行一次。
0 0-5 14 * * ?每天14:00點到14:05,每分鐘運行一次。
0 10,44 14 ? 3 WED3月每周三的14:10分到14:44,每分鐘運行一次。
0 15 10 ? * MON-FRI每周一,二,三,四,五的10:15分運行。
0 15 10 15 * ?每月15日10:15分運行。
0 15 10 L * ?每月最后一天10:15分運行。
0 15 10 ? * 6L每月最后一個星期五10:15分運行。
0 15 10 ? * 6L 2007-2009在2007,2008,2009年每個月的最后一個星期五的10:15分運行。
0 15 10 ? * 6#3每月第三個星期五的10:15分運行。

JobDetail & Job

JobDetail是任務的定義,而Job是任務的執行邏輯。在JobDetail里會引用一個Job Class定義。一個最簡單的例子

public class JobTest {public static void main(String[] args) throws SchedulerException, IOException {JobDetail job=newJob().ofType(DoNothingJob.class) //引用Job Class.withIdentity("job1", "group1") //設置name/group.withDescription("this is a test job") //設置描述.usingJobData("age", 18) //加入屬性到ageJobDataMap.build();job.getJobDataMap().put("name", "quertz"); //加入屬性name到JobDataMap//定義一個每秒執行一次的SimpleTriggerTrigger trigger=newTrigger().startNow().withIdentity("trigger1").withSchedule(simpleSchedule().withIntervalInSeconds(1).repeatForever()).build();Scheduler sche=StdSchedulerFactory.getDefaultScheduler();sche.scheduleJob(job, trigger);sche.start();System.in.read();sche.shutdown();}
}public class DoNothingJob implements Job {public void execute(JobExecutionContext context) throws JobExecutionException {System.out.println("do nothing");}
}

從上例我們可以看出,要定義一個任務,需要干幾件事:

  1. 創建一個org.quartz.Job的實現類,并實現實現自己的業務邏輯。比如上面的DoNothingJob。
  2. 定義一個JobDetail,引用這個實現類
  3. 加入scheduleJob

Quartz調度一次任務,會干如下的事:

  1. JobClass jobClass=JobDetail.getJobClass()
  2. Job jobInstance=jobClass.newInstance()。所以Job實現類,必須有一個public的無參構建方法。
  3. jobInstance.execute(JobExecutionContext context)。JobExecutionContext是Job運行的上下文,可以獲得Trigger、Scheduler、JobDetail的信息。

也就是說,每次調度都會創建一個新的Job實例,這樣的好處是有些任務并發執行的時候,不存在對臨界資源的訪問問題——當然,如果需要共享JobDataMap的時候,還是存在臨界資源的并發訪問的問題。

JobDataMap

Job都次都是newInstance的實例,那我怎么傳值給它? 比如我現在有兩個發送郵件的任務,一個是發給"liLei",一個發給"hanmeimei",不能說我要寫兩個Job實現類LiLeiSendEmailJob和HanMeiMeiSendEmailJob。實現的辦法是通過JobDataMap。

每一個JobDetail都會有一個JobDataMap。JobDataMap本質就是一個Map的擴展類,只是提供了一些更便捷的方法,比如getString()之類的。

我們可以在定義JobDetail,加入屬性值,方式有二:

newJob().usingJobData("age", 18) //加入屬性到ageJobDataMaporjob.getJobDataMap().put("name", "quertz"); //加入屬性name到JobDataMap

然后在Job中可以獲取這個JobDataMap的值,方式同樣有二:

public class HelloQuartz implements Job {private String name;public void execute(JobExecutionContext context) throws JobExecutionException {JobDetail detail = context.getJobDetail();JobDataMap map = detail.getJobDataMap(); //方法一:獲得JobDataMapSystem.out.println("say hello to " + name + "[" + map.getInt("age") + "]" + " at "+ new Date());}//方法二:屬性的setter方法,會將JobDataMap的屬性自動注入public void setName(String name) { this.name = name;}
}

對于同一個JobDetail實例,執行的多個Job實例,是共享同樣的JobDataMap,也就是說,如果你在任務里修改了里面的值,會對其他Job實例(并發的或者后續的)造成影響。

除了JobDetail,Trigger同樣有一個JobDataMap,共享范圍是所有使用這個Trigger的Job實例。

Job并發

Job是有可能并發執行的,比如一個任務要執行10秒中,而調度算法是每秒中觸發1次,那么就有可能多個任務被并發執行。

有時候我們并不想任務并發執行,比如這個任務要去”獲得數據庫中所有未發送郵件的名單“,如果是并發執行,就需要一個數據庫鎖去避免一個數據被多次處理。這個時候一個@DisallowConcurrentExecution解決這個問題。

就是這樣

public class DoNothingJob implements Job {@DisallowConcurrentExecutionpublic void execute(JobExecutionContext context) throws JobExecutionException {System.out.println("do nothing");}
}

注意,@DisallowConcurrentExecution是對JobDetail實例生效,也就是如果你定義兩個JobDetail,引用同一個Job類,是可以并發執行的。

JobExecutionException

Job.execute()方法是不允許拋出除JobExecutionException之外的所有異常的(包括RuntimeException),所以編碼的時候,最好是try-catch住所有的Throwable,小心處理。

其他屬性

  • Durability(耐久性?)

    如果一個任務不是durable,那么當沒有Trigger關聯它的時候,它就會被自動刪除。

  • RequestsRecovery

    如果一個任務是"requests recovery",那么當任務運行過程非正常退出時(比如進程崩潰,機器斷電,但不包括拋出異常這種情況),Quartz再次啟動時,會重新運行一次這個任務實例。

    可以通過JobExecutionContext.isRecovering()查詢任務是否是被恢復的。

Scheduler

Scheduler就是Quartz的大腦,所有任務都是由它來設施。

Schduelr包含一個兩個重要組件: JobStore和ThreadPool。

JobStore是會來存儲運行時信息的,包括Trigger,Schduler,JobDetail,業務鎖等。它有多種實現RAMJob(內存實現),JobStoreTX(JDBC,事務由Quartz管理),JobStoreCMT(JDBC,使用容器事務),ClusteredJobStore(集群實現)、TerracottaJobStore(什么是Terractta)。

ThreadPool就是線程池,Quartz有自己的線程池實現。所有任務的都會由線程池執行。

SchedulerFactory

SchdulerFactory,顧名思義就是來用創建Schduler了,有兩個實現:DirectSchedulerFactory和 StdSchdulerFactory。前者可以用來在代碼里定制你自己的Schduler參數。后者是直接讀取classpath下的quartz.properties(不存在就都使用默認值)配置來實例化Schduler。通常來講,我們使用StdSchdulerFactory也就足夠了。

SchdulerFactory本身是支持創建RMI stub的,可以用來管理遠程的Scheduler,功能與本地一樣,可以遠程提交個Job什么的。

DirectSchedulerFactory的創建接口

    /*** Same as* {@link DirectSchedulerFactory#createScheduler(ThreadPool threadPool, JobStore jobStore)},* with the addition of specifying the scheduler name and instance ID. This* scheduler can only be retrieved via* {@link DirectSchedulerFactory#getScheduler(String)}** @param schedulerName*          The name for the scheduler.* @param schedulerInstanceId*          The instance ID for the scheduler.* @param threadPool*          The thread pool for executing jobs* @param jobStore*          The type of job store* @throws SchedulerException*           if initialization failed*/public void createScheduler(String schedulerName,String schedulerInstanceId, ThreadPool threadPool, JobStore jobStore)throws SchedulerException;

StdSchdulerFactory的配置例子, 更多配置,參考Quartz配置指南:

org.quartz.scheduler.instanceName = DefaultQuartzScheduler
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10 
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true
org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

這里未講的稍微高級的主題

  • JobStore?介紹、配置
  • 集群:?介紹、配置
  • RMI
  • 監聽器?TriggerListeners and JobListeners、SchedulerListeners
  • 插件

參考

  • 主要的資料來自官方文檔,這里有教程,例子,配置等,非常詳細
  • Cron表達式的說明,大段引用自這里
  • 中文文檔,雖然版本比較舊,但是很多東西還是沒過時的,比如插件、RMI,Quartz_Job_Scheduling_Framework_CN_V1.0.0

?

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/449782.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/449782.shtml
英文地址,請注明出處:http://en.pswp.cn/news/449782.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

股票數據庫建立

import akshare as ak import baostock as bs import pandas as pd import datetime bs.login()stk_list_place D:/stk_list.csv #股票代碼表存儲地址 stk_place D:/Data/ #股票數據存儲地址 def update_stk_list(dateNone):#獲取指定日期的指數、股票數據stock_rs bs.qu…

利用redis實現分布式鎖:加鎖與解鎖

待補充轉載于:https://www.cnblogs.com/csuliujia/p/10451462.html

MVC日期格式化,后臺使用Newtonsoft.Json序列化日期,前端使用”f”格式化日期

MVC控制器中,經常使用Newtonsoft.Json把對象序列化成json字符串傳遞到前端視圖。當對象中有DateTime類型的屬性時,前后臺如何處理才能把DateTime類型轉換成想要的格式呢? 有這樣的一個類具有DateTime類型屬性: using System; name…

多股回測(backtrader+quantstats+akshare)

導包 #引入技術指標數據 from __future__ import (absolute_import ,division,print_function,unicode_literals) import datetime #用于datetime對象操作 import os.path #用于管理路徑 import sys #用于在argvTo[0]中找到腳本名稱 import backtrader as bt #引入backt…

Cron表達式、定時任務

前些天發現了一個巨牛的人工智能學習網站,通俗易懂,風趣幽默,忍不住分享一下給大家。點擊跳轉到教程。 Cron表達式。但這個表示式本身就夠復雜了。下面會有說明。 例子: cronSchedule("0 0/2 8-17 * * ?") // 每天8:0…

【轉載】ASP.NET自定義404和500錯誤頁面

在ASP.NET網站項目實際上線運行的過程中,有時候在運行環境下會出現400錯誤或者500錯誤,這些錯誤默認的頁面都不友好,比較簡單單調,其實我們可以自行設置這些錯誤所對應的頁面,讓這些錯誤跳轉到我們指定的路徑。此文將介…

年薪15萬的80后小本科:只要6分鐘,告訴你少走6年彎路

這個社會是很殘酷的,尤其是對于那些剛剛步入社會的80后而言。當很多人都在抱怨這個社會競爭壓力太大、沒有自己的追求,并因此而喪失斗志的時候,一個年薪15W的80后小本卻發出了這個的感慨,“一個人的成就,與歲月無關&am…

Google Go Programming In Eclipse

http://www.tutorialsavvy.com/2013/04/google-go-programming-in-eclipse.html/ Google Go Programming In Eclipse The new “Go” programming language is from Google co.It has many features better then other languages.Go language features are:-– High Speed Comp…

pycharm打開ipynb顯示為文本格式解決辦法

然后進入 添加類型 jupyter notebook 然后下方添加 *.ipynb

quartz各版本MySQL數據庫存儲建表SQL語句

前些天發現了一個巨牛的人工智能學習網站,通俗易懂,風趣幽默,忍不住分享一下給大家。點擊跳轉到教程。 用quartz管理任務計劃很方便,但是當使用數據庫作為存儲介質的時候,必須要先創建表,不然就會報錯。1.…

[基礎篇]ESP32-RTOS-SDK教程(一)之Windows環境搭建

當下正是物聯網最好的時代,學習新的技術怎么能只學習ESP8266呢?要知道ESP8266還有一個孿生兄弟呢,最重要的是這個孿生兄弟要比ESP8266是更厲害的,所以我們也是非常有必要學習一下的,其實這篇文章去年就已經寫了&#x…

對話Linus Torvalds:大多黑客甚至連指針都未理解

摘要:Linus Torvalds坦言那些狡詐的通過文件名查找高速緩存,然后又抱怨自己能力一般的內核“惡魔”才是他欣賞的;相反,很多人連低水平的內核編程都還沒學好。 幾周前, Linus Torvalds在Slashdot上回答了一些問題。其中…

總結學習(提綱)

之前在私募做期權量化學習了那么久,趁著畢業找工作這段時間,對之前學習的東西,制作的函數等進行一個系統性的總結,順便每天更新的時候,記錄下自己的體重與波比跳次數。 1.MC的學習與策略編寫 2.python基礎學習資料的…

安卓系統上的遠程 JS 調試 Remote JavaScript Debugging on Android

每當在 Android 移動設備上調試網頁時,開發人員往往都會不自覺陷入調試的泥潭中去。《Android開發指南》提供了一個解決方案,卻有點繁瑣復雜。因此,許多 Web 開發人員會傾向于使用類似 Firefox Firebug 的或像 WebKit 的 Web Inspector 之類的…

js關于表單校驗完善

<!DOCTYPE html><html> <head> <meta charset"UTF-8"> <title>注冊頁面</title> <style type"text/css"> .left{ width: 100px; …

Python高效編程技巧

摘要&#xff1a;作者有多年的Python編程經驗&#xff0c;并且有很多的編程小技巧和知識&#xff0c;其中大多數是通過閱讀很流行的開源軟件&#xff0c;如Django, Flask, Requests中獲得的。 我已經使用Python編程有多年了&#xff0c;即使今天我仍然驚奇于這種語言所能讓代碼…

quartz 任務調試 建表 sql 語句、create table語句

前些天發現了一個巨牛的人工智能學習網站&#xff0c;通俗易懂&#xff0c;風趣幽默&#xff0c;忍不住分享一下給大家。點擊跳轉到教程。 DROP TABLE IF EXISTS QRTZ_FIRED_TRIGGERS; DROP TABLE IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS; DROP TABLE IF EXISTS QRTZ_SCHEDUL…

關于ttk的使用與安裝

ttk是tkinter中的子模塊&#xff0c;在python2.x中是作為獨立模塊。但是在python3.x中則是成為了tkinter的子模塊&#xff0c;因此調用時&#xff0c;轉變為 from Tkinter import ttk

SEO藝術

SEO藝術 編輯推薦 在本書中&#xff0c;四位搜索引擎優化&#xff08;SEO&#xff09;領域最受矚目的專家闡述了制訂以及執行一個完善的SEO策略時應遵循的一些實用指南與最新技術。 基本信息 原書名&#xff1a; The Art of SEO原出版社&#xff1a; OReilly作者&#xff1a; (…

ActiveMQ支持的傳輸協議

連接到ActiveMQ Connector:ActiveMQ提供的&#xff0c;用來實現連接通信的功能。包括:client-to-broker、broker-to-broker。ActiveMQ允許客戶端使用多種協議來進行連接。 client-to-broker模式一般是配置文件中的transportConnector配置 broker-to-broker:一般是指網絡(networ…