SpringBoot定时任务及Cron表达式详解_springboot cron 定时任务时间点-程序员宅基地

0.SpringBoot定时任务及Cron表达式详解

2017年12月25日 14:01:02 fujiawei3710 阅读数:2364更多

个人分类: springBoot从零开始

一、定时任务概述

    后台项目开发中经常会用到定时任务,现在实现定时任务都方式也是多种多样。下面列举几种常见的定时任务实现方式:

    1. Quartz:Quartz的使用相当广泛,它是一个功能强大的调度器,当然使用起来也相对麻烦;

    2. java.util包里的Timer,它也可以实现定时任务但是功能过于单一所有使用很少。

    3. 就是我们今天要介绍的Spring自带的定时任务Schedule,其实可以把它看作是一个简化版的,轻量级的Quartz,使用起来也相对方便很多。

二、实现定时任务

1. 创建定时任务

 
  1. import org.slf4j.Logger;

  2. import org.slf4j.LoggerFactory;

  3. import org.springframework.scheduling.annotation.Scheduled;

  4. import org.springframework.stereotype.Component;

  5.  
  6. /**

  7. * Description: 构建执行定时任务www.fhadmin.org

  8. * Designer: jack

  9. * Date: 2017/8/10

  10. * Version: 1.0.0

  11. */

  12. @Component

  13. public class ScheduledTasks {

  14.  
  15. private Logger logger = LoggerFactory.getLogger(ScheduledTasks.class);

  16.  
  17. private int fixedDelayCount = 1;

  18. private int fixedRateCount = 1;

  19. private int initialDelayCount = 1;

  20. private int cronCount = 1;

  21.  
  22. @Scheduled(fixedDelay = 5000) //fixedDelay = 5000表示当前方法执行完毕5000ms后,Spring scheduling会再次调用该方法

  23. public void testFixDelay() {

  24. logger.info("===fixedDelay: 第{}次执行方法", fixedDelayCount++);

  25. }

  26.  
  27. @Scheduled(fixedRate = 5000) //fixedRate = 5000表示当前方法开始执行5000ms后,Spring scheduling会再次调用该方法

  28. public void testFixedRate() {

  29. logger.info("===fixedRate: 第{}次执行方法", fixedRateCount++);

  30. }

  31.  
  32. @Scheduled(initialDelay = 1000, fixedRate = 5000) //initialDelay = 1000表示延迟1000ms执行第一次任务

  33. public void testInitialDelay() {

  34. logger.info("===initialDelay: 第{}次执行方法", initialDelayCount++);

  35. }

  36.  
  37. @Scheduled(cron = "0 0/1 * * * ?") //cron接受cron表达式,根据cron表达式确定定时规则

  38. public void testCron() {

  39. logger.info("===initialDelay: 第{}次执行方法", cronCount++);

  40. }

  41.  
  42. }

    我们使用@Scheduled来创建定时任务 这个注解用来标注一个定时任务方法。官网:www.fhadmin.org 通过看@Scheduled源码可以看出它支持多种参数:

    (1)cron:cron表达式,指定任务在特定时间执行;

    (2)fixedDelay:表示上一次任务执行完成后多久再次执行,参数类型为long,单位ms;

    (3)fixedDelayString:与fixedDelay含义一样,只是参数类型变为String;

    (4)fixedRate:表示按一定的频率执行任务,参数类型为long,单位ms;

    (5)fixedRateString: 与fixedRate的含义一样,只是将参数类型变为String;

    (6)initialDelay:表示延迟多久再第一次执行任务,参数类型为long,单位ms;

    (7)initialDelayString:与initialDelay的含义一样,只是将参数类型变为String;

    (8)zone:时区,默认为当前时区,一般没有用到。

2.开启定时任务

 
  1. import org.springframework.boot.SpringApplication;

  2. import org.springframework.boot.autoconfigure.SpringBootApplication;

  3. import org.springframework.scheduling.annotation.EnableScheduling;

  4.  
  5. /**

  6. * Description: 启动类 官网:www.fhadmin.org

  7. * Designer: jack

  8. * Date: 2017/8/10

  9. * Version: 1.0.0

  10. */

  11. @SpringBootApplication

  12. @EnableScheduling

  13. public class Application {

  14. public static void main(String[] args) {

  15. SpringApplication.run(Application.class, args);

  16. }

  17. }

    注意这里的 @EnableScheduling 注解,它的作用是发现注解@Scheduled的任务并由后台执行。没有它的话将无法执行定时任务。

引用官方文档原文:

@EnableScheduling ensures that a background task executor is created. Without it, nothing gets scheduled.

3. 执行结果 (单线程)

    到此我们就完成了一个简单的定时任务模型,下面执行springBoot观察执行结果。

 
  1. 2017-08-11 12:06:19.738 INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks : ===initialDelay: 第1次执行方法

  2. 2017-08-11 12:06:23.739 INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks : ===fixedRate: 第2次执行方法

  3. 2017-08-11 12:06:23.739 INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks : ===fixedDelay: 第2次执行方法

  4. 2017-08-11 12:06:24.738 INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks : ===initialDelay: 第2次执行方法

  5. 2017-08-11 12:06:28.739 INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks : ===fixedRate: 第3次执行方法

  6. 2017-08-11 12:06:28.740 INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks : ===fixedDelay: 第3次执行方法

  7. 2017-08-11 12:06:29.739 INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks : ===initialDelay: 第3次执行方法

  8. 2017-08-11 12:06:33.735 INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks : ===fixedRate: 第4次执行方法

  9. 2017-08-11 12:06:33.741 INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks : ===fixedDelay: 第4次执行方法

  10. 2017-08-11 12:06:34.738 INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks : ===initialDelay: 第4次执行方法

    从控制台输入的结果中我们可以看出所有的定时任务都是在同一个线程池用同一个线程来处理的,那么我们如何来并发的处理各定时任务呢,请继续向下看。

4. 多线程处理定时任务

    看到控制台输出的结果,所有的定时任务都是通过一个线程来处理的,我估计是在定时任务的配置中设定了一个SingleThreadScheduledExecutor,于是我看了源码,从ScheduledAnnotationBeanPostProcessor类开始一路找下去。果然,在ScheduledTaskRegistrar(定时任务注册类)中的ScheduleTasks中又这样一段判断:

 
  1. if (this.taskScheduler == null) {

  2. this.localExecutor = Executors.newSingleThreadScheduledExecutor();

  3. this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor);

  4. }

    这就说明如果taskScheduler为空,那么就给定时任务做了一个单线程的线程池,正好在这个类中还有一个设置taskScheduler的方法:

 
  1. public void setScheduler(Object scheduler) {

  2. Assert.notNull(scheduler, "Scheduler object must not be null");

  3. if (scheduler instanceof TaskScheduler) {

  4. this.taskScheduler = (TaskScheduler) scheduler;

  5. }

  6. else if (scheduler instanceof ScheduledExecutorService) {

  7. this.taskScheduler = new ConcurrentTaskScheduler(((ScheduledExecutorService) scheduler));

  8. }

  9. else {

  10. throw new IllegalArgumentException("Unsupported scheduler type: " + scheduler.getClass());

  11. }

  12. }

    这样问题就很简单了,我们只需用调用这个方法显式的设置一个ScheduledExecutorService就可以达到并发的效果了。我们要做的仅仅是实现SchedulingConfigurer接口,重写configureTasks方法就OK了;

 
  1. import org.springframework.context.annotation.Configuration;

  2. import org.springframework.scheduling.annotation.SchedulingConfigurer;

  3. import org.springframework.scheduling.config.ScheduledTaskRegistrar;

  4.  
  5. import java.util.concurrent.Executors;

  6.  
  7. /**

  8. * Description: 多线程执行定时任务 官网:www.fhadmin.org

  9. * Designer: jack

  10. * Date: 2017/8/10

  11. * Version: 1.0.0

  12. */

  13. @Configuration

  14. //所有的定时任务都放在一个线程池中,定时任务启动时使用不同都线程。

  15. public class ScheduleConfig implements SchedulingConfigurer {

  16. @Override

  17. public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {

  18. //设定一个长度10的定时任务线程池

  19. taskRegistrar.setScheduler(Executors.newScheduledThreadPool(10));

  20. }

  21. }

    注: 最开始我试图在ScheduledAnnotationBeanPostProcessor类中做文章,因为里面也有一个类似的方法setScheduler(),但是最后失败了,不知道是否可以通过这个类实现定时任务的并发,如果有实现了的也请告诉大家一下方法。

5. 执行结果(并发)

 
  1. 2017-08-11 12:21:16.000 INFO 52284 --- [pool-1-thread-3] com.test.ScheduledTasks : ===initialDelay: 第1次执行方法

  2. 2017-08-11 12:21:19.998 INFO 52284 --- [pool-1-thread-4] com.test.ScheduledTasks : ===fixedRate: 第2次执行方法

  3. 2017-08-11 12:21:19.998 INFO 52284 --- [pool-1-thread-1] com.test.ScheduledTasks : ===fixedDelay: 第2次执行方法

  4. 2017-08-11 12:21:20.999 INFO 52284 --- [pool-1-thread-4] com.test.ScheduledTasks : ===initialDelay: 第2次执行方法

  5. 2017-08-11 12:21:25.000 INFO 52284 --- [pool-1-thread-2] com.test.ScheduledTasks : ===fixedRate: 第3次执行方法

  6. 2017-08-11 12:21:25.000 INFO 52284 --- [pool-1-thread-6] com.test.ScheduledTasks : ===fixedDelay: 第3次执行方法

  7. 2017-08-11 12:21:25.997 INFO 52284 --- [pool-1-thread-3] com.test.ScheduledTasks : ===initialDelay: 第3次执行方法

  8. 2017-08-11 12:21:30.000 INFO 52284 --- [pool-1-thread-7] com.test.ScheduledTasks : ===fixedRate: 第4次执行方法

  9. 2017-08-11 12:21:30.000 INFO 52284 --- [pool-1-thread-8] com.test.ScheduledTasks : ===fixedDelay: 第4次执行方法

  10. 2017-08-11 12:21:31.000 INFO 52284 --- [pool-1-thread-7] com.test.ScheduledTasks : ===initialDelay: 第4次执行方法

通过控制台输出的结果看出每个定时任务都是在通过不同的线程来处理了。

三、cron详解

1. cron表达式定义

    Cron表达式是一个字符串,是由空格隔开的6或7个域组成,每一个域对应一个含义(秒 分 时 每月第几天 月 星期 年)其中年是可选字段。

    但是,此处敲一下黑板,spring的schedule值支持6个域的表达式,也就是不能设定年,如果超过六个则会报错。源码如下:

 
  1. /**

  2. * Parse the given pattern expression.

  3. */

  4. private void parse(String expression) throws IllegalArgumentException {

  5. String[] fields = StringUtils.tokenizeToStringArray(expression, " ");

  6. if (!areValidCronFields(fields)) {

  7. throw new IllegalArgumentException(String.format(

  8. "Cron expression must consist of 6 fields (found %d in \"%s\")", fields.length, expression));

  9. }

  10. setNumberHits(this.seconds, fields[0], 0, 60);

  11. setNumberHits(this.minutes, fields[1], 0, 60);

  12. setNumberHits(this.hours, fields[2], 0, 24);

  13. setDaysOfMonth(this.daysOfMonth, fields[3]);

  14. setMonths(this.months, fields[4]);

  15. setDays(this.daysOfWeek, replaceOrdinals(fields[5], "SUN,MON,TUE,WED,THU,FRI,SAT"), 8);

  16. if (this.daysOfWeek.get(7)) {

  17. // Sunday can be represented as 0 or 7

  18. this.daysOfWeek.set(0);

  19. this.daysOfWeek.clear(7);

  20. }

  21. }

  22.  
  23. private static boolean areValidCronFields(String[] fields) {

  24. return (fields != null && fields.length == 6);

  25. }

2. 每个域可出现的字符类型和各字符的含义

(1)各域支持的字符类型

    秒:可出现", - * /"四个字符,有效范围为0-59的整数  

    分:可出现", - * /"四个字符,有效范围为0-59的整数  

    时:可出现", - * /"四个字符,有效范围为0-23的整数  

    每月第几天:可出现", - * / ? L W C"八个字符,有效范围为0-31的整数  

    月:可出现", - * /"四个字符,有效范围为1-12的整数或JAN-DEc  

    星期:可出现", - * / ? L C #"四个字符,有效范围为1-7的整数或SUN-SAT两个范围。1表示星期天,2表示星期一, 依次类推

(2)特殊字符含义

    * : 表示匹配该域的任意值,比如在秒*, 就表示每秒都会触发事件。;

    ? : 只能用在每月第几天和星期两个域。表示不指定值,当2个子表达式其中之一被指定了值以后,为了避免冲突,需要将另一个子表达式的值设为“?”;

    - : 表示范围,例如在分域使用5-20,表示从5分到20分钟每分钟触发一次  

    / : 表示起始时间开始触发,然后每隔固定时间触发一次,例如在分域使用5/20,则意味着5分,25分,45分,分别触发一次.  

    , : 表示列出枚举值。例如:在分域使用5,20,则意味着在5和20分时触发一次。  

    L : 表示最后,只能出现在星期和每月第几天域,如果在星期域使用1L,意味着在最后的一个星期日触发。  

    W : 表示有效工作日(周一到周五),只能出现在每月第几日域,系统将在离指定日期的最近的有效工作日触发事件。注意一点,W的最近寻找不会跨过月份  

    LW : 这两个字符可以连用,表示在某个月最后一个工作日,即最后一个星期五。  

    # : 用于确定每个月第几个星期几,只能出现在每月第几天域。例如在1#3,表示某月的第三个星期日。

(3)表达式例子

    引用spring官方注释:


 * <p>Example patterns:
 * <ul>
 * <li>"0 0 * * * *" = the top of every hour of every day.</li>
 * <li>"*&#47;10 * * * * *" = every ten seconds.</li>
 * <li>"0 0 8-10 * * *" = 8, 9 and 10 o'clock of every day.</li>
 * <li>"0 0/30 8-10 * * *" = 8:00, 8:30, 9:00, 9:30 and 10 o'clock every day.</li>
 * <li>"0 0 9-17 * * MON-FRI" = on the hour nine-to-five weekdays</li>
 * <li>"0 0 0 25 12 ?" = every Christmas Day at midnight</li>

    "0 0 * * * *"                      表示每小时0分0秒执行一次

    " */10 * * * * *"                 表示每10秒执行一次

    "0 0 8-10 * * *"                 表示每天8,9,10点执行

    "0 0/30 8-10 * * *"            表示每天8点到10点,每半小时执行

    "0 0 9-17 * * MON-FRI"     表示每周一至周五,9点到17点的0分0秒执行

    "0 0 0 25 12 ?"                  表示每年圣诞节(12月25日)0时0分0秒执行

 

 

文章出自:http://blog.csdn.net/ninifengs/article/details/77141240

 

 

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/f45056231p/article/details/88897926

智能推荐

Java以指定分隔符(逗号)拼接list_java list<list<string>>用逗号合并多个list-程序员宅基地

文章浏览阅读1.1w次。1.添加maven依赖&lt;!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 --&gt;&lt;dependency&gt; &lt;groupId&gt;org.apache.commons&lt;/groupId&gt; &lt;artifactId&gt;commons-l..._java list>用逗号合并多个list

unity连接sqlserver数据库发布后不能连接_unity的net 4.8的连接不sql了数据库-程序员宅基地

文章浏览阅读727次。前两天在用unity直连sqlserver数据库的时候遇到了发布后不能连接的问题,最后在unity Answers上找到了方法,这里分享给还不知道的朋友,其实unity已经提供了很多实用的dll文件,连接sqlserver最主要的System.data.dll文件可以在C:\Program Files (x86)\Unity\Editor\Data\Mono\lib\mono\unity这个目_unity的net 4.8的连接不sql了数据库

Unity_实现背景循环滚动_spine unity 背景循环-程序员宅基地

文章浏览阅读5.3k次。Unity_实现背景循环滚动1.创建一个工程,命名为roll2.向场景中添加一个立方体(右键-&gt;3D Object-&gt;Cube),命名为Background。并把它置于(0,0,0)处,把立方体缩放为(15,15,0.1)3.在Project视图中创建一个名为Textures的新文件夹。找到一个图片,我用的是小丸子xiaowanzi.png,把图片拖到Textures文件夹..._spine unity 背景循环

时域卷积,频域相乘-程序员宅基地

文章浏览阅读2.5w次,点赞8次,收藏51次。Fourier Transform有两个时域函数 g(t)g(t)g(t) 和 h(t)h(t)h(t), 则两者卷积后的函数 p(t)p(t)p(t) 可写作p(t)=g(t)∗h(t)=∫−∞∞g(τ)h(t−τ)dτp(t)=g(t)\ast h(t)=\int_{-\infty}^\infty g(\tau)h(t-\tau)d\taup(t)=g(t)∗h(t)=∫−∞∞​g(τ)h...

语音识别:时间序列的动态扭曲相似度(DTW)算法-程序员宅基地

文章浏览阅读1.1w次,点赞2次,收藏31次。在时间序列分析中,动态时间扭曲 (DTW) 是一种用于测量两个时间序列之间相似性的算法,这两个时间序列的速度可能不同。例如,即使一个人走得比另一个人快,或者在观察过程中出现加速和减速,也可以使用 DTW 检测步行的相似性。 DTW 已应用于视频、音频和图形数据的时间序列——实际上,任何可以转换为线性序列的数据都可以使用 DTW 进行分析。一个众所周知的应用是自动语音识别,以应对不同的语速。其他应用包括说话人识别和在线签名识别。它还可以用于部分形状匹配应用。一般来说,......_dtw

py4j.java gateway,为什么不能PySpark找到py4j.java_gateway?-程序员宅基地

文章浏览阅读162次。I installed Spark, ran the sbt assembly, and can open bin/pyspark with no problem. However, I am running into problems loading the pyspark module into ipython. I'm getting the following error:In [1]: ..._"you are trying to pass an insecure py4j gateway to spark. this\" 195 \" is no"

随便推点

鸿蒙车载智慧屏评测,搭载鸿蒙系统的荣耀智慧屏值得入手吗?荣耀智慧屏全面评测...-程序员宅基地

文章浏览阅读296次。下面是荣耀智慧屏升降式AI摄像头的开启过程,当我们开启视频通话功能时,摄像头就会快速地自动升起,而画面内容也会很快呈现。当然,与传统的智能电视搭配的外接式摄像头相比,荣耀智慧屏搭载的升降式AI摄像头尺寸更小巧,且拥有更好的隐藏性,不使用时更不会影响智慧屏整体的美观性,对于家庭场景来说更加优雅。联控智能家居在荣耀智慧屏的功能升级方面,联控智能家居无疑是未来的主流趋势,而将智能家居与智慧屏的结合则也是..._鸿蒙h8智慧屏

autojs编写的网易云音乐和视频搜索脚本源代码免费分享开源_autojs歌曲脚本大全-程序员宅基地

文章浏览阅读5k次。说明本文提供的代码仅供参考。不建议用于生产环境。可能有些地方在最新版本的Auto.js上面需要做修改,才能运行。Auto.js简介Auto.js是利用安卓系统的“辅助功能”实现类似于按键精灵一样,可以通过代码模拟一系列界面动作的辅助工作。与“按键精灵”不同的是,它的模拟动作并不是简单的使用在界面定坐标点来实现,而是类似与win一般,找窗口句柄来实现的。Auto.js使用JavaScri..._autojs歌曲脚本大全

java utf-8中文乱码的四种解决方案_java.lang.exception: encodecontent = null,charset -程序员宅基地

文章浏览阅读3.6w次。1.在html首部编写如下代码:&lt;%@ page language="java" contentType="text/html; charset=utf-8" pageEncoding="utf-8"%&gt; 示例如下:&lt;%@ page language="java" contentType="text/html; charset=utf-8" pag_java.lang.exception: encodecontent = null,charset = utf-8 chsiencrypt.decryp

地理空间的简单定义_地理空间定义-程序员宅基地

文章浏览阅读2.1k次。一般指经过投影变换,在笛卡尔坐标系下表示的地球表面特征空间。地理世界以实体进行单位组织,每个实体具有时间,空间,和实体自身属性和其它对象关联关系属性。绝对空间表示对象在世界坐标系下的实际位置。而相对空间主要描述不同实体之间的空间位置关系。 特征实体:{形状,属性,时序信息} 地理信息系统处理的是离散的数据,系统主要对分对地理空间信息进行分析和可视化两部分。可视化部分主要用到图形学,而分析主要用到_地理空间定义

S5700 端口镜像的配置-程序员宅基地

文章浏览阅读357次。华为S5700交换机配置怎么端口镜像?7分步阅读一键约师傅百度师傅最快的到家服务,最优质的电脑清灰目的:如果我们要对交换机下面的数据流量进行抓包的话;那么就需要在交换机上配置镜像端口;也就是说24端口镜像了23端口的所有数据;然后你吧电脑接在24端口上就能抓包到23端口的所有数据;下面我们就用华为S5700交换机来演示如何配置端口镜像工具/原料华为交换机一台电脑一台方法/步骤..._s5700配置镜像端口

【在线仿真】Arduino WS2812b环形24颗霓虹灯动态效果显示_adafruit_neopixel实现动画效果-程序员宅基地

文章浏览阅读895次。【在线仿真】Arduino WS2812b环形24颗霓虹灯动态效果显示在线仿真效果程序代码#include <Adafruit_NeoPixel.h>// Which pin on the Arduino is connected to the NeoPixels?// On a Trinket or Gemma we suggest changing this to 1:#define LED_PIN 6// How many NeoPixels are att_adafruit_neopixel实现动画效果