SpringBoot中使用Quartz筆記


Quartz可以用來做什么?

Quartz是一個任務調度框架,可用來做定時任務。

吧啦吧啦.........

還是直接上代碼。

application.properties  配置文件。

job.calculateTriggerCron=0 0 23 * * ?   //秒,分鍾,小時,天,月,年,星期       這個配置的意思是 每天的 23:0:0 

QuartzPropertyConfig類 配置的實體化類。

@Configuration
public class QuartzPropertyConfig {
    
    /**
     * 清算任務
     */
    @Value("${job.calculateTriggerCron}")
    private String calculateTriggerCron;

    public String getCalculateTriggerCron() {
        return calculateTriggerCron;
    }

    public void setCalculateTriggerCron(String   calculateTriggerCron) {
        this.calculateTriggerCron = calculateTriggerCron;
    }
}
CalculateJob類  這個類用來實現定時具體需要執行的操作
@DisallowConcurrentExecution
public class CalculateJob implements Job {    //必須是實現Job接口喔
   @Resource
   private CalculateService calculateService;
    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        // 具體執行操作
        
    }
}
//CalculateService是配置在spring容器中的,而CalculateJob則是配置在Quartz數據庫中,由org.springframework.scheduling.quartz.SpringBeanJobFactory 
// 運行時調用 protected ObjectcreateJobInstance(TriggerFiredBundle bundle) throws Exception; 方法創建的。
// 所以我們等會把
Quartz中的job自動注入spring容器托管的對象
 
        
CalculateTask類 這個類中主要用來設置 JobDetailFactoryBean類 和 CronTriggerFactoryBean類
@Configuration 
public class CalculateTask {
    
    //時間配置文件
    @Resource
    private QuartzPropertyConfig zKQuartzConfig;
    
    @Bean(name="calculate")
    public JobDetailFactoryBean jobDetailFactoryBean(){
        //生成JobDetail
        JobDetailFactoryBean factory = new JobDetailFactoryBean();
        factory.setJobClass(CalculateJob.class);  //設置對應的Job
        factory.setGroup("calculateGroup");
        factory.setName("calculateJob");
        return factory;
    }


    @Bean(name="calculateTrigger")
    public CronTriggerFactoryBean cronTriggerFactoryBean(){
        CronTriggerFactoryBean stFactory = new CronTriggerFactoryBean();
        //設置JobDetail
        stFactory.setJobDetail(jobDetailFactoryBean().getObject());
        stFactory.setStartDelay(1000);
        stFactory.setName("calculateTrigger");
        stFactory.setGroup("calculateGroup");
        stFactory.setCronExpression(zKQuartzConfig.getCalculateTriggerCron());  //定時任務時間配置
        return stFactory;
    }
}    
AutowiringSpringBeanJobFactory類,這個類用來Quartz中的job自動注入spring容器托管的對象 【這個類直接復制用就行了,不用做任何修改
public final class AutowiringSpringBeanJobFactory extends SpringBeanJobFactory
        implements ApplicationContextAware {

    private transient AutowireCapableBeanFactory beanFactory;

  //Spring提供了一種機制讓你可以獲取ApplicationContext。就是ApplicationContextAware接口。
  //對於一個實現了ApplicationContextAware接口的類,Spring會實例化它的同時
  //調用它的public voidsetApplicationContext(ApplicationContext applicationContext) throws BeansException;接口,將該bean所屬上下文傳遞給它。 @Override
public void setApplicationContext(final ApplicationContext context) { beanFactory = context.getAutowireCapableBeanFactory(); } @Override protected Object createJobInstance(final TriggerFiredBundle bundle) throws Exception { final Object job = super.createJobInstance(bundle); beanFactory.autowireBean(job); return job; } }

Quartz中的job如何自動注入spring容器托管的對象  更多可以查看  http://ju.outofmemory.cn/entry/75776


QuartzConfig類 這個類用來設置配置 SchedulerFactoryBean
@Configuration
public class QuartzConfig {

    @Autowired
    @Qualifier("calculateTrigger")
    private CronTriggerFactoryBean calculateTrigger;
        //Quartz中的job自動注入spring容器托管的對象
    @Bean
    public AutowiringSpringBeanJobFactory autoWiringSpringBeanJobFactory() {
        return new AutowiringSpringBeanJobFactory();
    }

    @Bean
    public SchedulerFactoryBean schedulerFactoryBean() {
        SchedulerFactoryBean scheduler = new SchedulerFactoryBean();
        scheduler.setJobFactory(autoWiringSpringBeanJobFactory());  //配置Spring注入的Job類 固定不變
        scheduler.setTriggers(      //  SchedulerFactoryBean 中 必須設置 List<Trigger> triggers; 參數(triggers是個list容器) 對應方法 setTriggers(Trigger... triggers);
                calculateTrigger.getObject()
          ,tempTrigger.getObject()
         // ...  
);
//這里可以設置多個CronTriggerFactoryBean return scheduler; } }

 

Cron表達式的格式:秒 分 時 日 月 周 年(可選)。
字段名              允許的值                    允許的特殊字符 
秒                     0-59                           , - * / 
分                     0-59                           , - * / 
小時                  0-23                           , - * / 
日                     1-31                            , - * ? / L W C
月                     1-12 or JAN-DEC        , - * / 
周幾                  1-7 or SUN-SAT         , - * ? / L C # 
年(可選字段)     empty                         1970-2099 , - * /

 

字符含義:

:代表所有可能的值。因此,“*”在Month中表示每個月,在Day-of-Month中表示每天,在Hours表示每小時

:表示指定范圍。

:表示列出枚舉值。例如:在Minutes子表達式中,“5,20”表示在5分鍾和20分鍾觸發。

:被用於指定增量。例如:在Minutes子表達式中,“0/15”表示從0分鍾開始,每15分鍾執行一次。"3/20"表示從第三分鍾開始,每20分鍾執行一次。和"3,23,43"(表示第3,23,43分鍾觸發)的含義一樣。

:用在Day-of-Month和Day-of-Week中,指“沒有具體的值”。當兩個子表達式其中一個被指定了值以后,為了避免沖突,需要將另外一個的值設為“?”。例如:想在每月20日觸發調度,不管20號是星期幾,只能用如下寫法:0 0 0 20 * ?,其中最后以為只能用“?”,而不能用“*”。

L :用在day-of-month和day-of-week字串中。它是單詞“last”的縮寫。它在兩個子表達式中的含義是不同的。
在day-of-month中,“L”表示一個月的最后一天,一月31號,3月30號。
在day-of-week中,“L”表示一個星期的最后一天,也就是“7”或者“SAT”
如果“L”前有具體內容,它就有其他的含義了。例如:“6L”表示這個月的倒數第六天。“FRIL”表示這個月的最后一個星期五。
注意:在使用“L”參數時,不要指定列表或者范圍,這樣會出現問題。

W :“Weekday”的縮寫。只能用在day-of-month字段。用來描敘最接近指定天的工作日(周一到周五)。例如:在day-of-month字段用“15W”指“最接近這個月第15天的工作日”,即如果這個月第15天是周六,那么觸發器將會在這個月第14天即周五觸發;如果這個月第15天是周日,那么觸發器將會在這個月第 16天即周一觸發;如果這個月第15天是周二,那么就在觸發器這天觸發。注意一點:這個用法只會在當前月計算值,不會越過當前月。“W”字符僅能在 day-of-month指明一天,不能是一個范圍或列表。也可以用“LW”來指定這個月的最后一個工作日,即最后一個星期五。

# :只能用在day-of-week字段。用來指定這個月的第幾個周幾。例:在day-of-week字段用"6#3" or "FRI#3"指這個月第3個周五(6指周五,3指第3個)。如果指定的日期不存在,觸發器就不會觸發。

 

表達式例子:

0 * * * * ? 每1分鍾觸發一次
0 0 * * * ? 每天每1小時觸發一次
0 0 10 * * ? 每天10點觸發一次
0 * 14 * * ? 在每天下午2點到下午2:59期間的每1分鍾觸發 
0 30 9 1 * ? 每月1號上午9點半
0 15 10 15 * ? 每月15日上午10:15觸發

*/5 * * * * ? 每隔5秒執行一次
0 */1 * * * ? 每隔1分鍾執行一次
0 0 5-15 * * ? 每天5-15點整點觸發
0 0/3 * * * ? 每三分鍾觸發一次
0 0-5 14 * * ? 在每天下午2點到下午2:05期間的每1分鍾觸發 
0 0/5 14 * * ? 在每天下午2點到下午2:55期間的每5分鍾觸發
0 0/5 14,18 * * ? 在每天下午2點到2:55期間和下午6點到6:55期間的每5分鍾觸發
0 0/30 9-17 * * ? 朝九晚五工作時間內每半小時
0 0 10,14,16 * * ? 每天上午10點,下午2點,4點 

0 0 12 ? * WED 表示每個星期三中午12點
0 0 17 ? * TUES,THUR,SAT 每周二、四、六下午五點
0 10,44 14 ? 3 WED 每年三月的星期三的下午2:10和2:44觸發 
0 15 10 ? * MON-FRI 周一至周五的上午10:15觸發

0 0 23 L * ? 每月最后一天23點執行一次
0 15 10 L * ? 每月最后一日的上午10:15觸發 
0 15 10 ? * 6L 每月的最后一個星期五上午10:15觸發 

0 15 10 * * ? 2005 2005年的每天上午10:15觸發 
0 15 10 ? * 6L 2002-2005 2002年至2005年的每月的最后一個星期五上午10:15觸發 
0 15 10 ? * 6#3 每月的第三個星期五上午10:15觸發

 

以下是我自己看源碼時隨意記的筆記。請忽略(私人可見)

Quartz 配置使用關系網
  一 SchedulerFactoryBean 中 必須設置 List<Trigger> triggers; 參數(triggers是個list容器) 對應方法 setTriggers(Trigger... triggers);
  二 可以使用 CronTriggerBean類 或 CronTriggerFactoryBean類 實例triggers (這兩個類已經實現了Trigger接口)
    必須設置 JobDetail jobDetail; 對應方法 setJobDetail(JobDetail jobDetail), 因為JobDetail中 有Trigger接口中必須的 JobKey 參數
    必須設置 setCronExpression(String cronExpression); cronExpression就是定時任務時間配置 例如
  三 需要設置 JobDetail 實例了,我們會實現一個JobDetailFactoryBean類, 在這個類中必須賦值的有 jobClass 參數;對應方法 setJobClass(Class<?> jobClass);
    而jobClass就是定時任務的具體實現了
  四 編寫jobClass。寫個類 實現 org.quartz.Job 接口,重新execute()方法。定時需要執行的具體步驟放在這個方法里。

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM