Spring Boot 實(shí)現(xiàn)定時(shí)任務(wù)的4種方式

內(nèi)容參考來自"我是程序汪"公眾號(hào)一篇文章《Spring Boot 實(shí)現(xiàn)定時(shí)任務(wù)的 4 種方式》。如果原作者覺得此文章不得轉(zhuǎn)載,請(qǐng)聯(lián)系我,本人立即刪除。

定時(shí)任務(wù)實(shí)現(xiàn)的幾種方式:

Timer:這是java自帶的java.util.Timer類,這個(gè)類允許你調(diào)度一個(gè)java.util.TimerTask任務(wù)。使用這種方式可以讓你的程序按照某一個(gè)頻度執(zhí)行,但不能在指定時(shí)間運(yùn)行。一般用的較少。
ScheduledExecutorService:也jdk自帶的一個(gè)類;是基于線程池設(shè)計(jì)的定時(shí)任務(wù)類,每個(gè)調(diào)度任務(wù)都會(huì)分配到線程池中的一個(gè)線程去執(zhí)行,也就是說,任務(wù)是并發(fā)執(zhí)行,互不影響。
Spring Task:Spring3.0以后自帶的task,可以將它看成一個(gè)輕量級(jí)的Quartz,而且使用起來比Quartz簡單許多。
Quartz:這是一個(gè)功能比較強(qiáng)大的的調(diào)度器,可以讓你的程序在指定時(shí)間執(zhí)行,也可以按照某一個(gè)頻度執(zhí)行,配置起來稍顯復(fù)雜。

使用Timer

這個(gè)目前在項(xiàng)目中用的較少,直接貼demo代碼。具體的介紹可以查看api

public class TestTimer {

   public static void main(String[] args) {

       TimerTask timerTask = new TimerTask() {
           @Override
           public void run() {
               System.out.println("task  run:"+ new Date());
           }

       };

       Timer timer = new Timer();

       //安排指定的任務(wù)在指定的時(shí)間開始進(jìn)行重復(fù)的固定延遲執(zhí)行。這里是每3秒執(zhí)行一次
       timer.schedule(timerTask,10,3000);
   }

}

使用ScheduledExecutorService

該方法跟Timer類似,直接看demo:

public class TestScheduledExecutorService {

   public static void main(String[] args) {

       ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();

       // 參數(shù):1、任務(wù)體 2、首次執(zhí)行的延時(shí)時(shí)間
       //      3、任務(wù)執(zhí)行間隔 4、間隔時(shí)間單位
       service.scheduleAtFixedRate(()->System.out.println("task ScheduledExecutorService "+new Date()), 0, 3, TimeUnit.SECONDS);

   }

}

使用Spring Task

簡單的定時(shí)任務(wù)

創(chuàng)建任務(wù)類:


@Slf4j

@Component

public class ScheduledService {

   @Scheduled(cron = "0/5 * * * * *")
   public void scheduled(){
       log.info("=====>>>>>使用cron  {}",System.currentTimeMillis());
   }

   @Scheduled(fixedRate = 5000)
   public void scheduled1() {
       log.info("=====>>>>>使用fixedRate{}", System.currentTimeMillis());
   }

   @Scheduled(fixedDelay = 5000)
   public void scheduled2() {
       log.info("=====>>>>>fixedDelay{}",System.currentTimeMillis());
   }

}

然后在主類上使用@EnableScheduling注解開啟對(duì)定時(shí)任務(wù)的支持,然后啟動(dòng)項(xiàng)目即可運(yùn)行。

執(zhí)行時(shí)間的配置

在上面的定時(shí)任務(wù)中,我們?cè)诜椒ㄉ鲜褂聾Scheduled注解來設(shè)置任務(wù)的執(zhí)行時(shí)間,并且使用三種屬性配置方式:

fixedRate:定義一個(gè)按一定頻率執(zhí)行的定時(shí)任務(wù)

fixedDelay:定義一個(gè)按一定頻率執(zhí)行的定時(shí)任務(wù),與上面不同的是,改屬性可以配合initialDelay, 定義該任務(wù)延遲執(zhí)行時(shí)間。

cron:通過表達(dá)式來配置任務(wù)執(zhí)行時(shí)間
關(guān)于cron,可自行在網(wǎng)絡(luò)上查閱相關(guān)資料。或者直接通過 在線生成cron表達(dá)式

多線程執(zhí)行

當(dāng)然如果只有一個(gè)定時(shí)任務(wù),這樣做肯定沒問題,當(dāng)定時(shí)任務(wù)增多,如果一個(gè)任務(wù)卡死,會(huì)導(dǎo)致其他任務(wù)也無法執(zhí)行?;蛘呶覀円部梢杂枚嗑€程的方式執(zhí)行。
在傳統(tǒng)的Spring項(xiàng)目中,我們可以在xml配置文件添加task的配置,而在SpringBoot項(xiàng)目中一般使用java代碼配置類的方式添加配置,所以新建一個(gè)AsyncConfig類。

@Configuration
@EnableAsync
public class AsyncConfig {

    /*
     *此處成員變量應(yīng)該使用@Value從配置中讀取
    */
   private int corePoolSize = 10;
   private int maxPoolSize = 200;
   private int queueCapacity = 10;

   @Bean
   public Executor taskExecutor() {
       ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
       executor.setCorePoolSize(corePoolSize);
       executor.setMaxPoolSize(maxPoolSize);
       executor.setQueueCapacity(queueCapacity);
       executor.initialize();
       return executor;
   }

}

@Configuration:表明該類是一個(gè)配置類
@EnableAsync:開啟異步事件的支持
然后在定時(shí)任務(wù)的類或者方法上添加@Async 。最后重啟項(xiàng)目,每一個(gè)任務(wù)都是在不同的線程中。

整合Quartz

添加依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

創(chuàng)建任務(wù)類TestQuartz,該類主要是繼承了QuartzJobBean

public class TestQuartz extends QuartzJobBean {

    /**
     * 執(zhí)行定時(shí)任務(wù)
     * @param jobExecutionContext
     * @throws JobExecutionException
     */

    @Override
    protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {

        System.out.println("quartz task "+new Date());

    }

}

創(chuàng)建配置類QuartzConfig

@Configuration
public class QuartzConfig {

    @Bean
    public JobDetail teatQuartzDetail(){

        return JobBuilder.newJob(TestQuartz.class).withIdentity("testQuartz").storeDurably().build();

    }

    @Bean
    public Trigger testQuartzTrigger(){

        SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()
                .withIntervalInSeconds(10)  //設(shè)置時(shí)間周期單位秒
                .repeatForever();
        return TriggerBuilder.newTrigger().forJob(teatQuartzDetail())

                .withIdentity("testQuartz")
                .withSchedule(scheduleBuilder)
                .build();

    }

}

上面都是簡單的介紹了關(guān)于SpringBoot定時(shí)任務(wù)的處理,直接使用SpringTask注解的方式應(yīng)該是最方便的,而使用Quartz從2.0開始也變得很方便。對(duì)于這兩種方式,應(yīng)該說各有長處吧,按需選擇。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容