SpringBoot定时任务(schedule、quartz)

SpringBoot定时任务(schedule、quartz)

Scheduled

　　只适合处理简单的计划任务&＃xff0c;不能处理分布式计划任务。优势&＃xff1a;是spring框架提供的计划任务&＃xff0c;开发简单&＃xff0c;执行效率比较高。且在计划任务数量太多的时候&＃xff0c;可能出现阻塞&＃xff0c;崩溃&＃xff0c;延迟启动等问题。
　　Scheduled定时任务是spring3.0版本之后自带的一个定时任务。其所属Spring的资源包为&＃xff1a;spring-context-support。所以需要使用Scheduled定时任务机制时&＃xff0c;需要在工程中依赖对应资源&＃xff0c;具体如下&＃xff1a;


org.springframeworkspring-context-support


　　如果在spring应用中需要启用Scheduled定时任务&＃xff0c;则需要在启动类上增加注解&＃64;EnableScheduling&＃xff0c;代表启用Scheduled定时任务机制。具体如下&＃xff1a;

&＃64;SpringBootApplication
&＃64;EnableScheduling
public class AppStarter {public static void main(String[] args) {SpringApplication.run(AppStarter.class, args);}
}

　　Scheduled定时任务的核心在于注解&＃64;Scheduled&＃xff0c;这个注解的核心属性是cron&＃xff0c;代表定时任务的触发计划表达式。这个表达式的格式为&＃xff1a;

&＃64;Scheduled(cron&＃61;"seconds minutes hours day month week")

　　或

&＃64;Scheduled(cron&＃61;"seconds minutes hours day month week year")

　　推荐使用第一种表达式形式&＃xff0c;因为在很多其他技术中都有不同的定时任务机制&＃xff0c;其中用于设置触发计划的表达式都是第一种cron表达式。第二种表达式不能说是Spring Scheduled特有的&＃xff0c;也是只有少数技术支持的。

　　cron表达式中&＃xff0c;每个位置的约束如下&＃xff1a;

星号(*)&＃xff1a;可用在所有字段中&＃xff0c;表示对应时间域的每一个时刻&＃xff0c;例如&＃xff0c;*在分钟字段时&＃xff0c;表示“每分钟”&＃xff1b;
问号&＃xff08;?&＃xff09;&＃xff1a;该字符只在日期和星期字段中使用&＃xff0c;它通常指定为“无意义的值”&＃xff0c;相当于占位符&＃xff1b;
减号(-)&＃xff1a;表达一个范围&＃xff0c;如在小时字段中使用“10-12”&＃xff0c;则表示从10到12点&＃xff0c;即10,11,12&＃xff1b;
逗号(,)&＃xff1a;表达一个列表值&＃xff0c;如在星期字段中使用“MON,WED,FRI”&＃xff0c;则表示星期一&＃xff0c;星期三和星期五&＃xff1b;
斜杠(/)&＃xff1a;x/y表达一个等步长序列&＃xff0c;x为起始值&＃xff0c;y为增量步长值。如在秒数字段中使用0/15&＃xff0c;则表示为0,15,30和45秒&＃xff0c;而5/15在分钟字段中表示5,20,35,50&＃xff0c;你也可以使用*/y&＃xff0c;它等同于0/y&＃xff1b;

　　L&＃xff1a;该字符只在日期和星期字段中使用&＃xff0c;代表“Last”的意思&＃xff0c;但它在两个字段中意思不同。L在日期字段中&＃xff0c;表示这个月份的最后一天&＃xff0c;如一月的31号&＃xff0c;非闰年二月的28号&＃xff1b;如果L用在星期中&＃xff0c;则表示星期六&＃xff0c;等同于7。但是&＃xff0c;如果L出现在星期字段里&＃xff0c;而且在前面有一个数值X&＃xff0c;则表示“这个月的最后X天”&＃xff0c;例如&＃xff0c;6L表示该月的最后星期五&＃xff1b;

　　W&＃xff1a;该字符只能出现在日期字段里&＃xff0c;是对前导日期的修饰&＃xff0c;表示离该日期最近的工作日。例如15W表示离该月15号最近的工作日&＃xff0c;如果该月15号是星期六&＃xff0c;则匹配14号星期五&＃xff1b;如果15日是星期日&＃xff0c;则匹配16号星期一&＃xff1b;如果15号是星期二&＃xff0c;那结果就是15号星期二。但必须注意关联的匹配日期不能够跨月&＃xff0c;如你指定1W&＃xff0c;如果1号是星期六&＃xff0c;结果匹配的是3号星期一&＃xff0c;而非上个月最后的那天。W字符串只能指定单一日期&＃xff0c;而不能指定日期范围&＃xff1b;

　　LW组合&＃xff1a;在日期字段可以组合使用LW&＃xff0c;它的意思是当月的最后一个工作日&＃xff1b;

　　井号(#)&＃xff1a;该字符只能在星期字段中使用&＃xff0c;表示当月某个工作日。如6#3表示当月的第三个星期五(6表示星期五&＃xff0c;#3表示当前的第三个)&＃xff0c;而4#5表示当月的第五个星期三&＃xff0c;假设当月没有第五个星期三&＃xff0c;忽略不触发&＃xff1b;

　　C&＃xff1a;该字符只在日期和星期字段中使用&＃xff0c;代表“Calendar”的意思。它的意思是计划所关联的日期&＃xff0c;如果日期没有被关联&＃xff0c;则相当于日历中所有日期。例如5C在日期字段中就相当于日历5日以后的第一天。1C在星期字段中相当于星期日后的第一天。

　　Cron表达式对特殊字符的大小写不敏感&＃xff0c;对代表星期的缩写英文大小写也不敏感。

　　计划任务Scheduled是通过一个线程池实现的。是一个多线程的调度。SpringBoot会初始化一个线程池&＃xff0c;线程池默认大小为1&＃xff0c;专门用于执行计划任务。每个计划任务启动的时候&＃xff0c;都从线程池中获取一个线程执行&＃xff0c;如果发生异常&＃xff0c;只是执行当前任务的线程发生异常&＃xff0c;而不是计划任务调度线程发生异常。如果当前定时任务还未执行完成&＃xff0c;当相同的定时任务又进入到执行周期时&＃xff0c;不会触发新的定时任务。如&＃xff1a;

&＃64;Scheduled(cron&＃61;"* * * * * ?")
public void test1(){Random r &＃61; new Random();/*int i &＃61; r.nextInt(100);if(i % 3 &＃61;&＃61; 0){throw new RuntimeException("error");}*/System.out.println(Thread.currentThread().getName() &＃43; " cron&＃61;* * * * * ? --- " &＃43; new Date());try{Thread.sleep(2000);}catch(Exception e){e.printStackTrace();}
}

　　如结果所示(每次的线程名称一致&＃xff0c;由于前一个定时任务未执行完成&＃xff0c;因此造成后一个任务的推迟&＃xff0c;而不是1秒执行一次&＃xff0c;而是3秒)&＃xff1a;

pool-1-thread-1 cron&＃61;* * * * * ? --- Thu Sep 19 02:23:20 CST 2019
pool-1-thread-1 cron&＃61;* * * * * ? --- Thu Sep 19 02:23:23 CST 2019
pool-1-thread-1 cron&＃61;* * * * * ? --- Thu Sep 19 02:23:26 CST 2019
pool-1-thread-1 cron&＃61;* * * * * ? --- Thu Sep 19 02:23:29 CST 2019

quartz

　　Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目&＃xff0c;它可以与J2EE与J2SE应用程序相结合也可以单独使用。Quartz可以用来创建简单或为运行十个&＃xff0c;百个&＃xff0c;甚至是好几万个Jobs这样复杂的程序。

　　Quartz是一个完全由java编写的开源作业调度框架。不要让作业调度这个术语吓着你。尽管Quartz框架整合了许多额外功能&＃xff0c; 但就其简易形式看&＃xff0c;你会发现它易用得简直让人受不了&＃xff01;
在开发Quartz相关应用时&＃xff0c;只要定义了Job&＃xff08;任务&＃xff09;&＃xff0c;Trigger&＃xff08;触发器&＃xff09;和Scheduler&＃xff08;调度器&＃xff09;&＃xff0c;即可实现一个定时调度能力。其中Scheduler是Quartz中的核心&＃xff0c;Scheduler负责管理Quartz应用运行时环境&＃xff0c;Scheduler不是靠自己完成所有的工作&＃xff0c;是根据Trigger的触发标准&＃xff0c;调用Job中的任务执行逻辑&＃xff0c;来完成完整的定时任务调度。
　　Job - 定时任务内容是什么。
　　Trigger - 在什么时间上执行job。
　　Scheduler - 维护定时任务环境&＃xff0c;并让触发器生效。
　　在SpringBoot中应用Quartz&＃xff0c;需要依赖下述资源&＃xff1a;

org.springframeworkspring-context-supportorg.quartz-schedulerquartz2.2.1slf4j-apiorg.slf4jorg.springframeworkspring-tx


　　启动器添加注解&＃64;EnableScheduling&＃xff1a;

/*** &＃64;EnableScheduling 必要* 开启定时任务机制。*/
&＃64;SpringBootApplication
&＃64;EnableScheduling
public class AppStarter {public static void main(String[] args) {SpringApplication.run(AppStarter.class, args);}
}

　　定义JOB任务以及JOB任务调用的模拟业务对象&＃xff1a;

1 public class SpringBootQuartzJobDemo implements Job {2 3 // 用于模拟任务中的业务对象。 也可能是数据访问对象&＃xff0c;或其他类型的对象。4 &＃64;Autowired5 private CommonsUtil4Quartz commonsUtil4Quartz;6 7 &＃64;Override8 public void execute(JobExecutionContext context) throws JobExecutionException {9 System.out.println("SpringBootQuartzJobDemo : " &＃43; new Date());
10 this.commonsUtil4Quartz.testMethod();
11 }
12
13 }

&＃64;Component
public class CommonsUtil4Quartz {public void testMethod(){System.out.println("CommonsUtil4Quartz testMethod run...");}
}

　　创建Trigger以及JobDetail对象&＃xff0c;并用Schedule配置定时任务&＃xff1a;

/*** 初始化类* Quartz环境初始化。* */
&＃64;Configuration
public class QuartzConfiguration {/*** 创建Job对象。在Spring环境中&＃xff0c;创建一个类型的对象的时候&＃xff0c;很多情况下&＃xff0c;都是通过FactoryBean来间接创建的。* 如果有多个Job对象&＃xff0c;定义多次方法。* * 在JobDetailFactoryBean类型中&＃xff0c;用于创建JobDetail对象的方法&＃xff0c;其底层使用的逻辑是&＃xff1a;Class.newInstance()* 也就是说&＃xff0c;JobDetail对象不是通过Spring容器管理的。* 因为Spring容器不管理JobDetail对象&＃xff0c;那么Job中需要自动装配的属性&＃xff0c;就无法实现自动状态。如上JOB的第10行会报空指针异常。* * 解决方案是&＃xff1a; 将JobDetail加入到Spring容器中&＃xff0c;让Spring容器管理JobDetail对象。* 需要重写Factory相关代码。实现Spring容器管理JobDetail。* &＃64;return*/&＃64;Beanpublic JobDetailFactoryBean initJobDetailFactoryBean(){JobDetailFactoryBean factoryBean &＃61; new JobDetailFactoryBean();// 提供job类型。factoryBean.setJobClass(SpringBootQuartzJobDemo.class);return factoryBean;}/*** 管理Trigger对象* CronTrigger - 就是Trigger的一个实现类型。 其中用于定义周期时间的是CronSchedulerBuilder* 实际上&＃xff0c;CronTrigger是用于管理一个Cron表达式的类型。* &＃64;param jobDetailFactoryBean - 上一个方法初始化的JobDetailFactoryBean* &＃64;return*/&＃64;Bean(name&＃61;"cronTriggerFactoryBean1")public CronTriggerFactoryBean initCronTriggerFactoryBean(){CronTriggerFactoryBean factoryBean &＃61; new CronTriggerFactoryBean();JobDetailFactoryBean jobDetailFactoryBean &＃61; this.initJobDetailFactoryBean();factoryBean.setJobDetail(jobDetailFactoryBean.getObject());factoryBean.setCronExpression("0/3 * * * * ?");return factoryBean;}/*** 初始化Scheduler* &＃64;param cronTriggerFactoryBean - 上一个方法初始化的CronTriggerFactoryBean* &＃64;return*/&＃64;Beanpublic SchedulerFactoryBean initSchedulerFactoryBean(CustomJobFactory customJobFactory,CronTriggerFactoryBean[] cronTriggerFactoryBean){SchedulerFactoryBean factoryBean &＃61; new SchedulerFactoryBean();CronTrigger[] triggers &＃61; new CronTrigger[cronTriggerFactoryBean.length];for(int i &＃61; 0; i

　　重写JobFactory&＃xff1a;

/*** 重写的工厂对象。*/
&＃64;Component
public class CustomJobFactory extends AdaptableJobFactory {/*** AutowireCapableBeanFactory : 简单理解为Spring容器&＃xff0c;是Spring容器Context的一个Bean对象管理工程。* 可以实现自动装配逻辑&＃xff0c;和对象创建逻辑。* 是SpringIoC容器的一个重要组成部件。*/&＃64;Autowiredprivate AutowireCapableBeanFactory autowireCapableBeanFactory;&＃64;Overrideprotected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {// 通过父类型中的方法&＃xff0c;创建JobDetail对象。Object obj &＃61; super.createJobInstance(bundle);// 将JobDetail对象加入到Spring容器中&＃xff0c;让Spring容器管理&＃xff0c;并实现自动装配逻辑。this.autowireCapableBeanFactory.autowireBean(obj);return obj;}}

分布式quartz配置