服務在經過一定負荷之後，如果達到一定上限之後會中斷進行報錯，而服務呼叫的方法也會報錯等等，一旦整體服務停下，別的客戶端再來訪問就會無法呼叫。對此需要進行另外一種服務熔斷模式。

不同於現實中的熔斷保險絲，服務熔斷是在系統服務達到一定錯誤之後，自動熔斷降級，採取備用方法，但是在一定時間後客戶端再次呼叫成功後，一定時間內成功率上去，系統的熔斷機制會慢慢的關閉，恢復到正常請求的狀態。

本篇接上一章直接改動。

1.主啟動類加上新的註解。

@EnableCircuitBreaker

2.service寫入新的熔斷控制方法

@Service
public class PaymentHystrixService {
  @HystrixCommand(fallbackMethod 
 
= "paymentCircuitBreaker_fallback",commandProperties = {
            @HystrixProperty(name = "circuitBreaker.enabled", value = "true"),              //是否開啟斷路器
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),    //請求數達到後才計算
            @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"), //
 
休眠時間窗
            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "60"),  //錯誤率達到多少跳閘
    })
    public String paymentCirtuitBreaker(@PathVariable("id")Integer id){
      if(id<0){
          throw new RuntimeException("****id不能為負數");
      }
      String randomNum= IdUtil.simpleUUID();

      
 
return Thread.currentThread().getName()+"\t"+"呼叫成功，編號"+randomNum;

    }
    public String paymentCircuitBreaker_fallback(@PathVariable("id")Integer id){
        return "id不能為負數，請稍後重試，o(╥﹏╥)o+"+id;
    }

此處hystrixCommand註解即是對熔斷的一些限制，一般是在10秒內進行10次有60%的訪問錯誤率就會進行熔斷，自動啟動備用的方法，預設5秒後有 正確的執行結果就會慢慢恢復正常狀態，關閉斷路器。

3.dashboard

為了能夠更加直觀的看見服務訪問的一些情況，配置下視覺化的網頁觀察熔斷。

新建dashboard工程。

pom檔案依賴

<dependencies>
        <dependency>
            <groupId>com.bai</groupId>
            <artifactId>cloud-api-common</artifactId>
            <version>${project.version}</version>
        </dependency>
        <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-hystrix</artifactId>
        </dependency>
        <!--eureka client-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <!--熱部署-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-devtools</artifactId>
            <scope>runtime</scope>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

主啟動類

@SpringBootApplication
@EnableHystrixDashboard
public class HystrixDashboard9001 {
    public static void main(String[] args) {
        SpringApplication.run(HystrixDashboard9001.class,args);
    }
}

yml配置下埠即可。

訪問地址

http://localhost:9001/hystrix/

對於被監控的服務需要額外的配置。新版本會有報錯需要在啟動類加上如下配置。

/**
         * 此配置是為了服務監控而配置，與服務容錯本身無關，springcloud升級後的坑
         * ServletRegistrationBean因為SpringBoot的預設路徑不是 “/hystrix.stream"
         * 只要在自己的專案裡配置上下的servlet就可以了
         */
        @Bean
        public ServletRegistrationBean getServlet() {
            HystrixMetricsStreamServlet streamServlet = new HystrixMetricsStreamServlet() ;
            ServletRegistrationBean registrationBean = new ServletRegistrationBean(streamServlet);
            registrationBean.setLoadOnStartup(1);
            registrationBean.addUrlMappings("/hystrix.stream");
            registrationBean.setName("HystrixMetricsStreamServlet");
            return  registrationBean;
        }