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

富縣網(wǎng)站制作公司哪家好，找成都創(chuàng)新互聯(lián)公司！從網(wǎng)頁設(shè)計、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、響應(yīng)式網(wǎng)站建設(shè)等網(wǎng)站項目制作，到程序開發(fā)，運營維護。成都創(chuàng)新互聯(lián)公司于2013年開始到現(xiàn)在10年的時間，我們擁有了豐富的建站經(jīng)驗和運維經(jīng)驗，來保證我們的工作的順利進行。專注于網(wǎng)站建設(shè)就選成都創(chuàng)新互聯(lián)公司。

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下聲明相應(yīng)的版本信息，然后在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 就此處來找版本聲明。 -->  <!-- 如果有，就會繼承它；如果沒有就會報錯，告訴你沒有版本信息 -->  <!-- 優(yōu)先級：如果 dependencies 里的 dependency 已經(jīng)聲明了版本信息，就不會生效此處的版本信息了 -->  <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 工程 - 項目結(jié)構(gòu)

service 工程

① 此工程下有三個模塊：一個注冊中心以及服務(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>   <!-- 三坐標 -->  <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下引用的時候用 ${} 就可以引入該版本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 代替實例名  prefer-ip-address: true  # 實例的主機名  hostname: ${spring.cloud.client.ip-address}  # 實例的 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/

這里使用了默認的 8761 端口，當然也可以更改，不過在發(fā)現(xiàn)調(diào)用服務(wù)端的注冊中心地址端口要與它一致

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 主頁面

服務(wù)工程 A（提供者和消費者）

服務(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>   <!-- 三坐標 -->  <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下引用的時候用 ${} 就可以引入該版本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依賴：提供和注冊服務(wù)  加入 Feign 的起步依賴spring-cloud-starter-openfeign：消費服務(wù)  加入依賴 spring-boot-starter-actuator：開啟并配置端點  加入依賴 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 代替實例名  prefer-ip-address: true  # 實例的主機名  hostname: ${spring.cloud.client.ip-address}  # 實例的 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)控端點    include: hystrix.stream   base-path: /

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

服務(wù)工程 A- application.properties（注意）

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

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

服務(wù)工程 A- bootstrap.yml（注意）

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

斷路器要主動開啟，服務(wù)調(diào)用失敗時才會熔斷  此處有一個坑，把此配置寫到 application.yml中熔斷不會生效  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 */@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;  } }

提供一個服務(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)用哪個服務(wù)  dashboard-b 就是提供者的spring.application.name：應(yīng)用名稱  通過 @FeignClient 注解中 fallback= FeignApiFallBack.class 來指定熔斷時調(diào)用的方法  FeignApiFallBack 就是此類（FeignApi）的實現(xiàn)類，對應(yīng)的實現(xiàn)方法就是此類的熔斷時調(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 */@Componentpublic class FeignApiFallBack implements FeignApi {   /*   * @ClassName FeignApiFallBack   * @Desc TODO  調(diào)用 dashboard-b 服務(wù)中的 b() 方法失敗時執(zhí)行   * @Date 2019/5/20 23:31   * @Version 1.0   */  @Override  public String b() {    return "Hello！aUseB fail";  }}

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

實現(xiàn)了FeignApi 接口，提供熔斷時對應(yīng)的方法

服務(wù)工程 A- controller 前端控制器（消費服務(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 */@RestControllerpublic 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)用的實則是提供者的服務(wù)

服務(wù)工程 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 注解表示此工程可以向注冊中心提供服務(wù)  添加@EnableFeignClients 注解表示開啟 Feign 功能進行遠程調(diào)用  添加@EnableHystrix 注解表示開啟熔斷器  添加 @EnableHystrixDashboard 注解表示開啟熔斷監(jiān)控

服務(wù)工程 A- 啟動項目

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

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

3. 此時還未調(diào)用服務(wù)，所以一直顯示 'Loading ...'

4. 另起頁面訪問：http://localhost:8090/a（調(diào)用自己的服務(wù)）

5.輸出內(nèi)容：'Hello！I'm a. port：8090'

6. 這是熔斷監(jiān)控頁面還是不會有所改變，因為在調(diào)用別人的服務(wù)時才會有相關(guān)數(shù)據(jù)

7.訪問地址：http://localhost:8090/aUseB（調(diào)用 B 工程的服務(wù)）

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

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

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

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

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

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

14. 左邊的六個數(shù)字對應(yīng)著頁面右上角的六個狀態(tài)（Success、Short-Circuited..）

service 工程 -項目結(jié)構(gòu)

把多工程項目使用 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，F(xiàn)inish  點擊 Apply，OK

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

當前文章：SpringCloud中怎么利用HystrixDashboard實現(xiàn)熔斷監(jiān)控
文章地址：http://www.rwnh.cn/article30/jsdhpo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供微信小程序、外貿(mào)建站、網(wǎng)頁設(shè)計公司、網(wǎng)站制作、企業(yè)建站、響應(yīng)式網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)