exec 线程 crontab extends err inter 应用 一段 java 实现
前言
在实际项目开发中,除了 web 应用,SOA 服务外,还有一类不可缺少的,那就是定时任务调度.定时任务的场景可以说非常广泛,比如某些视频网站,购买会员后,每天会给会员送成长值,每月会给会员送一些电影券;比如在保证最终一致性的场景中,往往利用定时任务调度进行一些比对工作;比如一些定时需要生成的报表,邮件;比如一些需要定时清理数据的任务等.本篇博客将系统的介绍定时任务调度,会涵盖 Timer,ScheduledExecutorService,开源工具包 Quartz,以及 Spring 和 Quartz 的结合等内容.
JDK 原生定时工具:Timer
定时任务调度:基于给定的时间点,给定的时间间隔,给定的执行次数自动执行的任务.
Timer 位于 java.util 包下,其内部包含且仅包含一个后台线程(TimeThread)对多个业务任务(TimeTask)进行定时定频率的调度.
schedule 的四种用法和 scheduleAtFixedRate 的两种用法
参数说明:
task:所要执行的任务,需要 extends TimeTask override run()
time/firstTime:首次执行任务的时间
period:周期性执行 Task 的时间间隔,单位是毫秒
delay:执行 task 任务前的延时时间,单位是毫秒
很显然,通过上述的描述,我们可以实现:
延迟多久后执行一次任务;指定时间执行一次任务;延迟一段时间,并周期性执行任务;指定时间,并周期性执行任务;
思考 1:如果 time/firstTime 指定的时间,在当前时间之前,会发生什么呢?
在时间等于或者超过 time/firstTime 的时候,会执行 task!也就是说,如果 time/firstTime 指定的时间在当前时间之前,就会立即得到执行.
思考 2:schedule 和 scheduleAtFixedRate 有什么区别?
scheduleAtFixedRate:每次执行时间为上一次任务开始起向后推一个 period 间隔,也就是说下次执行时间相对于上一次任务开始的时间点,因此执行时间不会延后,但是存在任务并发执行的问题.
schedule:每次执行时间为上一次任务结束后推一个 period 间隔,也就是说下次执行时间相对于上一次任务结束的时间点,因此执行时间会不断延后.
思考 3:如果执行 task 发生异常,是否会影响其他 task 的定时调度?
如果 TimeTask 抛出 RuntimeException,那么 Timer 会停止所有任务的运行!
思考 4:Timer 的一些缺陷?
前面已经提及到 Timer 背后是一个单线程,因此 Timer 存在管理并发任务的缺陷:所有任务都是由同一个线程来调度,所有任务都是串行执行,意味着同一时间只能有一个任务得到执行,而前一个任务的延迟或者异常会影响到之后的任务.
其次,Timer 的一些调度方式还算比较简单,无法适应实际项目中任务定时调度的复杂度.
一个简单的 Demo 实例
Timer 其他需要关注的方法
cancel():终止 Timer 计时器,丢弃所有当前已安排的任务(TimeTask 也存在 cancel() 方法,不过终止的是 TimeTask)
purge():从计时器的任务队列中移除已取消的任务,并返回个数
JDK 对定时任务调度的线程池支持:ScheduledExecutorService
由于 Timer 存在的问题,JDK5 之后便提供了基于线程池的定时任务调度:ScheduledExecutorService.
设计理念:每一个被调度的任务都会被线程池中的一个线程去执行,因此任务可以并发执行,而且相互之间不受影响.
我们直接看例子:
定时任务大哥:Quartz
虽然 ScheduledExecutorService 对 Timer 进行了线程池的改进,但是依然无法满足复杂的定时任务调度场景.因此 OpenSymphony 提供了强大的开源任务调度框架:Quartz.Quartz 是纯 Java 实现,而且作为 Spring 的默认调度框架,由于 Quartz 的强大的调度功能,灵活的使用方式,还具有分布式集群能力,可以说 Quartz 出马,可以搞定一切定时任务调度!
Quartz 的体系结构
先来看一个 Demo:
说明:
1,从代码上来看,有 XxxBuilder,XxxFactory,说明 Quartz 用到了 Builder,Factory 模式,还有非常易懂的链式编程风格.
2,Quartz 有 3 个核心概念:调度器(Scheduler),任务(Job&JobDetail),触发器(Trigger).(一个任务可以被多个触发器触发,一个触发器只能触发一个任务)
3,注意当 Scheduler 调度 Job 时,实际上会通过反射 newInstance 一个新的 Job 实例(待调度完毕后销毁掉),同时会把 JobExecutionContext 传递给 Job 的 execute 方法,Job 实例通过 JobExecutionContext 访问到 Quartz 运行时的环境以及 Job 本身的明细数据.
4,JobDataMap 可以装载任何可以序列化的数据,存取很方便.需要注意的是 JobDetail 和 Trigger 都可以各自关联上 JobDataMap.JobDataMap 除了可以通过上述代码获取外,还可以在 YourJob 实现类中,添加相应 setter 方法获取.
5,Trigger 用来告诉 Quartz 调度程序什么时候执行,常用的触发器有 2 种:SimpleTrigger(类似于 Timer),CronTrigger(类似于 Linux 的 Crontab).
6,实际上,Quartz 在进行调度器初始化的时候,会加载 quartz.properties 文件进行一些属性的设置,比如 Quartz 后台线程池的属性(threadCount),作业存储设置等.它会先从工程中找,如果找不到那么就是用 quartz.jar 中的默认的 quartz.properties 文件.
7,Quartz 存在监听器的概念,比如任务执行前后,任务的添加等,可以方便实现任务的监控.
CronTrigger 示例
这里给出一些常用的示例:
0 15 10 ? * 每天 10 点 15 分触发
0 15 10 ? 2017 2017 年每天 10 点 15 分触发
0 14 * ? 每天下午的 2 点到 2 点 59 分每分触发
0 0/5 14 ? 每天下午的 2 点到 2 点 59 分 (整点开始,每隔 5 分触发)
0 0/5 14,18 ? 每天下午的 2 点到 2 点 59 分,18 点到 18 点 59 分 (整点开始,每隔 5 分触发)
0 0-5 14 ? 每天下午的 2 点到 2 点 05 分每分触发
0 15 10 ? * 6L 每月最后一周的星期五的 10 点 15 分触发
0 15 10 ? * 6#3 每月的第三周的星期五开始触发
我们可以通过一些 Cron 在线工具非常方便的生成,比如 http://www.pppet.net / 等.
Spring 和 Quartz 的整合
实际上,Quartz 和 Spring 结合是很方便的,无非就是进行一些配置.大概基于 2 种方式:
第一,普通的类,普通的方法,直接在配置中指定(MethodInvokingJobDetailFactoryBean).
第二,需要继承 QuartzJobBean,复写指定方法(executeInternal)即可.
然后,就是一些触发器,调度器的配置了,这里不再展开介绍了,只要弄懂了原生的 Quartz 的使用,那么和 Spring 的结合使用就会很简单.
Java 定时任务调度详解
来源: http://www.bubuko.com/infodetail-2471609.html