详解SpringBoot开发案例之整合定时任务(Scheduled)

来来来小伙伴们，基于上篇的邮件服务，定时任务就不单独分项目了，天然整合进了邮件服务中。

不知道，大家在工作之中，经常会用到那些定时任务去执行特定的业务，这里列举一下我在工作中曾经使用到的几种实现。

任务介绍

1. java自带的java.util.timer类，这个类允许你调度一个java.util.timertask任务。timer的优点在于简单易用；缺点是timer的所有任务都是由同一个线程调度的，因此所有任务都是串行执行的。同一时间只能有一个任务在执行，前一个任务的延迟或异常都将会影响到之后的任务。这种实现已经被项目所废弃。
2. 开源集群任务框架quartz，这是一个功能比较强大的的调度器，适合做任务集群，解决单点故障，目前项目中在使用。
3. spring家族自带的scheduled，可以将它看成一个轻量级的quartz，而且使用起来比quartz简单许多，适用于简单的任务，微服务使用很方便。

项目应用

创建任务

代码中，可以发现，sendmail方法上注解被注释掉了，目前我们采用的是xml配置实现的。

import org.springframework.stereotype.component;
/**
 * 统计失败邮件定时重新发送
 * 创建时间 2017年7月21日
 *
 */
@component("sendmail")
public class sendmail {
 //@scheduled(cron = "0/5 * * * * ?")
 public void sendmail() {
  system.out.println("统计失败邮件定时重新发送开始");
 }
}

配置文件

 <!-- 配置任务线性池 -->
<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">
  <!-- 统计失败邮件定时重新发送 -->
  <task:scheduled ref="sendmail" method="sendmail" cron="0/5 * * * * ?"/> 
</task:scheduled-tasks>

启动项目

/**
 * 启动类
 * 创建时间 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打印”统计失败邮件定时重新发送开始”。当然scheduled的功能不仅仅如此，我们查找源码scheduled类，可以发现还有一些注解属性，这里就不一一为大家介绍了。总之，要养成查看源码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();
}

项目：

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。