1.定時(shí)任務(wù)注解

在springboot啟動(dòng)器開啟定時(shí)任務(wù)注解

這里的 @EnableScheduling 注解，它的作用是發(fā)現(xiàn)注解 @Scheduled的任務(wù)并由后臺(tái)執(zhí)行。沒有它的話將無法執(zhí)行定時(shí)任務(wù)。

2.使用的@Scheduled 注解

2.1 @Scheduled 的常用配置項(xiàng)

@Scheduled(fixedRate=2000)：上一次開始執(zhí)行時(shí)間點(diǎn)后2秒再次執(zhí)行，無論上一個(gè)任務(wù)是否執(zhí)行完過2s就開始下一個(gè)任務(wù)；

@Scheduled(fixedDelay=2000)：上一次執(zhí)行完畢時(shí)間點(diǎn)后2秒再次執(zhí)行，上一個(gè)任務(wù)執(zhí)行完后過2s 才執(zhí)行下個(gè)任務(wù)；

@Scheduled(initialDelay=1000, fixedDelay=2000)：第一次延遲1秒執(zhí)行， 然后在上一次執(zhí)行完畢時(shí)間點(diǎn)后2秒再次執(zhí)行；

@Scheduled(cron=“* * * * * ?”)：按cron規(guī)則執(zhí)行。 在線Cron表達(dá)式生成器：//cron.qqe2.com/介紹

3.實(shí)戰(zhàn)

3.1 @Scheduled 多線程并發(fā)執(zhí)行

@Scheduled 默認(rèn)是使用單線程執(zhí)行所有任務(wù)的。

1）驗(yàn)證：

編寫多個(gè)@Scheduled 任務(wù)且設(shè)置執(zhí)行時(shí)間和時(shí)間間隔都相同。

@Component
public class AnnotationSchedulTask {
    private static final Logger LOG = LoggerFactory.getLogger(AnnotationSchedulTask.class);
    private int count=0;
    
    @Scheduled(cron = "0/2 * * * * ? ")
    public  void test(){
        //0/1 第一次運(yùn)行間隔0s，每次間隔1s運(yùn)行一次
        LOG.info("SchedulTask run count:"+count++);
    }
    
    /**
     * 測(cè)試@Scheduled 默認(rèn)是否是單線程運(yùn)行
     */
    @Scheduled(cron = "0/2 * * * * ? ")
    public  void testConcurrence(){
        LOG.info("*********testConcurrence run**************");
    }

    /**
     * 測(cè)試@Scheduled 默認(rèn)是否是單線程運(yùn)行
     */
    @Scheduled(cron = "0/2 * * * * ? ")
    public  void testConcurrence2(){
        LOG.info("--------testConcurrence2-----------");
    }
    
}

啟動(dòng)服務(wù)運(yùn)行結(jié)果：

可以看到所有任務(wù)都被 scheduling-1 線程執(zhí)行

原因：

從ScheduledAnnotationBeanPostProcessor類開始一路找下去，在ScheduledTaskRegistrar（定時(shí)任務(wù)注冊(cè)類）中的ScheduleTasks中又這樣一段判斷：

if (this.taskScheduler == null) {
 this.localExecutor = Executors.newSingleThreadScheduledExecutor();
 this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor);
}

當(dāng)this.taskScheduler 為null 時(shí) Executors.newSingleThreadScheduledExecutor(); 單個(gè)線程的線程池。

2）擴(kuò)展多線程

其實(shí)只要設(shè)置一個(gè)我們自定義的this.taskScheduler

方法一： 配置一個(gè)ScheduledExecutorService bean即可設(shè)置

 /**
     * 執(zhí)行周期性或定時(shí)任務(wù)
     */
    @Bean(name = "scheduledExecutorService")
    protected ScheduledExecutorService scheduledExecutorService()
    {
        return new ScheduledThreadPoolExecutor(corePoolSize,
                new BasicThreadFactory.Builder().namingPattern("MySchedule-pool-%d").daemon(true).build(),
                new ThreadPoolExecutor.CallerRunsPolicy())
        {
            @Override
            protected void afterExecute(Runnable r, Throwable t)
            {
                super.afterExecute(r, t);
                if (t == null && r instanceof Future<?>)
                {
                    try
                    {
                        Future<?> future = (Future<?>) r;
                        if (future.isDone())
                        {
                            future.get();
                        }
                    }
                    catch (CancellationException ce)
                    {
                        t = ce;
                    }
                    catch (ExecutionException ee)
                    {
                        t = ee.getCause();
                    }
                    catch (InterruptedException ie)
                    {
                        Thread.currentThread().interrupt();
                    }
                }
                if (t != null)
                {
                    log.error(t.getMessage(), t);
                }
            }
        };
    }

