0-為什么需要熔斷器
在分布式系統中，各個服務相互呼叫相互依賴，如果某個服務掛了，很可能導致其他呼叫它的一連串服務也掛掉或者在不斷等待中耗盡服務器資源，這種現象稱之為雪崩效應；
未來防止系統雪崩，熔斷機制必不可少，就是當一個服務掛掉后，呼叫它的服務能快速熔斷，不再耗費資源，快速失敗并提供回退方案；
【Hystrix】：是spring cloud的熔斷器組件，提供了熔斷器功能，能夠阻止聯動故障，并提供故障的解決方案，提供系統彈性；
【Hystrix Dashboard】：是熔斷器的監控面板，通過它，能直觀的了解熔斷器的狀況；
【Turbine】： 在Dashboard中，我們要輸入一個一個單獨的服務地址進行監控和了解；那么多服務，一個一個輸入那不是累死人，有沒有一個工具能把眾多分散的微服務熔斷器監控狀況聚合到一起，使得我們在一個Dashboard就能了解眾多服務的熔斷器監控狀況呢，有，這個工具就是Turbine；它的作用就是聚合眾多微服務的hystrix監控資料到一起，使得我們只需要在一個Dashboard就能了解所有；
一、使用hystrix
1.1、添加依賴
<!-- 斷路器 hystrix-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>
1.2、組態檔中開啟熔斷器開關
#開啟熔斷器開關 feign: hystrix: enabled: true
1.3、啟動類中增加 @EnableHystrix 注解和bean
@SpringBootApplication @EnableEurekaClient @EnableHystrix @EnableFeignClients public class application { public static void main(String[] args) { SpringApplication.run(application.class);
@Bean
public ServletRegistrationBean getServlet(){
HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet();
ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
registrationBean.setLoadOnStartup(1);
registrationBean.addUrlMappings("/actuator/hystrix.stream");
registrationBean.setName("HystrixMetricsStreamServlet");
return registrationBean;
}
} }
1.4、增加熔斷器類，實作Feign的介面
package com.anson.service.feign; import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.RequestMapping; /** * @description: 熔斷器類 * @author: anson * @Date: 2020/1/7 11:24 */ @Component public class FUserServiceHystrix implements FUserService { @RequestMapping("/user/hello") @Override public String hello() { return "對不起，user服務不可達，請稍后再試！"; } }
1.5、增加熔斷器配置類FeignConfig
package com.anson.config; import feign.Retryer; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import java.util.concurrent.TimeUnit; @Configuration public class FeignConfig { @Bean public Retryer feignRetryer() { /* * 引數說明： * 第一個> 重試間隔為100毫秒 * 第二個> 最大重試時間為1秒 * 第三個> 最大重試次數為5次 */ return new Retryer.Default(100, TimeUnit.SECONDS.toMillis(1), 5); } }
1.6、在Feign介面注解中增加fallback，指向熔斷器類
package com.anson.service.feign; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.RequestMapping;
@FeignClient(name = "user",configuration = FeignConfig.class,fallback = FUserServiceHystrix.class)
public interface FUserService
{
@RequestMapping("/user/hello")
public String hello();
}
1.7、運行測驗
user服務正常時：
user服務關閉時：
---------------------------華麗麗的分割線-------------------------------------------------------
二、Hystrix Dashboard的使用
2.1、熔斷器加了，那么我們要監控和查看hystrix的運行狀態，這時候Dashboard上場；
2.2、添加依賴：
<!-- dashboard -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
2.3、啟動類添加注解 @EnableHystrixDashboard
2.4、完成，運行測驗，打開，http://localhost:8767/hystrix
在里面填入要監控的微服務地址 +/actuator/histrix.stream，如：http://localhost:8768/actuator/histrix.stream，title也填入，點擊按鈕就可以看到結果了：如圖：
可以看到我們加入的熔斷器的運行狀態
----------------------------------------------華麗麗的分割線-----------------------------------------------------------------
三、Turbine 聚合監控資料
3.1、上面Dashboard中，我們輸入http://localhost:8767/actuator/histrix.stream，它只是現實埠8767這個微服務實體的監控資料而已，要看其他的，還得重新輸入，那能不能有個工具將所有微服務的監控資料都聚合到一起，顯示到Dashboard中呢，這個工具就是Turbine
3.2、新建一個模塊，添加相關依賴：
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-turbine</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
3,.3、修改組態檔，其中app-config是要監控的服務名，多個用逗號分隔；
server: port: 8768 spring: application: name: turbine eureka: client: serviceUrl: defaultZone: http://localhost:8761/eureka/ instance: prefer-ip-address: true turbine: combine-host-port: true app-config: order cluster-name-expression: new String("default") instanceUrlSuffix: actuator/hystrix.stream aggregator: cluster-config: default
3.4、在啟動類中添加注解@EnableTurbine；
package com.anson; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard; import org.springframework.cloud.netflix.turbine.EnableTurbine; /** * @description: TODO * @author: anson * @Date: 2020/1/6 14:27 */ @SpringBootApplication @EnableEurekaClient @EnableTurbine @EnableHystrixDashboard public class application { public static void main(String[] args) { SpringApplication.run(application.class); } }
完成，啟動運行后，他就會將所有組態檔中添加進來的服務全部的熔斷器監控資料聚合到一起了，
在任意專案的Dashboard面板中填入http://turbine-hostname:port/turbine.stream 的地址樣式，就能看到所有的監控資料了
,如 : http://localhost:8768/turbine.stream
我們只加了一個熔斷器，你可以多加幾個看看效果；
好了，熔斷器hystrix簡單講解到著，，更深入的后續再詳聊，GIT原始碼后續再放出
轉載請註明出處，本文鏈接：https://www.uj5u.com/ruanti/22632.html
標籤：架構設計