【译】Spring 4 基于TaskScheduler实现定时任务(注解)-阿里云开发者社区

开发者社区> 文艺小青年> 正文

【译】Spring 4 基于TaskScheduler实现定时任务(注解)

简介:
+关注继续查看

涉及技术及开发工具

  • 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://www.cnblogs.com/chenpi/p/6222220.html,如需转载请自行联系原作者

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
精通SpringBoot——第十篇:使用Quartz实现动态配置定时任务
spring boot 整合quartz实现数据库动态配置定时任务
17275 0
处理亿级数据的“定时任务”,如何缩短执行时间?
一次性集中处理大量数据的定时任务,优化思路是:同一份数据,减少重复计算次数;分摊CPU计算时间,尽量分散处理(甚至可以实时),而不是集中处理;减少单次计算数据量。
462 0
spring-boot | 多线程并发定时任务
刚刚看了下Spring Boot实现定时任务的文章,感觉还不错。Spring Boot 使用Spring自带的Schedule来实现定时任务变得非常简单和方便。在这里个大家分享下。
3048 0
有赞实时任务优化:Flink Checkpoint 异常解析与应用实践
本文结合 Flink 1.9 版本,重点讲述 Flink Checkpoint 原理流程以及常见原因分析,让用户能够更好的理解 Flink Checkpoint,从而开发出更健壮的实时任务。
1288 0
SpringBoot ~ 启动系统任务
启动系统任务 ​ SpringBoot对于系统启动时执行的任务,例如配置文件加载,数据库初始化等操作提供了两种解决方案:CommandLineRunner和ApplicationRunner,两者差别主要在于参数。
526 0
SpringBoot整合Quartz定时任务
记录一个SpringBoot 整合 Quartz 的Demo实例   POM.XML文件 org.quartz-scheduler quartz 1.
953 0
spring boot2 整合(四)定时任务Scheduled || Quartz并持久化
在进入正文前,我想把所有java可以实现的定时任务介绍一下,其实这个也是底层实现思路。 本教程大概目录: 线程等待实现定时任务 用Timer实现定时任务 用ScheduledExecutorService实现定时任务 Quartz 定时任务框架单...
1570 0
Spring整合的quartz任务调度的实现方式
一、在web.xml中将配置文件的位置指定好。 Web.xml的配置如下: &lt;?xmlversion="1.0"encoding="UTF-8"?&gt; &lt;web-appversion="2.5"       xmlns="http://java.sun.com/xml/ns/javaee"       xmlns:xsi="http://www.w3.org/20
1058 0
3576
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
文娱运维技术
立即下载
《SaaS模式云原生数据仓库应用场景实践》
立即下载
《看见新力量:二》电子书
立即下载