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原始碼後續再放出

&n