SpringCloud中怎么利用HystrixDashboard實現熔斷監控

這篇文章將為大家詳細講解有關SpringCloud中怎么利用HystrixDashboard實現熔斷監控，文章內容質量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關知識有一定的了解。

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>   <!-- 三坐標 -->  <groupId>com.zwc</groupId>  <artifactId>springcloud-dashboard-commons</artifactId>  <version>1.0</version>   <!-- 工程名稱和描述 -->  <name>springcloud-dashboard-commons</name>  <description>公用工程</description>   <!-- 打包方式 -->  <packaging>jar</packaging>   <!-- 在 properties下聲明相應的版本信息，然后在dependency下引用的時候用 ${} 就可以引入該版本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 就此處來找版本聲明。 -->  <!-- 如果有，就會繼承它；如果沒有就會報錯，告訴你沒有版本信息 -->  <!-- 優先級：如果 dependencies 里的 dependency 已經聲明了版本信息，就不會生效此處的版本信息了 -->  <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 工程 - 項目結構

service 工程

① 此工程下有三個模塊：一個注冊中心以及服務 A、B

②A 提供服務并且調用服務 B 以及B 提供服務

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>   <!-- 三坐標 -->  <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下聲明相應的版本信息，然后在dependency下引用的時候用 ${} 就可以引入該版本jar包了 -->  <properties>   </properties>   <!-- 加入依賴 -->  <dependencies>    <!-- commons工程 依賴 -->    <dependency>      <groupId>com.zwc</groupId>      <artifactId>springcloud-dashboard-commons</artifactId>      <version>1.0</version>    </dependency>     <!-- 服務注冊中心 -->    <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 # 應用名稱spring: application:  name: eureka-server eureka: instance:  # 使用 ip 代替實例名  prefer-ip-address: true  # 實例的主機名  hostname: ${spring.cloud.client.ip-address}  # 實例的 ID 規則  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/

這里使用了默認的 8761 端口，當然也可以更改，不過在發現調用服務端的注冊中心地址端口要與它一致

registry-service - 啟動類

package com.zwc; import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer; @SpringBootApplication@EnableEurekaServerpublic class SpringcloudDashboardRegistryServiceApplication {   public static void main(String[] args) {    SpringApplication.run(SpringcloudDashboardRegistryServiceApplication.class, args);  } }

在啟動類中添加 @EnableEurekaServer 注解表示此工程是注冊中心registry-service - 啟動項目

. 項目啟動成功后訪問http://localhost:8761/即可看到eureka-server 主頁面

服務工程 A（提供者和消費者）

服務工程 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>   <!-- 三坐標 -->  <groupId>com.zwc</groupId>  <artifactId>springcloud-dashboard-a-service-core</artifactId>  <version>1.0</version>   <!-- 工程名稱描述 -->  <name>springcloud-dashboard-a-service-core</name>  <description>服務工程 - A 核心</description>   <!-- 打包方式 -->  <packaging>jar</packaging>   <!-- 在 properties下聲明相應的版本信息，然后在dependency下引用的時候用 ${} 就可以引入該版本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>     <!-- 提供者消費者 -->    <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依賴：提供和注冊服務  加入 Feign 的起步依賴spring-cloud-starter-openfeign：消費服務  加入依賴 spring-boot-starter-actuator：開啟并配置端點  加入依賴 spring-cloud-starter-netflix-hystrix：熔斷器  加入依賴 spring-cloud-starter-netflix-hystrix-dashboard：熔斷監控

服務工程 A- application.yml配置文件

# 端口server: port: 8090 # 應用名稱spring: application:  name: dashboard-a eureka: instance:  # 使用 ip 代替實例名  prefer-ip-address: true  # 實例的主機名  hostname: ${spring.cloud.client.ip-address}  # 實例的 ID 規則  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:    # 開啟監控端點    include: hystrix.stream   base-path: /

注意此處配置注冊中心地址的端口為 8761 也就是上面注冊中心工程配置的端口  spring.application.name：應用名稱，被消費者調用時需要用到，它在消費的同時也可以被消費  另一個服務工程 B 配置與此類似，只是端口不一樣，不再贅述  在 2.0 后需要主動開啟端點 hystrix.stream，否則 404

服務工程 A- application.properties（注意）

# 開啟斷路器feign.hystrix.enabled=true

斷路器要主動開啟，服務調用失敗時才會熔斷  此處有一個坑，把此配置寫到 yml 中熔斷不會生效  application.properties 和bootstrap.yml 二選一就行

服務工程 A- bootstrap.yml（注意）

feign: hystrix:  # 開啟斷路器  enabled: true

斷路器要主動開啟，服務調用失敗時才會熔斷  此處有一個坑，把此配置寫到 application.yml中熔斷不會生效  application.properties 和bootstrap.yml 二選一就行

服務工程 A- controller 前端控制器（提供服務）

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 */@RestControllerpublic 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;  } }

提供一個服務：輸出 Hello 和端口

服務工程 A- 服務調用

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 調用 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 服務名調用 b() 方法   * @Date 2019/5/20 23:21   * @Version 1.0   */  @RequestMapping("/b")  String b(); }

通過 @FeignClient 注解中 value = "dashboard-b" 來指定調用哪個服務  dashboard-b 就是提供者的spring.application.name：應用名稱  通過 @FeignClient 注解中 fallback= FeignApiFallBack.class 來指定熔斷時調用的方法  FeignApiFallBack 就是此類（FeignApi）的實現類，對應的實現方法就是此類的熔斷時調用的方法  b()：此方法是 B 工程中提供的服務，在這里定義成接口  注意要與提供者具有相同返回值，相同方法名以及相同參數

服務工程 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 */@Componentpublic class FeignApiFallBack implements FeignApi {   /*   * @ClassName FeignApiFallBack   * @Desc TODO  調用 dashboard-b 服務中的 b() 方法失敗時執行   * @Date 2019/5/20 23:31   * @Version 1.0   */  @Override  public String b() {    return "Hello！aUseB fail";  }}

使用@Component 注解把此類交給 Spring 管理

實現了FeignApi 接口，提供熔斷時對應的方法

服務工程 A- controller 前端控制器（消費服務）

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 調用 b - 前端控制器 * @Date 2019/5/20 23:23 * @Version 1.0 */@RestControllerpublic class AUseBFeignController {   @Autowired(required = false)  private FeignApi feignApi;   /*   * @ClassName FeignController   * @Desc TODO  通過 dashboard-b 服務名調用 b() 方法   * @Date 2019/5/20 23:13   * @Version 1.0   */  @RequestMapping("/aUseB")  public String aUseB(){    return feignApi.b();  } }

使用 @Autowired 注解裝配 Bean，通過此 Bean 中的方法調用服務

此類對外暴露接口，調用的實則是提供者的服務

服務工程 A- 啟動類

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@EnableHystrixDashboardpublic class SpringcloudDashboardAServiceCoreApplication {   public static void main(String[] args) {    SpringApplication.run(SpringcloudDashboardAServiceCoreApplication.class, args);  } }

添加 @EnableEurekaClient 注解表示此工程可以向注冊中心提供服務  添加@EnableFeignClients 注解表示開啟 Feign 功能進行遠程調用  添加@EnableHystrix 注解表示開啟熔斷器  添加 @EnableHystrixDashboard 注解表示開啟熔斷監控

服務工程 A- 啟動項目

1.項目啟動成功后訪問：http://localhost:8090/hystrix可以看到

2. 在中間的輸入框中輸入：http://127.0.0.1:8090/hystrix.stream，點擊Monitor Stream 按鈕可以看到

3. 此時還未調用服務，所以一直顯示 'Loading ...'

4. 另起頁面訪問：http://localhost:8090/a（調用自己的服務）

5.輸出內容：'Hello！I'm a. port：8090'

6. 這是熔斷監控頁面還是不會有所改變，因為在調用別人的服務時才會有相關數據

7.訪問地址：http://localhost:8090/aUseB（調用 B 工程的服務）

8.輸出內容：'Hello！aUseB fail' （此時因為 B 工程還未啟動，所以調用了 fallback中的方法）

9. 再觀察步驟 2 中的熔斷監控頁面，可以看到

10.啟動服務工程 B，項目啟動成功后再次訪問：http://localhost:8090/aUseB（調用 B 工程的服務）

11.輸出內容：'Hello！I'm b. port：8091' （如果還未調用成功，等待一會再刷新試試）

12. 再次觀察步驟 2 中的熔斷監控頁面，可以看到

13. 紅色的百分比表示失敗率

14. 左邊的六個數字對應著頁面右上角的六個狀態（Success、Short-Circuited..）

service 工程 -項目結構

把多工程項目使用 IntelliJ IDEA 打開

把項目從 GitHub 中下載到你的本地  打開IntelliJ IDEA  點擊 File -> Open  打開你下載到本地的項目目錄  springcloud-dashboard ->springcloud-dashboard-service（選擇打開此工程）  打開 service 工程后  再次點擊 File -> Project Structrue  選擇 Modules，點擊 '+' 符號  點擊 ImportModule  還是打開你下載到本地的項目目錄  springcloud-dashboard ->springcloud-dashboard-commons -> pom.xml  點擊 OK  點擊 Next，Finish  點擊 Apply，OK

關于SpringCloud中怎么利用HystrixDashboard實現熔斷監控就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。