執(zhí)行結(jié)果：

可以看到現(xiàn)在@Scheduled 由不同線程執(zhí)行。

原理：

ScheduledAnnotationBeanPostProcessor 類的finishRegistration方法

最終在 this.registrar.setScheduler(resolveSchedulerBean(this.beanFactory, ScheduledExecutorService.class, false));

這一行 我們自定義的ScheduledExecutorService bean被當(dāng)作執(zhí)行的線程池。

方法2:

@Configurationpublic class ScheduleConfig implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { taskRegistrar.setScheduler( new ScheduledThreadPoolExecutor(8, new BasicThreadFactory.Builder().namingPattern("taskRegistrar-pool-%d").daemon(true).build(), new ThreadPoolExecutor.CallerRunsPolicy())); }}

運(yùn)行結(jié)果：

可以看出來也成功了，并且覆蓋了我們之前設(shè)置的ScheduledExecutorService。

3.2 cron 表達(dá)式實(shí)現(xiàn)指定時(shí)間執(zhí)行任務(wù)

1）cron 表達(dá)式詳細(xì)介紹：

• 域 必填 允許值 允許的通配符
• 秒（seconds） 是 0-59整數(shù) , - * /
• 分（minutes） 是 0-59整數(shù) , - * /
• 時(shí)（hours） 是 0-23整數(shù) , - * /
• 日（daysOfMonth） 是 1-31整數(shù)（需要考慮月的天數(shù)） , - * ? / L W
• 月（months） 是 1-12整數(shù) 或 JAN-DEC , - * /
• 周 （daysOfWeek） 是 1-7整數(shù) 或 SUN-SAT , - * ? / L #

通配符說明：

• *：表示匹配該域的任意值。在minutes域使用 * 表示每分鐘。在months里表示每個(gè)月。在daysOfWeek域表示一周的每一天。
• ?：只能用在daysofMonth和daysofWeek兩個(gè)域，表示不指定值，當(dāng)兩個(gè)子表達(dá)式其中之一被指定了值以后，為了避免沖突，需要將另一個(gè)子表達(dá)式的值設(shè)為 ？。因?yàn)閐aysofMonth和daysofWeek會(huì)相互影響。例如想在每月的2號(hào)觸發(fā)調(diào)度，不管2號(hào)是周幾，則只能使用如下寫法：0 0 0 2 * ?, 其中最后一位只能用?，而不能使用*，如果使用*表示不管周幾都會(huì)觸發(fā)。
• -：表示范圍。例如在minutes域使用5-20，表示從5分到20分鐘每分鐘觸發(fā)一次
• /：表示起始時(shí)間開始觸發(fā)，然后每隔固定時(shí)間觸發(fā)一次。例如在minutes域使用5/20，則意味著從當(dāng)前小時(shí)的第5分鐘開每20分鐘觸發(fā)一次。
• ,：表示列出枚舉值。例如：在minutes域使用5,20，則意味著在5分和20分時(shí)各觸發(fā)一次。
• L：表示最后，是單詞“last”的縮寫，只能出現(xiàn)在daysofWeek和dayofMonth域。在daysofWeek域使用5L意思是在指定月的最后的一個(gè)星期四觸發(fā)。在dayofMonth域使用5L或者FRIL意思是在指定月的倒數(shù)第5天觸發(fā)。在使用L參數(shù)時(shí)，不要指定列表或范圍。
• W：表示有效工作日(周一到周五),只能出現(xiàn)在daysofMonth域，系統(tǒng)將在離指定日期的最近的有效工作日觸發(fā)事件。例如：在daysofMonth使用5W，如果5號(hào)是周六，則將在最近的工作日周五，即4號(hào)觸發(fā)。如果5號(hào)是周日，則在6日(周一)觸發(fā)。如果5日在星期一到星期五中的一天，則就在5日觸發(fā)。另外，W的最近尋找不會(huì)跨過月份 。
• LW：這兩個(gè)字符可以連用，表示指定月的最后一個(gè)工作日。
• #：用于確定每個(gè)月第幾個(gè)周幾，只能出現(xiàn)在daysOfWeek域。例如在4#2，表示某月的第二個(gè)周三。

常用表達(dá)式示例：

• 0/2 * * * * ? 表示每2秒 執(zhí)行任務(wù)
• 0 0/2 * * * ? 表示每2分鐘 執(zhí)行任務(wù)
• 0 0 2 1 * ? 表示在每月的1日的凌晨2點(diǎn)調(diào)整任務(wù)
• 0 15 10 ? * MON-FRI 表示周一到周五每天上午10:15執(zhí)行作業(yè)
• 0 0 10,14,16 * * ? 每天上午10點(diǎn)，下午2點(diǎn)，4點(diǎn)
• 0 0/30 9-17 * * ? 朝九晚五工作時(shí)間內(nèi)每半小時(shí)
• 0 0 12 ? * WED 表示每個(gè)星期三中午12點(diǎn)
• 0 0 12 * * ? 每天中午12點(diǎn)觸發(fā)
• 0 15 10 ? * * 每天上午10:15觸發(fā)
• 0 15 10 * * ? 每天上午10:15觸發(fā)
• 0 15 10 * * ? 每天上午10:15觸發(fā)
• 0 * 14 * * ? 在每天下午2點(diǎn)到下午2:59期間的每1分鐘觸發(fā)
• 0 0/5 14 * * ? 在每天下午2點(diǎn)到下午2:55期間的每5分鐘觸發(fā)
• 0 0/5 14,18 * * ? 在每天下午2點(diǎn)到2:55期間和下午6點(diǎn)到6:55期間的每5分鐘觸發(fā)
• 0 0-5 14 * * ? 在每天下午2點(diǎn)到下午2:05期間的每1分鐘觸發(fā)
• 0 10,44 14 ? 3 WED 每年三月的星期三的下午2:10和2:44觸發(fā)
• 0 15 10 ? * MON-WED,SAT 周一至周三和周六的上午10:15觸發(fā)
• 0 15 10 15 * ? 每月15日上午10:15觸發(fā)
• 0 15 10 L * ? 每月最后一日的上午10:15觸發(fā)
• 0 15 10 ? * 6L 每月的最后一個(gè)星期五上午10:15觸發(fā)
• 0 15 10 ? * 6#3 每月的第三個(gè)星期五上午10:15觸發(fā)

2）設(shè)置每天固定時(shí)間執(zhí)行

    //測(cè)試每天下午兩點(diǎn)執(zhí)行
    @Scheduled(cron = "0 0 14 * * ? ")
    public  void testCron2(){
        LOG.info("*********testCron2 run**************");
    }

結(jié)果：

在下午兩點(diǎn)被執(zhí)行

14:00:00.005 [taskRegistrar-pool-1] INFO  c.e.s.api.task.AnnotationSchedulTask
 *********testCron2 run**************

3）設(shè)定沒1分鐘執(zhí)行一次

   //測(cè)試每分鐘執(zhí)行一次
    @Scheduled(cron = "0 0/1 * * * ? ")
    public  void testFixedDelay(){
        LOG.info("*********testFixedDelay run**************");
    }

結(jié)果：

每分鐘執(zhí)行一次

4)設(shè)定每月幾號(hào)執(zhí)行一次

必須指定執(zhí)行時(shí)間不然當(dāng)天每分鐘都會(huì)被執(zhí)行一次。

  //設(shè)定每月幾號(hào)執(zhí)行一次
    @Scheduled(cron = "0 14 14 3 * ? ")
    public  void testFixedDay(){
        LOG.info("*********testFixedDay run**************");
    }

結(jié)果：

在 3號(hào)的 14.14 被執(zhí)行。

到此這篇關(guān)于SpringBoot中定時(shí)任務(wù)的使用方法解析的文章就介紹到這了,更多相關(guān)SpringBoot定時(shí)任務(wù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論