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

时间:2021-05-19

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

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

任务介绍

  • Java自带的java.util.Timer类,这个类允许你调度一个java.util.TimerTask任务。Timer的优点在于简单易用;缺点是Timer的所有任务都是由同一个线程调度的,因此所有任务都是串行执行的。同一时间只能有一个任务在执行,前一个任务的延迟或异常都将会影响到之后的任务。这种实现已经被项目所废弃。
  • 开源集群任务框架Quartz,这是一个功能比较强大的的调度器,适合做任务集群,解决单点故障,目前项目中在使用。
  • 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();}

    项目:spring-boot-mail_jb51.rar

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

    声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。

    相关文章