介绍
如果我们想执行定时任务，那么JDK为我们提供了Timer，但是Timer会有很多问题，如时间可能延迟、时间依赖系统导致不准确、出现异常停止等各种问题。spring为我们提供了定时器Spring Scheduler，但是它也不是很完美，有很多坑去踩。
结构
spirng执行定时任务的三个模块：
-
TaskExecutor任务执行器
TaskExecutor类图.jpg
① SyncTaskExecutor：没有采用异步的方式执行调用，实际上每个任务的调用都是执行自己线程的run方法。
② ThreadPoolTaskExecutor：其本身的实现采用jdk提供的线程池ThreadPoolExecutor实现的。
③ ConcurrentTaskExecutor：该类主要是为jdk中的Executor设计的对象适配器模式。
④ WorkManagerTaskExecutor：主要采用WorkManager来实现的。
⑤ SimpleAsyncTaskExecutor：主要就是每个调用就为其分配一个线程，如果超出指定的并发限制，任务就会阻塞，直到有空闲线程为止。 -
TaskScheduler任务调度器
TaskScheduler类图.jpg
① ThreadPoolTaskScheduler：主要还是依赖于jdk的线程池来实现的。 -
Trigger任务触发器
Trigger类图.jpg
① PeriodicTrigger：在给定的时间间隔触发任务，类似于quartz的SimpleTrigger。
② CronTrigger：使用cron表达式来触发任务。
使用Spring Scheduler
- 配置文件方式
① 配置文件：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:beans="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd
http://www.springframework.org/schema/task
http://www.springframework.org/schema/task/spring-task-4.0.xsd">
<beans:bean id="springSchedulerTask" class="cn.sunpy.task.SpringSchedulerTask"></beans:bean>
<task:scheduled-tasks>
<task:scheduled ref="springSchedulerTask" method="executeTask" cron="0/3 * * * * ?"/>
</task:scheduled-tasks>
</beans>
② 任务：
public class SpringSchedulerTask {
public void executeTask() {
SimpleDateFormat sdf = new SimpleDateFormat("yyy-MM-dd HH:mm:ss");
System.out.println("executeTask" + sdf.format(new Date()));
}
}
- 注解方式
① 配置文件：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.3.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-4.3.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-4.3.xsd
http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd
http://www.springframework.org/schema/task
http://www.springframework.org/schema/task/spring-task.xsd">
<context:component-scan base-package="com.hlw.grhc" />
<context:component-scan base-package="com.hlw.sch" />
<!-- 开启quartz的注解 -->
<task:annotation-driven/>
</beans>
② 任务：
@Component
public class OrgDataSch {
/**
* 每日00:00:00执行 ,如2018/7/31 0:00:00
*/
@Scheduled(cron="0 30 0 * * ?")
public void countPhsTask() throws ServiceException{
......
}
}
思考
现在的机器都是多台集群部署的，而Spring Scheduler本身对于集群没什么完美的解决方案，提供的方案是通过指定ip来让一台机器执行定时任务，感觉如果这台机器出现问题，这个定时任务就玩不转了，高可用就没戏了，这个方案不是真正的集群解决方式，发现这个Spring Scheduler功能有点鸡肋了。打算深入研究下quartz组件。
网友评论