发布于 2018-02-25 10:58:05 | 212 次阅读 | 评论: 0 | 来源: 网友投递
Java程序设计语言
java 是一种可以撰写跨平台应用软件的面向对象的程序设计语言，是由Sun Microsystems公司于1995年5月推出的Java程序设计语言和Java平台（即JavaEE(j2ee), JavaME(j2me), JavaSE(j2se)）的总称。
之前在的公司有专门的任务调度框架，需要使用的时候引个jar包加个配置和注解就可以使用了，还有专门的平台来维护运行的机器及监控执行状态等等。
现在突然没了这个工具，而又要写定时任务，该怎么办呢？
对于非Web应用来说，我们可以使用Quartz，使用简单，功能强大。
对于Java Web应用来说，当然也可以使用Quartz（有一篇介绍了方法：/article/17/1108/358686.html），但是还有更方便的工具，那就是spring自带的支持定时任务功能。
Spring的定时任务在spring-context中，简单配置的模板如下：
<?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:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd
http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd">
<task:scheduler id="scheduler" pool-size="200"/>
<task:scheduled-tasks>
<!-- 你的task -->
<task:scheduled ref="xxxTask" method="execute" cron="0 0 * * * ?"/>
</task:scheduled-tasks>
<task:annotation-driven scheduler="scheduler"/>
</beans>
其中task:scheduler指定了执行定时任务使用的scheduler，默认使用的是
org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler；
task:annotation-driven允许使用@Async和@Scheduled注解；
task:scheduler-tasks中定义了一个个task，其中执行周期可以使用cron表达式，还可指定延时或频率等方式。
接下来还有一个问题，通常我们的线上环境是集群环境，有多台机器，而这些定时任务通常只需要在一台上执行，如何来进行控制呢？
目前想到两种办法，分享给大家：
1. 使用Redis全局缓存
2. 通过判断文件的方式
通过判断某文件是否存在，来决定是否执行任务（是否加载任务对应的spring配置文件），参考代码：
@Component
public class XxxListener implements ApplicationContextAware {
// 防止加载多次
private static final AtomicInteger INIT_LOCK = new AtomicInteger(0);
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
if (INIT_LOCK.incrementAndGet() > 1) {
// 类已加载过
return;
}
Resource resource = applicationContext.getResource("classpath:<标识文件>");
if (!resource.exists()) {
// 文件不存在，不启动
return;
}
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(applicationContext);
context.setConfigLocations("classpath:spring/job.xml");
context.refresh();
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持PHPERZ。