這篇文章將為大家詳細(xì)講解有關(guān)SpringCloud中怎么利用HystrixDashboard實(shí)現(xiàn)熔斷監(jiān)控，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關(guān)知識有一定的了解。
富縣網(wǎng)站制作公司哪家好，找成都創(chuàng)新互聯(lián)公司！從網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、響應(yīng)式網(wǎng)站建設(shè)等網(wǎng)站項(xiàng)目制作，到程序開發(fā)，運(yùn)營維護(hù)。成都創(chuàng)新互聯(lián)公司于2013年開始到現(xiàn)在10年的時間，我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn)，來保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選成都創(chuàng)新互聯(lián)公司。
commons 工程
commons 工程 - POM 文件
配置一些共用依賴
commons 工程 - 項(xiàng)目結(jié)構(gòu)
service 工程
① 此工程下有三個模塊：一個注冊中心以及服務(wù) A、B
②A 提供服務(wù)并且調(diào)用服務(wù) B 以及B 提供服務(wù)
registry-service（注冊中心）
registry-service - POM 文件
主要是加入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 - 啟動類
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 - 啟動項(xiàng)目
. 項(xiàng)目啟動成功后訪問http://localhost:8761/即可看到eureka-server 主頁面
服務(wù)工程 A（提供者和消費(fèi)者）
服務(wù)工程 A- POM 文件
加入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)用時需要用到，它在消費(fèi)的同時也可以被消費(fèi) 另一個服務(wù)工程 B 配置與此類似，只是端口不一樣，不再贅述 在 2.0 后需要主動開啟端點(diǎn) 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）的實(shí)現(xiàn)類，對應(yīng)的實(shí)現(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 管理
實(shí)現(xiàn)了FeignApi 接口，提供熔斷時對應(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 */@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)用的實(shí)則是提供者的服務(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 功能進(jìn)行遠(yuǎn)程調(diào)用 添加@EnableHystrix 注解表示開啟熔斷器 添加 @EnableHystrixDashboard 注解表示開啟熔斷監(jiān)控
服務(wù)工程 A- 啟動項(xiàng)目
1.項(xiàng)目啟動成功后訪問：http://localhost:8090/hystrix可以看到
2. 在中間的輸入框中輸入：http://127.0.0.1:8090/hystrix.stream，點(diǎn)擊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)控頁面還是不會有所改變，因?yàn)樵谡{(diào)用別人的服務(wù)時才會有相關(guān)數(shù)據(jù)
7.訪問地址：http://localhost:8090/aUseB（調(diào)用 B 工程的服務(wù)）
8.輸出內(nèi)容：'Hello！aUseB fail' （此時因?yàn)?B 工程還未啟動，所以調(diào)用了 fallback中的方法）
9. 再觀察步驟 2 中的熔斷監(jiān)控頁面，可以看到
10.啟動服務(wù)工程 B，項(xiàng)目啟動成功后再次訪問：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 工程 -項(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)擊 ImportModule 還是打開你下載到本地的項(xiàng)目目錄 springcloud-dashboard ->springcloud-dashboard-commons -> pom.xml 點(diǎn)擊 OK 點(diǎn)擊 Next，F(xiàn)inish 點(diǎn)擊 Apply，OK
關(guān)于SpringCloud中怎么利用HystrixDashboard實(shí)現(xiàn)熔斷監(jiān)控就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。
重慶分公司
重慶分公司
