开发文章

Java Web项目中编写定时任务

之前在的公司有专门的任务调度框架,需要使用的时候引个jar包加个配置和注解就可以使用了,还有专门的平台来维护运行的机器及监控执行状态等等。

现在突然没了这个工具,而又要写定时任务,该怎么办呢?

 

对于非Web应用来说,我们可以使用Quartz,使用简单,功能强大。

 

对于Java Web应用来说,当然也可以使用Quartz(有一篇博客介绍了方法:http://blog.csdn.net/sadfishsc/article/details/50808027),但是还有更方便的工具,那就是spring自带的支持定时任务功能。

Spring的定时任务在spring-context中,简单配置的模板如下:

复制内容到剪贴板
  1. 之前在的公司有专门的任务调度框架,需要使用的时候引个jar包加个配置和注解就可以使用了,还有专门的平台来维护运行的机器及监控执行状态等等。  
  2.   
  3. 现在突然没了这个工具,而又要写定时任务,该怎么办呢?  
  4.   
  5.   
  6. 对于非Web应用来说,我们可以使用Quartz,使用简单,功能强大。  
  7.   
  8.   
  9. 对于Java Web应用来说,当然也可以使用Quartz(有一篇博客介绍了方法:http://blog.csdn.net/sadfishsc/article/details/50808027),但是还有更方便的工具,那就是spring自带的支持定时任务功能。  
  10.   
  11. Spring的定时任务在spring-context中,简单配置的模板如下:  

其中task:scheduler指定了执行定时任务使用的scheduler,默认使用的是org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;

task:annotation-driven允许使用@Async和@Scheduled注解;

task:scheduler-tasks中定义了一个个task,其中执行周期可以使用cron表达式,还可指定延时或频率等方式。

有一个转换cron的在线工具挺好用,推荐给大家(注意这里可能会显示7个字符,去掉最后一个*即可):

http://cron.qqe2.com/

 

接下来还有一个问题,通常我们的线上环境是集群环境,有多台机器,而这些定时任务通常只需要在一台上执行,如何来进行控制呢?

目前想到两种办法,分享给大家:

1. 使用Redis全局缓存

这个就不详细介绍了,可以参考下面两篇文章:

http://blog.csdn.net/lihao21/article/details/49104695

http://blog.csdn.net/liubenlong007/article/details/53782934

2. 通过判断文件的方式

通过判断某文件是否存在,来决定是否执行任务(是否加载任务对应的spring配置文件),参考代码:

复制内容到剪贴板
  1. @Component    
  2. public class XxxListener implements ApplicationContextAware {    
  3.     
  4.     // 防止加载多次    
  5.     private static final AtomicInteger INIT_LOCK = new AtomicInteger(0);    
  6.     
  7.     @Override    
  8.     public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {    
  9.     
  10.         if (INIT_LOCK.incrementAndGet() > 1) {    
  11.             // 类已加载过    
  12.             return;    
  13.         }    
  14.     
  15.         Resource resource = applicationContext.getResource("classpath:<标识文件>");    
  16.         if (!resource.exists()) {    
  17.             // 文件不存在,不启动    
  18.             return;    
  19.         }    
  20.             
  21.         ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(applicationContext);    
  22.         context.setConfigLocations("classpath:spring/job.xml");    
  23.         context.refresh();    
  24.     }    
  25. }    

 

感谢 _tsubasa_ 支持 磐实编程网 原文地址:
blog.csdn.net/mj158518/article/details/54694589

文章信息

发布时间:2017-02-01

作者:_tsubasa_

发布者:aquwcw

浏览次数: