Spring定时任务的几种实现

男娘i 2022-07-18 11:54 215阅读 0赞

定时任务在我们的开发中都会遇到，今天来总结一下Spring定时器的几种用法。

# 类别： #

目前在JavaWeb开发中，主要有三种实现定时器的方式；

1.Java自带的java.util.Timer类，这个类允许你调度一个java.util.TimerTask任务。使用这种方式可以让你的程序按照某一个频度执行，效率应该是最高的，但是使用场景并不是很多，因为他对一些并发，不能很好的保证。

2.使用Quartz，这是一个功能比较强大的的调度器，可以让你的程序在指定时间执行，也可以按照某一个频度执行，配置起来稍显复杂。

3.Spring3.0以后自带的task，可以将它看成一个轻量级的Quartz，而且使用起来比Quartz简单许多。

从任务调度来说可以分为两种，这里主要是针对调度的触发时机和场景来说的：

1.每隔指定时间则触发一次；

2.每到指定时间触发一次；

# JAVA自带的类： #

Java自带的类Timer和TimerTask,Timer类是用来记时，定时的类，它接受一个TimerTask做参数；TimerTask里面可以写我们的任务。

Timer有两种执行任务的模式,最常用的是schedule,它可以以两种方式执行任务:1:在某个时间(Data)，2:在某个固定的时间之后(int delay)

public class TimeTest {
    	public static void main(String[] args){     
            Timer timer = new Timer();     
            timer.schedule(new MyTask(), 1000, 2000);//在1秒后执行此任务,每次间隔2秒执行一次,如果传递一个Data参数,就可以在某个固定的时间执行这个任务. 
            //timer.scheduleAtFixedRate(new MyTask(), 2000, 3000); 
        }    
        static class MyTask extends java.util.TimerTask{ 
        	int i=0;
            @Override
    		public void run(){     
                System.out.println(i++);     
            }     
        }   
    }

还有另外一种是

timer.scheduleAtFixedRate

两个方式调用方法一模一样，区别就在于；scheduleAtFixedRate()方法安排指定的任务在指定的时间开始进行重复的固定速率执行。以近似固定的时间间隔（由指定的周期分隔）进行后续执行。

简单来说就是，定时器在我们的JVM里面执行优先级并不算高，可能在执行定时器的时候进程在执行其他事情（比如垃圾回收），忙不过来，无法去执行定时器，比如说这个时候schedule安排了三秒后执行，每两秒执行一次，那么这三秒到了，没有执行，到了5秒才开始执行，那么定时器就会从这第五秒开始，每两秒执行一次。而scheduleAtFixedRate()会把这多出来两秒，在后面执行的时候给加上，使得他能够平均的去执行定时器。

用固定比率调度。使用本方法时，所有后续执行根据初始执行的时间进行调度，

从而希望减小延迟。

# Quartz #

**quartz主要有两种方式；**

**1.利用JobDetailBean包装QuartzJobBean子类（即Job类）的实例，主要是继承的方式。**

**2.利用MethodInvokingJobDetailFactoryBean工厂Bean包装普通的Java对象（即Job类）。**

**第一种继承org.springframework.scheduling.quartz.QuartzJobBean**

## 1.定义作业类： ##

public class Job  extends QuartzJobBean  {  
        //判断作业是否执行的旗标  
        private boolean isRunning = false;  
      
        //定义任务执行体  
        @Override
    	public void executeInternal(JobExecutionContext ctx)   
            throws JobExecutionException   
        {  
            if (!isRunning)  
            {  
                System.out.println("开始执行定时任务");  
                isRunning = true;  
          
            }  
        }
    }

## 2.spring配置文件中配置作业类JobDetailBean ##

jobClass属性即我们在java代码中定义的任务类，jobDataAsMap属性即该任务类中需要注入的属性值。

Quartz的作业触发器有两种，分别是

org.springframework.scheduling.quartz.SimpleTriggerBean 每隔多少时间执行一次

org.springframework.scheduling.quartz.CronTriggerBean每到什么时间执行一次

第二种CronTriggerBean，支持到指定时间运行一次，如每天03:00运行一次等。

## cronExpression表达式的语法 ##

CronTriggers往往比SimpleTrigger更有用，如果您需要基于日历的概念，而非SimpleTrigger完全指定的时间间隔，复发的发射工作的时间表。  
CronTrigger，你可以指定触发的时间表如“每星期五中午”，或“每个工作日9:30时”，甚至“每5分钟一班9:00和10:00逢星期一上午，星期三星期五“。  
即便如此，SimpleTrigger一样，CronTrigger拥有的startTime指定的时间表时生效，指定的时间表时，应停止（可选）结束时间。

#### Cron Expressions ####

cron的表达式被用来配置CronTrigger实例。 cron的表达式是字符串，实际上是由七子表达式，描述个别细节的时间表。这些子表达式是分开的空白，代表：

1.  **1.        Seconds**
2.  **2.        Minutes**
3.  **3.        Hours**
4.  **4.        Day-of-Month**
5.  **5.        Month**
6.  **6.        Day-of-Week**
7.  **7.        Year (可选字段)**

例  "0 0 12 ? \* WED" 在每星期三下午12:00 执行,

个别子表达式可以包含范围, 例如，在前面的例子里("WED")可以替换成 "MON-FRI", "MON, WED, FRI"甚至"MON-WED,SAT".

“\*” 代表整个时间段.

每一个字段都有一套可以指定有效值，如

**Seconds** (秒)         ：可以用数字0－59 表示，

**Minutes(**分)          ：可以用数字0－59 表示，

**Hours(**时)             ：可以用数字0-23表示,

**Day-of-Month(**天) ：可以用数字1-31 中的任一一个值，但要注意一些特别的月份

**Month(**月)            ：可以用0-11 或用字符串  “JAN, FEB, MAR, APR, MAY, JUN, JUL, AUG, SEP, OCT, NOV and DEC” 表示

**Day-of-Week(每周)：**可以用数字1-7表示（1 ＝ 星期日）或用字符口串“SUN, MON, TUE, WED, THU, FRI and SAT”表示

“/”：为特别单位，表示为“每”如“0/15”表示每隔15分钟执行一次,“0”表示为从“0”分开始, “3/20”表示表示每隔20分钟执行一次，“3”表示从第3分钟开始执行

“?”：表示每月的某一天，或第周的某一天

“L”：用于每月，或每周，表示为每月的最后一天，或每个月的最后星期几如“6L”表示“每月的最后一个星期五”

“W”：表示为最近工作日，如“15W”放在每月（day-of-month）字段上表示为“到本月15日最近的工作日”

““\#”：是用来指定“的”每月第n个工作日,例 在每周（day-of-week）这个字段中内容为"6\#3" or "FRI\#3" 则表示“每月第三个星期五”

1）Cron表达式的格式：秒 分 时 日 月 周 年(可选)。

字段名                 允许的值                        允许的特殊字符    
               秒                         0-59                               , - \* /    
               分                         0-59                               , - \* /    
               小时                     0-23                               , - \* /    
               日                         1-31                               , - \* ? / L W C    
               月                         1-12 or JAN-DEC         , - \* /    
               周几                     1-7 or SUN-SAT           , - \* ? / L C \#    
               年 (可选字段)     empty, 1970-2099      , - \* /

“?”字符：表示不确定的值

“,”字符：指定数个值

“-”字符：指定一个值的范围

“/”字符：指定一个值的增加幅度。n/m表示从n开始，每次增加m

“L”字符：用在日表示一个月中的最后一天，用在周表示该月最后一个星期X

“W”字符：指定离给定日期最近的工作日(周一到周五)

“\#”字符：表示该月第几个周X。6\#3表示该月第3个周五

2）Cron表达式范例：

每隔5秒执行一次：\*/5 \* \* \* \* ?

每隔1分钟执行一次：0 \*/1 \* \* \* ?

每天23点执行一次：0 0 23 \* \* ?

每天凌晨1点执行一次：0 0 1 \* \* ?

每月1号凌晨1点执行一次：0 0 1 1 \* ?

每月最后一天23点执行一次：0 0 23 L \* ?

每周星期天凌晨1点实行一次：0 0 1 ? \* L

在26分、29分、33分执行一次：0 26,29,33 \* \* \* ?

每天的0点、13点、18点、21点都执行一次：0 0 0,13,18,21 \* \* ?

## 4.配置调度工厂 ##

当然也有人是把时间指定到调度工厂里面的。  
第二种调度器是利用MethodInvokingJobDetailFactoryBean工厂Bean包装普通的Java对象（即Job类）。

1.编写作业类

作业类即普通的类：

public class InvDetailDayJob {
    	private Logger logger = LogUtils.getLogger(InvDetailDayJob.class);
    	
    
    	/**
    	 * 任务执行
    	 */
    	public void run() {
    		try {
    			logger.info("Run InvDetailDayJob at: "+new Date());
    		} catch(Exception e) {
    			logger.error("Run InvDetailDayJob error at: "+new Date() + ", with error message: " + e.getMessage());
    		}
    	}
    	
    }

## Spring配置如下： ##

<bean id="taskJob" class="com.odianyun.owms.task.job.InvDetailDayJob" />
    
    	<bean id="jobDetail"
    		class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    		<property name="group" value="job_work" />
    		<property name="name" value="job_work_name" />
    		
    		<property name="concurrent" value="false" />
    		<property name="targetObject">
    			<ref bean="taskJob" />
    		</property>
    		<property name="targetMethod">
    			<value>run</value>
    		</property>
    	</bean>
    
    	
    	<bean id="myTrigger"
    		class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    		<property name="name" value="work_default_name" />
    		<property name="group" value="work_default" />
    		<property name="jobDetail">
    			<ref bean="jobDetail" />
    		</property>
    		<property name="cronExpression">
    			
    			<value>0 0 3 * * ?</value>
    		</property>
    	</bean>

# Spring-Task #

spring task，可以将它比作一个轻量级的Quartz，而且使用起来很简单，强烈建议使用这个。

配置：

## 第一步：编写作业类 ##

@Service  
    public class TaskJob {  
        public void job1() {  
           System.out.println(“任务进行中。。。”);  
        }  
    }

## 第二步：在spring配置文件头中添加命名空间及描述 ##

## 第三步：spring配置文件中设置具体的任务 ##

<task:scheduled-tasks>   
    <task:scheduled ref="taskJob" method="job1" cron="0 * * * * ?"/>   
    </task:scheduled-tasks>  
    
    <context:component-scan base-package="com.gy.mytask " />

## 注解： ##

@Component(“taskJob”)  
    public class TaskJob {  
        @Scheduled(cron = "0 0 3 * * ?")  
        public void job1() {  
           System.out.println(“任务进行中。。。”);  
        } 
    }

<?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:aop="http://www.springframework.org/schema/aop"  
        xmlns:context="http://www.springframework.org/schema/context"  
        xmlns:tx="http://www.springframework.org/schema/tx"  
        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.0.xsd  
        http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd  
        http://www.springframework.org/schema/context   
        http://www.springframework.org/schema/jdbc/spring-jdbc-3.0.xsd  
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd  
        http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-3.0.xsd"  
        default-lazy-init="false">  
    
        <context:annotation-config />  
        <!—spring扫描注解的配置   -->  
        <context:component-scan base-package="com.gy.mytask" />  
    <!—开启这个配置，spring才能识别@Scheduled注解   -->  
        <task:annotation-driven scheduler="qbScheduler" mode="proxy"/>  
        <task:scheduler id="qbScheduler" pool-size="10"/>