SpringBoot定时任务

时间  2019-11-17
标签 springboot 定时 任务 栏目 Spring 繁體版
原文   原文链接

1、定时任务概述

    后台项目开发中常常会用到定时任务，如今实现定时任务都方式也是多种多样。下面列举几种常见的定时任务实现方式：html

    1. Quartz：Quartz的使用至关普遍，它是一个功能强大的调度器，固然使用起来也相对麻烦；java

    2. java.util包里的Timer，它也能够实现定时任务可是功能过于单一全部使用不多。spring

    3. 就是咱们今天要介绍的Spring自带的定时任务Schedule，其实能够把它看做是一个简化版的，轻量级的Quartz，使用起来也相对方便不少。express

2、实现定时任务

1. 建立定时任务

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
 * Description: 构建执行定时任务
 * Designer: jack
 * Date: 2017/8/10
 * Version: 1.0.0
 */
@Component
public class ScheduledTasks {

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

    private int fixedDelayCount = 1;
    private int fixedRateCount = 1;
    private int initialDelayCount = 1;
    private int cronCount = 1;

    @Scheduled(fixedDelay = 5000)        //fixedDelay = 5000表示当前方法执行完毕5000ms后，Spring scheduling会再次调用该方法
    public void testFixDelay() {
        logger.info("===fixedDelay: 第{}次执行方法", fixedDelayCount++);
    }

    @Scheduled(fixedRate = 5000)        //fixedRate = 5000表示当前方法开始执行5000ms后，Spring scheduling会再次调用该方法
    public void testFixedRate() {
        logger.info("===fixedRate: 第{}次执行方法", fixedRateCount++);
    }

    @Scheduled(initialDelay = 1000, fixedRate = 5000)   //initialDelay = 1000表示延迟1000ms执行第一次任务
    public void testInitialDelay() {
        logger.info("===initialDelay: 第{}次执行方法", initialDelayCount++);
    }

    @Scheduled(cron = "0 0/1 * * * ?")  //cron接受cron表达式，根据cron表达式肯定定时规则
    public void testCron() {
        logger.info("===initialDelay: 第{}次执行方法", cronCount++);
    }

}

    咱们使用@Scheduled来建立定时任务 这个注解用来标注一个定时任务方法。经过看@Scheduled源码能够看出它支持多种参数：多线程

    （1）cron：cron表达式，指定任务在特定时间执行；并发

    （2）fixedDelay：表示上一次任务执行完成后多久再次执行，参数类型为long，单位ms；ide

    （3）fixedDelayString：与fixedDelay含义同样，只是参数类型变为String；this

    （4）fixedRate：表示按必定的频率执行任务，参数类型为long，单位ms；spa

    （5）fixedRateString: 与fixedRate的含义同样，只是将参数类型变为String；线程

    （6）initialDelay：表示延迟多久再第一次执行任务，参数类型为long，单位ms；

    （7）initialDelayString：与initialDelay的含义同样，只是将参数类型变为String；

    （8）zone：时区，默认为当前时区，通常没有用到。

2.开启定时任务

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

/**
 * Description: 启动类
 * Designer: jack
 * Date: 2017/8/10
 * Version: 1.0.0
 */
@SpringBootApplication
@EnableScheduling
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

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

引用官方文档原文：

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

3. 执行结果 （单线程）

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

2017-08-11 12:06:19.738  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===initialDelay: 第1次执行方法
2017-08-11 12:06:23.739  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedRate: 第2次执行方法
2017-08-11 12:06:23.739  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedDelay: 第2次执行方法
2017-08-11 12:06:24.738  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===initialDelay: 第2次执行方法
2017-08-11 12:06:28.739  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedRate: 第3次执行方法
2017-08-11 12:06:28.740  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedDelay: 第3次执行方法
2017-08-11 12:06:29.739  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===initialDelay: 第3次执行方法
2017-08-11 12:06:33.735  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedRate: 第4次执行方法
2017-08-11 12:06:33.741  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedDelay: 第4次执行方法
2017-08-11 12:06:34.738  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===initialDelay: 第4次执行方法

    从控制台输入的结果中咱们能够看出全部的定时任务都是在同一个线程池用同一个线程来处理的，那么咱们如何来并发的处理各定时任务呢，请继续向下看。

4. 多线程处理定时任务

    看到控制台输出的结果，全部的定时任务都是经过一个线程来处理的，我估计是在定时任务的配置中设定了一个SingleThreadScheduledExecutor，因而我看了源码，从ScheduledAnnotationBeanPostProcessor类开始一路找下去。果真，在ScheduledTaskRegistrar（定时任务注册类）中的ScheduleTasks中又这样一段判断：

if (this.taskScheduler == null) {
			this.localExecutor = Executors.newSingleThreadScheduledExecutor();
			this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor);
		}

    这就说明若是taskScheduler为空，那么就给定时任务作了一个单线程的线程池，正好在这个类中还有一个设置taskScheduler的方法：

public void setScheduler(Object scheduler) {
		Assert.notNull(scheduler, "Scheduler object must not be null");
		if (scheduler instanceof TaskScheduler) {
			this.taskScheduler = (TaskScheduler) scheduler;
		}
		else if (scheduler instanceof ScheduledExecutorService) {
			this.taskScheduler = new ConcurrentTaskScheduler(((ScheduledExecutorService) scheduler));
		}
		else {
			throw new IllegalArgumentException("Unsupported scheduler type: " + scheduler.getClass());
		}
	}

    这样问题就很简单了，咱们只需用调用这个方法显式的设置一个ScheduledExecutorService就能够达到并发的效果了。咱们要作的仅仅是实现SchedulingConfigurer接口，重写configureTasks方法就OK了；

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;

import java.util.concurrent.Executors;

/**
 * Description: 多线程执行定时任务
 * Designer: jack
 * Date: 2017/8/10
 * Version: 1.0.0
 */
@Configuration
//全部的定时任务都放在一个线程池中，定时任务启动时使用不一样都线程。
public class ScheduleConfig implements SchedulingConfigurer {
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        //设定一个长度10的定时任务线程池
        taskRegistrar.setScheduler(Executors.newScheduledThreadPool(10));
    }
}

    注: 最开始我试图在ScheduledAnnotationBeanPostProcessor类中作文章，由于里面也有一个相似的方法setScheduler（），可是最后失败了，不知道是否能够经过这个类实现定时任务的并发，若是有实现了的也请告诉你们一下方法。

5. 执行结果（并发）

2017-08-11 12:21:16.000  INFO 52284 --- [pool-1-thread-3] com.test.ScheduledTasks                  : ===initialDelay: 第1次执行方法
2017-08-11 12:21:19.998  INFO 52284 --- [pool-1-thread-4] com.test.ScheduledTasks                  : ===fixedRate: 第2次执行方法
2017-08-11 12:21:19.998  INFO 52284 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedDelay: 第2次执行方法
2017-08-11 12:21:20.999  INFO 52284 --- [pool-1-thread-4] com.test.ScheduledTasks                  : ===initialDelay: 第2次执行方法
2017-08-11 12:21:25.000  INFO 52284 --- [pool-1-thread-2] com.test.ScheduledTasks                  : ===fixedRate: 第3次执行方法
2017-08-11 12:21:25.000  INFO 52284 --- [pool-1-thread-6] com.test.ScheduledTasks                  : ===fixedDelay: 第3次执行方法
2017-08-11 12:21:25.997  INFO 52284 --- [pool-1-thread-3] com.test.ScheduledTasks                  : ===initialDelay: 第3次执行方法
2017-08-11 12:21:30.000  INFO 52284 --- [pool-1-thread-7] com.test.ScheduledTasks                  : ===fixedRate: 第4次执行方法
2017-08-11 12:21:30.000  INFO 52284 --- [pool-1-thread-8] com.test.ScheduledTasks                  : ===fixedDelay: 第4次执行方法
2017-08-11 12:21:31.000  INFO 52284 --- [pool-1-thread-7] com.test.ScheduledTasks                  : ===initialDelay: 第4次执行方法

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

3、cron详解

1. cron表达式定义

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

    可是，此处敲一下黑板，spring的schedule值支持6个域的表达式，也就是不能设定年，若是超过六个则会报错。源码以下：

/**
	 * Parse the given pattern expression.
	 */
	private void parse(String expression) throws IllegalArgumentException {
		String[] fields = StringUtils.tokenizeToStringArray(expression, " ");
		if (!areValidCronFields(fields)) {
			throw new IllegalArgumentException(String.format(
					"Cron expression must consist of 6 fields (found %d in \"%s\")", fields.length, expression));
		}
		setNumberHits(this.seconds, fields[0], 0, 60);
		setNumberHits(this.minutes, fields[1], 0, 60);
		setNumberHits(this.hours, fields[2], 0, 24);
		setDaysOfMonth(this.daysOfMonth, fields[3]);
		setMonths(this.months, fields[4]);
		setDays(this.daysOfWeek, replaceOrdinals(fields[5], "SUN,MON,TUE,WED,THU,FRI,SAT"), 8);
		if (this.daysOfWeek.get(7)) {
			// Sunday can be represented as 0 or 7
			this.daysOfWeek.set(0);
			this.daysOfWeek.clear(7);
		}
	}

	private static boolean areValidCronFields(String[] fields) {
		return (fields != null && fields.length == 6);
	}

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秒执行

相关文章
相关标签/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公众号
   欢迎关注本站公众号,获取更多信息
联系我们 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程