SpringCloud之熔斷監(jiān)控Hystrix Dashboard的實(shí)現(xiàn)
前言
SpringCloud 是微服務(wù)中的翹楚,最佳的落地方案。
SpringCloud 中的 Hystrix 組件可以實(shí)現(xiàn)熔斷,而在實(shí)際情況中,一般還需要直觀地看到各個(gè)服務(wù)的調(diào)用情況,
這時(shí),就用到了 SpringCloud 另一個(gè)組件:Hystrix Dashboard。
Hystrix Dashboard 是一款針對于 Hystrix 進(jìn)行實(shí)時(shí)監(jiān)控的工具,還提供了友好的圖形化界面。
源碼
GitHub地址:https://github.com/intomylife/SpringCloud
- JDK 1.8.0 +
- Maven 3.0 +
- SpringBoot 2.0.3
- SpringCloud Finchley.RELEASE
開發(fā)工具
IntelliJ IDEA
正文
commons 工程
commons 工程 - POM 文件
<?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> <!-- 三坐標(biāo) --> <groupId>com.zwc</groupId> <artifactId>springcloud-dashboard-commons</artifactId> <version>1.0</version> <!-- 工程名稱和描述 --> <name>springcloud-dashboard-commons</name> <description>公用工程</description> <!-- 打包方式 --> <packaging>jar</packaging> <!-- 在 properties下聲明相應(yīng)的版本信息,然后在dependency下引用的時(shí)候用 ${} 就可以引入該版本jar包了 --> <properties> <!-- 編碼 --> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <!-- jdk --> <java.version>1.8</java.version> <!-- SpringBoot --> <platform-bom.version>Cairo-SR3</platform-bom.version> <!-- SpringCloud --> <spring-cloud-dependencies.version>Finchley.RELEASE</spring-cloud-dependencies.version> </properties> <!-- 加入依賴 --> <dependencies> </dependencies> <!-- 依賴 jar 包版本管理的管理器 --> <!-- 如果 dependencies 里的 dependency 自己沒有聲明 version 元素,那么 maven 就此處來找版本聲明。 --> <!-- 如果有,就會(huì)繼承它;如果沒有就會(huì)報(bào)錯(cuò),告訴你沒有版本信息 --> <!-- 優(yōu)先級:如果 dependencies 里的 dependency 已經(jīng)聲明了版本信息,就不會(huì)生效此處的版本信息了 --> <dependencyManagement> <dependencies> <!-- SpringBoot --> <dependency> <groupId>io.spring.platform</groupId> <artifactId>platform-bom</artifactId> <version>${platform-bom.version}</version> <type>pom</type> <scope>import</scope> </dependency> <!-- SpringCloud --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud-dependencies.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <!-- 插件依賴 --> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
配置一些共用依賴
commons 工程 - 項(xiàng)目結(jié)構(gòu)
service 工程
① 此工程下有三個(gè)模塊:一個(gè)注冊中心以及服務(wù) A、B
② A 提供服務(wù)并且調(diào)用服務(wù) B 以及 B 提供服務(wù)
registry-service(注冊中心)
registry-service - POM 文件
<?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> <!-- 繼承父 --> <parent> <groupId>com.zwc</groupId> <artifactId>springcloud-dashboard-service</artifactId> <version>1.0</version> </parent> <!-- 三坐標(biāo) --> <groupId>com.zwc</groupId> <artifactId>springcloud-dashboard-registry-service</artifactId> <version>1.0</version> <!-- 工程名稱描述 --> <name>springcloud-dashboard-registry-service</name> <description>注冊中心</description> <!-- 打包方式 --> <packaging>jar</packaging> <!-- 在 properties下聲明相應(yīng)的版本信息,然后在dependency下引用的時(shí)候用 ${} 就可以引入該版本jar包了 --> <properties> </properties> <!-- 加入依賴 --> <dependencies> <!-- commons工程 依賴 --> <dependency> <groupId>com.zwc</groupId> <artifactId>springcloud-dashboard-commons</artifactId> <version>1.0</version> </dependency> <!-- 服務(wù)注冊中心 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency> </dependencies> <!-- 插件依賴 --> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
主要是加入 spring-cloud-starter-netflix-eureka-server 依賴
registry-service - application.yml 配置文件
# 端口 server: port: 8761 # 應(yīng)用名稱 spring: application: name: eureka-server eureka: instance: # 使用 ip 代替實(shí)例名 prefer-ip-address: true # 實(shí)例的主機(jī)名 hostname: ${spring.cloud.client.ip-address} # 實(shí)例的 ID 規(guī)則 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: # 是否向注冊中心注冊自己 registerWithEureka: false # 是否向注冊中心獲取注冊信息 fetchRegistry: false serviceUrl: # 注冊中心地址 defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
這里使用了默認(rèn)的 8761 端口,當(dāng)然也可以更改,不過在發(fā)現(xiàn)調(diào)用服務(wù)端的注冊中心地址端口要與它一致
registry-service - 啟動(dòng)類
package com.zwc; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; @SpringBootApplication @EnableEurekaServer public class SpringcloudDashboardRegistryServiceApplication { public static void main(String[] args) { SpringApplication.run(SpringcloudDashboardRegistryServiceApplication.class, args); } }
在啟動(dòng)類中添加 @EnableEurekaServer 注解表示此工程是注冊中心registry-service - 啟動(dòng)項(xiàng)目
. 項(xiàng)目啟動(dòng)成功后訪問 http://localhost:8761/ 即可看到 eureka-server 主頁面
服務(wù)工程 A(提供者和消費(fèi)者)
服務(wù)工程 A - POM 文件
<?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> <!-- 繼承父 --> <parent> <groupId>com.zwc</groupId> <artifactId>springcloud-dashboard-a-service</artifactId> <version>1.0</version> </parent> <!-- 三坐標(biāo) --> <groupId>com.zwc</groupId> <artifactId>springcloud-dashboard-a-service-core</artifactId> <version>1.0</version> <!-- 工程名稱描述 --> <name>springcloud-dashboard-a-service-core</name> <description>服務(wù)工程 - A 核心</description> <!-- 打包方式 --> <packaging>jar</packaging> <!-- 在 properties下聲明相應(yīng)的版本信息,然后在dependency下引用的時(shí)候用 ${} 就可以引入該版本jar包了 --> <properties> </properties> <!-- 加入依賴 --> <dependencies> <!-- commons工程 依賴 --> <dependency> <groupId>com.zwc</groupId> <artifactId>springcloud-dashboard-commons</artifactId> <version>1.0</version> </dependency> <!-- api工程 依賴 --> <dependency> <groupId>com.zwc</groupId> <artifactId>springcloud-dashboard-a-service-api</artifactId> <version>1.0</version> </dependency> <!-- 提供者消費(fèi)者 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency> <!-- feign --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId> </dependency> <!-- actuator --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId> </dependency> <!-- hystrix --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency> <!-- dashboard --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId> </dependency> </dependencies> <!-- 插件依賴 --> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
- 加入 spring-cloud-starter-netflix-eureka-client 依賴:提供和注冊服務(wù)
- 加入 Feign 的起步依賴 spring-cloud-starter-openfeign:消費(fèi)服務(wù)
- 加入依賴 spring-boot-starter-actuator:開啟并配置端點(diǎn)
- 加入依賴 spring-cloud-starter-netflix-hystrix:熔斷器
- 加入依賴 spring-cloud-starter-netflix-hystrix-dashboard:熔斷監(jiān)控
服務(wù)工程 A - application.yml 配置文件
# 端口 server: port: 8090 # 應(yīng)用名稱 spring: application: name: dashboard-a eureka: instance: # 使用 ip 代替實(shí)例名 prefer-ip-address: true # 實(shí)例的主機(jī)名 hostname: ${spring.cloud.client.ip-address} # 實(shí)例的 ID 規(guī)則 instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port} client: serviceUrl: # 注冊中心地址 defaultZone: http://${eureka.instance.hostname}:8761/eureka/ management: endpoints: web: exposure: # 開啟監(jiān)控端點(diǎn) include: hystrix.stream base-path: /
- 注意此處配置注冊中心地址的端口為 8761 也就是上面注冊中心工程配置的端口
- spring.application.name:應(yīng)用名稱,被消費(fèi)者調(diào)用時(shí)需要用到,它在消費(fèi)的同時(shí)也可以被消費(fèi)
- 另一個(gè)服務(wù)工程 B 配置與此類似,只是端口不一樣,不再贅述
- 在 2.0 后需要主動(dòng)開啟端點(diǎn) hystrix.stream,否則 404
服務(wù)工程 A - application.properties(注意)
# 開啟斷路器 feign.hystrix.enabled=true
- 斷路器要主動(dòng)開啟,服務(wù)調(diào)用失敗時(shí)才會(huì)熔斷
- 此處有一個(gè)坑,把此配置寫到 yml 中熔斷不會(huì)生效
- application.properties 和 bootstrap.yml 二選一就行
服務(wù)工程 A - bootstrap.yml(注意)
feign: hystrix: # 開啟斷路器 enabled: true
- 斷路器要主動(dòng)開啟,服務(wù)調(diào)用失敗時(shí)才會(huì)熔斷
- 此處有一個(gè)坑,把此配置寫到 application.yml 中熔斷不會(huì)生效
- application.properties 和 bootstrap.yml 二選一就行
服務(wù)工程 A - controller 前端控制器(提供服務(wù))
package com.zwc.a.controller; import org.springframework.beans.factory.annotation.Value; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; /* * @ClassName ASayHelloController * @Desc TODO Say Hello * @Date 2019/5/20 23:24 * @Version 1.0 */ @RestController public class ASayHelloController { /* * @ClassName ASayHelloController * @Desc TODO 讀取配置文件中的端口 * @Date 2019/5/20 23:24 * @Version 1.0 */ @Value("${server.port}") private String port; /* * @ClassName ASayHelloController * @Desc TODO Say Hello * @Date 2019/5/20 23:24 * @Version 1.0 */ @RequestMapping("/a") public String a(){ return "Hello!I'm a. port:" + port; } }
提供一個(gè)服務(wù):輸出 Hello 和端口
服務(wù)工程 A - 服務(wù)調(diào)用
package com.zwc.a.api.feign; import com.zwc.a.api.impl.FeignApiFallBack; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.RequestMapping; /* * @ClassName FeignApi * @Desc TODO 使用 Feign 調(diào)用 b - 接口 * @Date 2019/5/20 23:21 * @Version 1.0 */ @FeignClient(value = "dashboard-b" , fallback = FeignApiFallBack.class) public interface FeignApi { /* * @ClassName FeignApi * @Desc TODO 通過 dashboard-b 服務(wù)名調(diào)用 b() 方法 * @Date 2019/5/20 23:21 * @Version 1.0 */ @RequestMapping("/b") String b(); }
- 通過 @FeignClient 注解中 value = "dashboard-b" 來指定調(diào)用哪個(gè)服務(wù)
- dashboard-b 就是提供者的 spring.application.name:應(yīng)用名稱
- 通過 @FeignClient 注解中 fallback = FeignApiFallBack.class 來指定熔斷時(shí)調(diào)用的方法
- FeignApiFallBack 就是此類(FeignApi)的實(shí)現(xiàn)類,對應(yīng)的實(shí)現(xiàn)方法就是此類的熔斷時(shí)調(diào)用的方法
- b():此方法是 B 工程中提供的服務(wù),在這里定義成接口
- 注意要與提供者具有相同返回值,相同方法名以及相同參數(shù)
服務(wù)工程 A - Fallback(FeignApiFallBack)
package com.zwc.a.api.impl; import com.zwc.a.api.feign.FeignApi; import org.springframework.stereotype.Component; /* * @ClassName FeignApi * @Desc TODO fallback * @Date 2019/5/20 23:21 * @Version 1.0 */ @Component public class FeignApiFallBack implements FeignApi { /* * @ClassName FeignApiFallBack * @Desc TODO 調(diào)用 dashboard-b 服務(wù)中的 b() 方法失敗時(shí)執(zhí)行 * @Date 2019/5/20 23:31 * @Version 1.0 */ @Override public String b() { return "Hello!aUseB fail"; } }
使用 @Component 注解把此類交給 Spring 管理
實(shí)現(xiàn)了 FeignApi 接口,提供熔斷時(shí)對應(yīng)的方法
服務(wù)工程 A - controller 前端控制器(消費(fèi)服務(wù))
package com.zwc.a.controller; import com.zwc.a.api.feign.FeignApi; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; /* * @ClassName AUseBFeignController * @Desc TODO 使用 Feign 調(diào)用 b - 前端控制器 * @Date 2019/5/20 23:23 * @Version 1.0 */ @RestController public class AUseBFeignController { @Autowired(required = false) private FeignApi feignApi; /* * @ClassName FeignController * @Desc TODO 通過 dashboard-b 服務(wù)名調(diào)用 b() 方法 * @Date 2019/5/20 23:13 * @Version 1.0 */ @RequestMapping("/aUseB") public String aUseB(){ return feignApi.b(); } }
使用 @Autowired 注解裝配 Bean,通過此 Bean 中的方法調(diào)用服務(wù)
此類對外暴露接口,調(diào)用的實(shí)則是提供者的服務(wù)
服務(wù)工程 A - 啟動(dòng)類
package com.zwc; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; import org.springframework.cloud.netflix.hystrix.EnableHystrix; import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard; import org.springframework.cloud.openfeign.EnableFeignClients; @SpringBootApplication @EnableEurekaClient @EnableFeignClients @EnableHystrix @EnableHystrixDashboard public class SpringcloudDashboardAServiceCoreApplication { public static void main(String[] args) { SpringApplication.run(SpringcloudDashboardAServiceCoreApplication.class, args); } }
- 添加 @EnableEurekaClient 注解表示此工程可以向注冊中心提供服務(wù)
- 添加 @EnableFeignClients 注解表示開啟 Feign 功能進(jìn)行遠(yuǎn)程調(diào)用
- 添加 @EnableHystrix 注解表示開啟熔斷器
- 添加 @EnableHystrixDashboard 注解表示開啟熔斷監(jiān)控
服務(wù)工程 A - 啟動(dòng)項(xiàng)目
1. 項(xiàng)目啟動(dòng)成功后訪問:http://localhost:8090/hystrix 可以看到
2. 在中間的輸入框中輸入:http://127.0.0.1:8090/hystrix.stream ,點(diǎn)擊 Monitor Stream 按鈕可以看到
3. 此時(shí)還未調(diào)用服務(wù),所以一直顯示 'Loading ...'
4. 另起頁面訪問:http://localhost:8090/a (調(diào)用自己的服務(wù))
5. 輸出內(nèi)容:'Hello!I'm a. port:8090'
6. 這是熔斷監(jiān)控頁面還是不會(huì)有所改變,因?yàn)樵谡{(diào)用別人的服務(wù)時(shí)才會(huì)有相關(guān)數(shù)據(jù)
7. 訪問地址:http://localhost:8090/aUseB (調(diào)用 B 工程的服務(wù))
8. 輸出內(nèi)容:'Hello!aUseB fail' (此時(shí)因?yàn)?B 工程還未啟動(dòng),所以調(diào)用了 fallback 中的方法)
9. 再觀察步驟 2 中的熔斷監(jiān)控頁面,可以看到
10. 啟動(dòng)服務(wù)工程 B,項(xiàng)目啟動(dòng)成功后再次訪問:http://localhost:8090/aUseB (調(diào)用 B 工程的服務(wù))
11. 輸出內(nèi)容:'Hello!I'm b. port:8091' (如果還未調(diào)用成功,等待一會(huì)再刷新試試)
12. 再次觀察步驟 2 中的熔斷監(jiān)控頁面,可以看到
13. 紅色的百分比表示失敗率
14. 左邊的六個(gè)數(shù)字對應(yīng)著頁面右上角的六個(gè)狀態(tài)(Success、Short-Circuited..)
service 工程 - 項(xiàng)目結(jié)構(gòu)
把多工程項(xiàng)目使用 IntelliJ IDEA 打開
- 把項(xiàng)目從 GitHub 中下載到你的本地
- 打開 IntelliJ IDEA
- 點(diǎn)擊 File -> Open
- 打開你下載到本地的項(xiàng)目目錄
- springcloud-dashboard -> springcloud-dashboard-service(選擇打開此工程)
- 打開 service 工程后
- 再次點(diǎn)擊 File -> Project Structrue
- 選擇 Modules,點(diǎn)擊 '+' 符號
- 點(diǎn)擊 Import Module
- 還是打開你下載到本地的項(xiàng)目目錄
- springcloud-dashboard -> springcloud-dashboard-commons -> pom.xml
- 點(diǎn)擊 OK
- 點(diǎn)擊 Next,F(xiàn)inish
- 點(diǎn)擊 Apply,OK
以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Spring Boot配置application.yml及根據(jù)application.yml選擇啟動(dòng)配置的操作
Spring Boot中可以選擇applicant.properties 作為配置文件,也可以通過在application.yml中進(jìn)行配置,讓Spring Boot根據(jù)你的選擇進(jìn)行加載啟動(dòng)配置文件,本文給大家介紹Spring Boot配置application.yml及根據(jù)application.yml選擇啟動(dòng)配置的操作方法,感興趣的朋友一起看看吧2023-10-10maven多模塊項(xiàng)目單獨(dú)打包指定模塊jar包方式
這篇文章主要介紹了maven多模塊項(xiàng)目單獨(dú)打包指定模塊jar包方式,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-09-09Spring Boot使用AOP防止重復(fù)提交的方法示例
這篇文章主要介紹了Spring Boot使用AOP防止重復(fù)提交的方法示例,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2019-05-05MyBatis?實(shí)現(xiàn)多對多中間表插入數(shù)據(jù)
這篇文章主要介紹了MyBatis?實(shí)現(xiàn)多對多中間表插入數(shù)據(jù),具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-02-02一文看懂springboot實(shí)現(xiàn)短信服務(wù)功能
項(xiàng)目中的短信服務(wù)基本上上都會(huì)用到,簡單的注冊驗(yàn)證碼,消息通知等等都會(huì)用到。這篇文章主要介紹了springboot 實(shí)現(xiàn)短信服務(wù)功能,需要的朋友可以參考下2019-10-10