詳解SpringBoot開發(fā)案例之整合定時任務(Scheduled)

更新時間：2017年07月21日 15:19:23 作者：小柒

本篇文章主要介紹了詳解SpringBoot開發(fā)案例之整合定時任務(Scheduled)，具有一定的參考價值，有興趣的可以了解一下

來來來小伙伴們，基于上篇的郵件服務，定時任務就不單獨分項目了，天然整合進了郵件服務中。

不知道，大家在工作之中，經(jīng)常會用到那些定時任務去執(zhí)行特定的業(yè)務，這里列舉一下我在工作中曾經(jīng)使用到的幾種實現(xiàn)。

任務介紹

Java自帶的java.util.Timer類，這個類允許你調度一個java.util.TimerTask任務。Timer的優(yōu)點在于簡單易用；缺點是Timer的所有任務都是由同一個線程調度的，因此所有任務都是串行執(zhí)行的。同一時間只能有一個任務在執(zhí)行，前一個任務的延遲或異常都將會影響到之后的任務。這種實現(xiàn)已經(jīng)被項目所廢棄。
開源集群任務框架Quartz，這是一個功能比較強大的的調度器，適合做任務集群，解決單點故障，目前項目中在使用。
Spring家族自帶的Scheduled，可以將它看成一個輕量級的Quartz，而且使用起來比Quartz簡單許多，適用于簡單的任務，微服務使用很方便。

項目應用

創(chuàng)建任務

代碼中，可以發(fā)現(xiàn)，sendMail方法上注解被注釋掉了，目前我們采用的是xml配置實現(xiàn)的。

import org.springframework.stereotype.Component;
/**
 * 統(tǒng)計失敗郵件定時重新發(fā)送
 * 創(chuàng)建時間 2017年7月21日
 *
 */
@Component("sendMail")
public class SendMail {
 //@Scheduled(cron = "0/5 * * * * ?")
 public void sendMail() {
  System.out.println("統(tǒng)計失敗郵件定時重新發(fā)送開始");
 }
}

配置文件

 <!-- 配置任務線性池 -->
<task:executor id="executor" pool-size="5" /> 
<task:scheduler id="scheduler" pool-size="5"/>
<!-- 啟用注解驅動的定時任務 -->
<task:annotation-driven executor="executor" scheduler="scheduler" proxy-target-class="true"/>
<task:scheduled-tasks scheduler="scheduler">
  <!-- 統(tǒng)計失敗郵件定時重新發(fā)送 -->
  <task:scheduled ref="sendMail" method="sendMail" cron="0/5 * * * * ?"/> 
</task:scheduled-tasks>

啟動項目

/**
 * 啟動類
 * 創(chuàng)建時間 2017年7月19日
 *
 */
@EnableAutoConfiguration
@ComponentScan(basePackages={"com.itstyle.main"})
@ImportResource({"classpath:spring-context-dubbo.xml","classpath:spring-context-task.xml"})
public class Application {
 private static final Logger logger = Logger.getLogger(Application.class);
 public static void main(String[] args) throws InterruptedException {
  SpringApplication.run(Application.class, args);
  logger.info("項目啟動 ");
 }
}

啟動后，控制臺會每5s打印”統(tǒng)計失敗郵件定時重新發(fā)送開始”。當然Scheduled的功能不僅僅如此，我們查找源碼Scheduled類，可以發(fā)現(xiàn)還有一些注解屬性，這里就不一一為大家介紹了。總之，要養(yǎng)成查看源碼API的習慣。

@Target({ java.lang.annotation.ElementType.METHOD,
  java.lang.annotation.ElementType.ANNOTATION_TYPE })
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Repeatable(Schedules.class)
public @interface Scheduled {
 public abstract String cron();
 public abstract String zone();
 public abstract long fixedDelay();
 public abstract String fixedDelayString();
 public abstract long fixedRate();
 public abstract String fixedRateString();
 public abstract long initialDelay();
 public abstract String initialDelayString();
}

項目：spring-boot-mail_jb51.rar

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: