分享Spring Scheduled定时器的用法

摘要：在coding中经常会用到定时器，指定每隔1个小时，或是每天凌晨2点执行一段代码段，若是使用java.util.Timer来做这种事情，未免重复造轮子。幸亏Spring中封装有定时器，而且非常好用，采用注解的形式配置某时某刻执行一段代码段。在之前的项目中使用过一次，下面就把代码、配置一并分享与大家。

关键词：Spring, JAVA, Scheduled, 定时器

---

一、

首先写一个Handler接口（“定时器Handler”），用以说明实现这一接口的类做的处理逻辑都是由定时器驱动的。

/*
 *文件名：ITimeFlickerHandler.java
 *版权：王安琪
 *描述：时钟消息处理接口
 *修改时间：2014-01-13
 *修改内容：新增
 */

public interface ITimeFlickerHandler {

    void handle();
}

 

二、

编写定时器驱动，设置某时某刻执行哪些代码，从而驱动“定时器Handler”。

/*
 *文件名：TimeFlicker.java
 *版权：王安琪
 *描述：时钟触发源
 *修改时间：2014-01-13
 *修改内容：新增
 */

import java.util.ArrayList;
import java.util.List;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Scheduled;

/**
 * 时钟触发源
 * 
 * @author wanganqi
 * 
 */
public class TimeFlicker {

    private static final Logger logger = LoggerFactory
            .getLogger(LocatingSourceFilter.class);

    private List<ITimeFlickerHandler> handlers = new ArrayList<ITimeFlickerHandler>();

    /**
     * 通过配置文件获取要调用的时钟消息处理类
     * 
     * @return
     */
    public List<ITimeFlickerHandler> getHandlers() {
        return handlers;
    }

    public void setHandlers(List<ITimeFlickerHandler> handlers) {
        this.handlers = handlers;
    }

    // 每一个小时30分00秒执行处理
    @Scheduled(cron = "0 30 * * * ?")
    public void run() {
        for (ITimeFlickerHandler handler : handlers) {
            handler.handle();
        }
    }
}

 

三、

实现“定时器Handler”接口，实现定时器事件触发时的处理逻辑。

/*
 *文件名：Monitor.java
 *版权：王安琪
 *描述：监控处理
 *修改时间：2013-12-10
 *修改内容：新增
 */

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class Monitor implements ITimeFlickerHandler {

    private static final Logger logger = LoggerFactory
            .getLogger(LocatingSourceFilter.class);

    /**
     * 定时时间到，更新所有电子围栏缓存
     * 
     * @see ITimeFlickerHandler#handle()
     */
    @Override
    public void handle() {
        EF[] res = null;
        try {
            res = service.GetEF();
        } catch (Exception e) {
            logger.error("This is error message");
        }
        EFB.setBuffer(res);
    }
}

 

四、

配置Spring，注入“定时器Handler”，Spring配置文件bean.xml如下。

<?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.1.xsd
        http://www.springframework.org/schema/task  http://www.springframework.org/schema/task/spring-task-3.1.xsd  ">

    <!-- 处理器相关 -->
    <task:annotation-driven />
    <bean id="Monitor"
        class="com.imp.Monitor" />
    <bean id="TimeFlicker" class="com.imp.TimeFlicker">
        <property name="handlers">
            <list>
                <ref bean="Monitor" />
            </list>
        </property>
    </bean>
</beans>

五、

生成、获取Spring应用上下文，并编写测试用例......。

import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.FileSystemXmlApplicationContext;

public class AppContext {

    private static AbstractApplicationContext dispatchContext;

    /**
     * 以单例模式获取上下文
     * 
     * @return 上下文
     */
    public static AbstractApplicationContext getDispatchContext() {
        if (dispatchContext == null)
            dispatchContext = new FileSystemXmlApplicationContext(
                    "classpath:bean.xml");
        return dispatchContext;
    }
}

这个定时器真是简洁又极其有用的，至今还没有发现它有什么缺点，不知道C#中有没有这么一个小工具，能提高代码编写效率，知晓之人可以告之。

 

如有引用，请注明来自 http://www.cnblogs.com/wgp13x/ ，另外推荐一篇我刚写的博客：

如何写一篇论文,<一种低耗能的数据融合隐私保护算法ESPART> (计算机学报2011-5,王安琪)

来自王安琪(http://www.cnblogs.com/wgp13x/p/3885665.html)