Spring注解方式实现定时器

xmlns:task="http://www.springframework.org/schema/task" 

http://www.springframework.org/schema/task  
http://www.springframework.org/schema/task/spring-task-4.1.xsd

 <context:annotation-config /> 
 <!-- spring扫描注解的配置（要扫描的包，即定时器所在包） -->
 <context:component-scan base-package="com.qiyuan.listener" /> 
   
 <!-- 开启这个配置，spring才能识别@Scheduled注解   --> 
 <task:annotation-driven scheduler="qbScheduler" mode="proxy"/> 
 <task:scheduler />

<!-- task任务注解扫描包（定时器开关） -->
<task:annotation-driven/> <!-- 用定时器注解 -->
     
<!-- 扫描位置是 -->
<context:annotation-config/>  
<bean class="org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor"/> 
<context:component-scan base-package="com.qiyuan.listener"/>  

package com.qiyuan.listener;

public interface Test {

    public void myTest1(); 
    
    public void myTest2(); 
    
    public void myTest3();
    
    public void myTest4();
    
}

package com.qiyuan.listener;

import java.text.SimpleDateFormat;
import java.util.Date;

import javax.annotation.Resource;

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import com.qiyuan.bean.TRate;
import com.qiyuan.service.AnalysticService;
import com.qiyuan.service.CenterPurseService;
import com.qiyuan.service.OrderService;
import com.qiyuan.service.RateService;
import com.qiyuan.util.RateUtil;


@Component
public class TestImp implements Test {

    @Resource
    private RateService rateServiceImp;
    @Resource
    private CenterPurseService centerPurseServiceImp;
    @Resource
    private OrderService orderServiceImp;
    @Resource
    private AnalysticService analysticServiceImp;
    
    int count1 = 0;
    int count2 = 0;
    int count3 = 0;
    int count4 = 0;
    
    @Scheduled(cron="0 */5 * * * ?")   //每5分钟执行一次  
    @Override
    public void myTest1() {
        System.out.println("进入测试定时器1");  
        ++count1;
        System.out.println("定时器1：时间=" + new Date() + " 执行了" + count1 + "次"); // 1次
        //查询各种币的汇率
        TRate tRate=new TRate();
        tRate.setRate(1);
        tRate.setYkcrate(RateUtil.YKC());
        tRate.setBtcrate(RateUtil.BTC());
        tRate.setLtcrate(RateUtil.LTC());
        tRate.setEthrate(RateUtil.ETH());
        tRate.setLastmodify(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()));
        System.out.println("==========汇率"+tRate);
        //更新汇率表
        rateServiceImp.updateRate(tRate);
        //查询钱包充值记录，更新用户钱包
        centerPurseServiceImp.searchPurseChargeRecord();
    }

    
    @Scheduled(cron="0 0 2 * * ?")   //每天凌晨一点执行一次  
    @Override
    public void myTest2() {
        System.out.println("进入测试定时器2");  
        ++count2;
        System.out.println("定时器2：时间=" + new Date() + " 执行了" + count2 + "次"); // 1次
        //每天凌晨1点：超过7天已发货但未收货的让系统自动收货
        orderServiceImp.autoAcceptOrder();
    }
    

    @Scheduled(cron="0 0 2 * * ?")   //每天凌晨两点执行一次  
    @Override
    public void myTest3() {
        System.out.println("进入测试定时器3");  
        ++count3;
        System.out.println("定时器3：时间=" + new Date() + " 执行了" + count3 + "次"); // 1次
        //每天凌晨1点统计前一天的数据
        analysticServiceImp.insertAnalystic();
    }
    
    
    @Scheduled(cron = "0 0 3 1 * ?")   //每个月1号凌晨三点执行一次
    public void myTest4(){
        System.out.println("进入测试定时器4");  
        ++count4;
        System.out.println("定时器3：时间=" + new Date() + " 执行了" + count4 + "次"); // 1次
        //每个月1号凌晨三点清空临时订单表的数据
        orderServiceImp.deleteAllTempOrder();
    }

}

@Target({java.lang.annotation.ElementType.METHOD, java.lang.annotation.ElementType.ANNOTATION_TYPE})  
@Retention(RetentionPolicy.RUNTIME)  
@Documented  
public @interface Scheduled  
{  
  public abstract String cron();  
  
  public abstract long fixedDelay();  
  
  public abstract long fixedRate();  
}