6. 任务调度

Posted 技术宅星云-博客园

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了6. 任务调度相关的知识,希望对你有一定的参考价值。

本指南将引导您完成使用Spring任务调度的步骤。阅读原文

1. 你将会构建什么?

您将构建一个应用程序,该应用程序使用Spring的@Scheduled 注解每5秒打印一次当前时间。

 2. 你将需要准备什么?

3. 如何实现这个指南?

像大多数Spring入门指南一样,您可以从头开始并完成每个步骤,也可以绕过已熟悉的基本设置步骤。 无论哪种方式,你最终得到工作代码。

1. 打开STS,New ————> Import Spring Getting Started Content

2. 输入sche 搜索找到Scheduling Tasks

Tips: Build Type 选择Maven, Code Style 我们全部勾选,这样可以生成一个写好的代码和一个空白的Project,这样很方便我们学习和研究。

3.  点击Finish之后项目已经构建完成,现在让我们创建一个scheduled task 类

src/main/java/hello/ScheduledTasks.java

package hello;

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

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

@Component
public class ScheduledTasks {

    private static final Logger log = LoggerFactory.getLogger(ScheduledTasks.class);

    private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");

    @Scheduled(fixedRate = 5000)
    public void reportCurrentTime() {
        log.info("The time is now {}", dateFormat.format(new Date()));
    }
}

Scheduled注解定义了特定方法的运行时间。 注意:此示例使用fixedRate,它指定从每次调用的开始时间开始测量的方法调用之间的时间间隔。 还有其他选项,比如fixedDelay,它指定了从任务完成之后测量的调用之间的时间间隔。 您还可以使用@Scheduled(cron =“...”)表达式来执行更复杂的任务计划。

4.启用计划

虽然计划任务可以嵌入到Web应用程序和WAR文件中,但下面演示的更简单的方法会创建一个独立的应用程序。 您将所有内容打包到一个单独的,可执行的JAR文件中,由一个良好的旧Java main()方法驱动。

src/main/java/hello/Application.java

package hello;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;

@SpringBootApplication
@EnableScheduling
public class Application {

    public static void main(String[] args) throws Exception {
        SpringApplication.run(Application.class);
    }
}

@SpringBootApplication是一个方便的注释,它增加了以下所有内容:

  • @Configuration将类标记为应用程序上下文的bean定义的来源。
  • @EnableAutoConfiguration通知Spring Boot根据类路径设置,其他bean和各种属性设置开始添加bean。
  • 通常你会为Spring MVC应用程序添加@EnableWebMvc,但Spring Boot在类路径中看到spring-webmvc时会自动添加。 这将该应用程序标记为Web应用程序并激活关键行为,例如设置DispatcherServlet。
  • @ComponentScan告诉Spring在hello包中查找其他组件,配置和服务,以便找到控制器。

main()方法使用Spring Boot的SpringApplication.run()方法启动应用程序。 你有没有注意到没有一行XML? 没有web.xml文件。 这个Web应用程序是100%纯Java,您不必处理配置任何管道或基础设施。

@EnableScheduling确保创建后台任务执行程序。 没有它,没有任何计划。

5. 编译一个可执行的Jar

您可以使用Gradle或Maven从命令行运行应用程序。 或者您可以构建一个包含所有必需的依赖项,类和资源的可执行JAR文件,并运行该文件。 这使得在整个开发生命周期内跨越不同环境等,将服务作为应用程序发布,版本化和部署变得非常容易。

执行命令后我们可以在Target目录下看到生成的可执行 jar

如果您正在使用Gradle,则可以使用./gradlew bootRun运行该应用程序。 或者您可以使用./gradlew构建构建JAR文件。 然后你可以运行JAR文件:

java -jar build/libs/gs-scheduling-tasks-0.1.0.jar

如果您使用的是Maven,则可以使用./mvnw spring-boot:run来运行该应用程序。 或者,您可以使用./mvnw clean包构建JAR文件。 然后你可以运行JAR文件:

java -jar target/gs-scheduling-tasks-0.1.0.jar

上述过程将创建一个可运行的JAR。 您也可以选择构建经典的WAR文件。

记录输出显示,您可以从日志中看到它在后台线程上。 你应该看到你的计划任务每5秒触发一次:

源码:点击查看

以上是关于6. 任务调度的主要内容,如果未能解决你的问题,请参考以下文章

工作流任务调度系统--DolphinSchedule-1.3.6 window 安装配置

XXL-JOB分布式任务调度框架-基础入门

Slurm任务调度系统部署和测试

python 一个简单的线程调度

go任务调度6(etcd租约机制/自动过期)

分布式开源调度框架TBSchedule原理与应用