快捷導(dǎo)航

Java Web項(xiàng)目中編寫定時(shí)任務(wù)的實(shí)現(xiàn)

更新時(shí)間：2017年01月24日 08:57:02 作者：_tsubasa_

本篇文章主要介紹了Java Web項(xiàng)目中編寫定時(shí)任務(wù)的實(shí)現(xiàn)，具有一定的參考價(jià)值，有興趣的可以了解一下。

之前在的公司有專門的任務(wù)調(diào)度框架，需要使用的時(shí)候引個(gè)jar包加個(gè)配置和注解就可以使用了，還有專門的平臺(tái)來維護(hù)運(yùn)行的機(jī)器及監(jiān)控執(zhí)行狀態(tài)等等。

現(xiàn)在突然沒了這個(gè)工具，而又要寫定時(shí)任務(wù)，該怎么辦呢？

對(duì)于非Web應(yīng)用來說，我們可以使用Quartz，使用簡(jiǎn)單，功能強(qiáng)大。

對(duì)于Java Web應(yīng)用來說，當(dāng)然也可以使用Quartz（有一篇介紹了方法：http://chabaoo.cn/article/104105.htm），但是還有更方便的工具，那就是spring自帶的支持定時(shí)任務(wù)功能。

Spring的定時(shí)任務(wù)在spring-context中，簡(jiǎn)單配置的模板如下：

<?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指定了執(zhí)行定時(shí)任務(wù)使用的scheduler，默認(rèn)使用的是

org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler；

task:annotation-driven允許使用@Async和@Scheduled注解；

task:scheduler-tasks中定義了一個(gè)個(gè)task，其中執(zhí)行周期可以使用cron表達(dá)式，還可指定延時(shí)或頻率等方式。

有一個(gè)轉(zhuǎn)換cron的在線工具挺好用，推薦給大家（注意這里可能會(huì)顯示7個(gè)字符，去掉最后一個(gè)*即可）：http://tools.jb51.net/code/Quartz_Cron_create

接下來還有一個(gè)問題，通常我們的線上環(huán)境是集群環(huán)境，有多臺(tái)機(jī)器，而這些定時(shí)任務(wù)通常只需要在一臺(tái)上執(zhí)行，如何來進(jìn)行控制呢？

目前想到兩種辦法，分享給大家：

1. 使用Redis全局緩存

http://chabaoo.cn/article/104111.htm

2. 通過判斷文件的方式

通過判斷某文件是否存在，來決定是否執(zhí)行任務(wù)（是否加載任務(wù)對(duì)應(yīng)的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:<標(biāo)識(shí)文件>"); 
  if (!resource.exists()) { 
   // 文件不存在，不啟動(dòng) 
   return; 
  } 
   
  ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(applicationContext); 
  context.setConfigLocations("classpath:spring/job.xml"); 
  context.refresh(); 
 } 
}

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: