SpringCloud(第 046 篇)注解式Schedule配置定時任務(wù),不支持任務(wù)調(diào)度
一、大致介紹
1沧侥、很多時候我們需要隔一定的時間去執(zhí)行某個任務(wù)可霎,為了實現(xiàn)這樣的需求通常最普通的方式就是利用多線程來實現(xiàn);
2宴杀、但是有時候這個任務(wù)還真得去處理一些非常復(fù)雜非常耗時的動作癣朗,那么在SpringCloud生態(tài)圈中,Scheduled不失為一種好的解決方案旺罢;
3旷余、不過我們這里介紹的Scheduled如果部署在多臺服務(wù)的話,那么每臺都會執(zhí)行主经,不支持任務(wù)調(diào)度荣暮;
4、若要支持任務(wù)調(diào)度的話罩驻,請回頭查看(第 010 篇)簡單 Quartz-Cluster 微服務(wù)穗酥,支持集群任務(wù)調(diào)度;
二惠遏、實現(xiàn)步驟
2.1 添加 maven 引用包
<?xml version="1.0" encoding="UTF-8"?>
<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>
<artifactId>springms-schedule</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>jar</packaging>
<parent>
<groupId>com.springms.cloud</groupId>
<artifactId>springms-spring-cloud</artifactId>
<version>1.0-SNAPSHOT</version>
</parent>
<dependencies>
<!-- 訪問數(shù)據(jù)庫模塊 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<!-- web模塊 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- MYSQL -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
</dependencies>
</project>
2.2 添加應(yīng)用配置文件(springms-schedule\src\main\resources\application.yml)
server:
port: 8340
spring:
application:
name: springms-schedule #全部小寫
2.3 添加定時任務(wù)類(springms-schedule\src\main\java\com\springms\cloud\task\ScheduledTasks.java)
package com.springms.cloud.task;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* 定時任務(wù)類砾跃。
*
* @author hmilyylimh
*
* @version 0.0.1
*
* @date 2017/10/19
*
*/
@Component
public class ScheduledTasks {
private static final org.slf4j.Logger Logger = LoggerFactory.getLogger(ScheduledTasks.class);
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
@Scheduled(fixedRate = 1000)
public void reportCurrentTime() {
System.out.println("當(dāng)前時間: " + dateFormat.format(new Date()));
Logger.info("打印當(dāng)前時間: {}.", dateFormat.format(new Date()));
}
/**
* 定時任務(wù)觸發(fā),操作多個DAO添加數(shù)據(jù)节吮,事務(wù)中任一異常抽高,都可以正常導(dǎo)致數(shù)據(jù)回滾。
*/
@Scheduled(fixedRate = 5000)
public void addMovieJob() {
System.out.println("當(dāng)前時間: " + dateFormat.format(new Date()));
Logger.info("當(dāng)前時間: {}.", dateFormat.format(new Date()));
}
}
2.4 添加微服務(wù)啟動類(springms-schedule\src\main\java\com\springms\cloud\MsScheduleApplication.java)
package com.springms.cloud;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;
/**
* 注解式Schedule配置定時任務(wù)透绩,不支持任務(wù)調(diào)度翘骂。
*
* @author hmilyylimh
*
* @version 0.0.1
*
* @date 2017/10/19
*
*/
@SpringBootApplication
@EnableScheduling
public class MsScheduleApplication {
public static void main(String[] args) {
SpringApplication.run(MsScheduleApplication.class, args);
System.out.println("【【【【【【 Schedule定時任務(wù)微服務(wù) 】】】】】】已啟動.");
}
}
三、測試
/****************************************************************************************
一帚豪、用戶微服務(wù)接口測試:
1碳竟、注解:EnableEurekaClient
2、啟動 springms-discovery-eureka 模塊服務(wù)狸臣,啟動1個端口莹桅;
3、啟動 springms-provider-user 模塊服務(wù)烛亦,啟動1個端口诈泼;
4、在瀏覽器輸入地址http://localhost:7900/simple/1 可以看到信息成功的被打印出來煤禽,說明用戶微服務(wù)正常铐达;
5、在瀏覽器輸入地址 http://localhost:8761 并輸入用戶名密碼 admin/admin 進入Eureka微服務(wù)顯示在網(wǎng)頁中檬果,說明用戶微服務(wù)確實注冊到了 eureka 服務(wù)中娶桦;
6、在瀏覽器輸入地址 http://localhost:8761/eureka/apps/springms-provider-user 可以看到自定義的 <metadata>信息以及用戶微服務(wù)的相關(guān)信息成功的被展示出來了;
****************************************************************************************/
四衷畦、下載地址
https://gitee.com/ylimhhmily/SpringCloudTutorial.git
SpringCloudTutorial交流QQ群: 235322432
SpringCloudTutorial交流微信群: 微信溝通群二維碼圖片鏈接
歡迎關(guān)注,您的肯定是對我最大的支持!!!