【譯】Spring 4 基於TaskScheduler實現定時任務（注解）

前言

譯文鏈接：http://websystique.com/spring/spring-job-scheduling-with-scheduled-enablescheduling-annotations/

本文展示如何使用Spring的@Scheduled和@EnableScheduling注解來實現任務調度功能。

涉及技術及開發工具

• Spring 4.0.6.RELEASE
• Maven 3
• JDK 1.6
• Eclipse JUNO Service Release 2

工程目錄結構

步驟一：往pom.xml中添加依賴

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
 
    <groupId>com.websystique.spring</groupId>
    <artifactId>SpringSchedulingAnnotationExample</artifactId>
    <version>1.0.0</version>
    <packaging>jar</packaging>
    <name>SpringSchedulingAnnotationExample</name>
 
    <properties>
        <springframework.version>4.0.6.RELEASE</springframework.version>
    </properties>
 
    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-core</artifactId>
            <version>${springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${springframework.version}</version>
        </dependency>
    </dependencies>
    <build>
        <pluginManagement>
            <plugins>
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-compiler-plugin</artifactId>
                    <version>3.2</version>
                    <configuration>
                        <source>1.6</source>
                        <target>1.6</target>
                    </configuration>
                </plugin>
            </plugins>
        </pluginManagement>
    </build>
 
</project>

步驟二：創建Spring配置類

Spring配置類是指用@Configuration注解標注的類，這些類包含了用@Bean標注的方法。這些被@Bean標注的方法可以生成bean並交由spring容器管理。

package com.websystique.spring.config;
 
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
 
import com.websystique.spring.scheduling.MyBean;
 
@Configuration
@EnableScheduling
public class AppConfig {
 
    @Bean
    public MyBean bean() {
        return new MyBean();
    }
 
}

這里要注意下@EnableScheduling注解，該注解開啟了Spring的定時任務能力，使用該注解后，所有被@Scheduler標注的bean方法將會被注冊用於調度。

如下是bean類：

package com.websystique.spring.scheduling;
 
import org.springframework.scheduling.annotation.Scheduled;
 
public class MyBean {
 
    @Scheduled(fixedRate=5000)
    public void printMessage() {
        System.out.println("I am called by Spring scheduler");
    }
}

以上被@Scheduled標注的方法會每隔五秒調用一次；

注意被@Scheduled標注的方法返回值是void且不能有參數，當然你可以注入其它bean，然后在printMessage方法內部實現其它額外功能。

@Scheduled注解提供若干種屬性配置用於指定不同的調度時間：

initialDelay：在方法第一次執行之前等待的毫秒數；

fixedRate：方法每次開始執行的毫秒間隔，與該方法什么時候執行結束無關；

fixedDelay：上一次方法執行結束到下一次方法開始執行的毫秒間隔；

cron：提供更加詳細的控制，如@Scheduled(cron=*/5 * * * * MON-FRI")表示在工作日每隔五秒執行一次

步驟三：創建main方法執行

package com.websystique.spring;
 
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.support.AbstractApplicationContext;
 
import com.websystique.spring.config.AppConfig;
 
public class AppMain {
     
    @SuppressWarnings({ "unused", "resource" })
    public static void main(String args[]){
        AbstractApplicationContext  context = new AnnotationConfigApplicationContext(AppConfig.class);
    }
 
}

注意這里我們並沒有顯式的調用任何調度類或方法，僅僅簡單的注冊了我們的配置類；

但是，由於我們使用了@EnableScheduling注解，被@Scheduler標注的bean方法會自動注冊為計划任務去執行。

運行以上程序，結果如下：

I am called by Spring scheduler
I am called by Spring scheduler
I am called by Spring scheduler
I am called by Spring scheduler
I am called by Spring scheduler
.....

最后，假如你的任務需要花費很長的時間去完成，而且頻率很高，你可以使用指定大小的線程池去處理各個方法中的任務，如下所示：

package com.websystique.spring.config;
 
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
 
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
 
import com.websystique.spring.scheduling.MyBean;
 
@Configuration
@EnableScheduling
public class AppConfig implements SchedulingConfigurer {
 
    @Bean
    public MyBean bean() {
        return new MyBean();
    }
 
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(taskExecutor());
    }
 
    @Bean(destroyMethod="shutdown")
    public Executor taskExecutor() {
        return Executors.newScheduledThreadPool(10);
    }
 
}

以上配置使用的線程池大小為10，運行以上程序，可以得到相同的結果。

工程源碼

http://websystique.com/?smd_process_download=1&download_id=811