SpringCloud?hystrix斷路器與局部降級問題怎么解決

這篇文章主要介紹“SpringCloud hystrix斷路器與局部降級問題怎么解決”的相關知識，小編通過實際案例向大家展示操作過程，操作方法簡單快捷，實用性強，希望這篇“SpringCloud hystrix斷路器與局部降級問題怎么解決”文章能幫助大家解決問題。

服務降級

服務壓力劇增的時候，根據當前的業務情況及流量對一些服務和頁面有策略的降級，以此緩解服務器的壓力，以保證核心任務的進行。同時保證部分甚至大分客戶能得到正確的響應。也就是當前的請求處理不了或者出錯了，給一個默認的返回。例如：雙11降級產品評價等非核心功能，保證支持和訂單的核心任務進行。

服務熔斷

就是防止服務雪崩現象出現，是服務降級的一種特殊情況。

一、Hystrix的服務使用前的問題

1、ProductController 中方法異常和超時

在商品服務 ProductController 中的方法中增加異常和超時，ProductController 中方法修改如下：

package com.hwadee.springcloud.controller;
import com.hwadee.springcloud.entity.Product;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.math.BigDecimal;
@RestController
@RequestMapping("/product")
public class ProductController {
    //方便后面講負載均衡，查看ip，此處獲取配置中的端口號和ip
    @Value("${server.port}")
    private String port;
    @Value("${spring.cloud.client.ip-address}")
    private String ip;
    @RequestMapping("/buy/{id}")
    public Product findById(@PathVariable Long id) {
        Product product = new Product();
        product.setId(id);
        // 后面需要測試負載均衡，所以返回 ip 地址及端口號
        product.setName("當前訪問商品服務地址：" + ip + ":" + port+"  "+"查詢商品訂單，訂單號："+id);
        product.setPrice(new BigDecimal(10000.0));
        System.out.println(product);
        //測試超時熔斷
        try {
            Thread.sleep(5000);
            //測試并發熔斷
            //Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return product;
    }
    @RequestMapping(value = "/delete/{id}")
    public Product deleteOrderById(@PathVariable Long id){
        Product product = new Product();
        product.setId(id);
        // 后面需要測試負載均衡，所以返回 ip 地址及端口號
        product.setName("當前訪問商品服務地址：" + ip + ":" + port+"  "+"從購物車刪除訂單，訂單號："+id);
        product.setPrice(new BigDecimal(10000.0));
        System.out.println(product);
        //測試異常熔斷
        System.out.println(10/0);
        return product;
    }
}

2、訪問查看效果

訂單服務中OrderController 中 調用商品服務 ProductController 中方法時，ProductController 中方法出現異常和超時，訪問瀏覽器的異常結果和訂單服務中的內部異常如下：

3、問題分析

在微服務架構中,我們將系統拆分成了一個個的服務單元，各單元應用間通過服務注冊與訂閱的方式互相依賴。由于每個單元都在不同的進程中運行，依賴通過遠程調用的方式執行，這樣就有可能因為網絡原因或是依賴服務自身問題出現調用故障或延遲,而這些問題會直接導致調用方的對外服務也出現延遲，若此時調用方的請求不斷增加，最后就會出現因等待出現故障的依賴方響應而形成任務積壓，線程資源無法釋放,最終導致自身服務的癱瘓，進一步甚至出現故障的蔓延最終導致整個系統的癱瘓。如果這樣的架構存在如此嚴重的隱患，那么相較傳統架構就更加的不穩定。

二、 商品服務 Hystrix的 局部降級

1、降級配置

注解 @HistrixCommand

在商品服務 ProductController 中的 findById( )和deleteOrderById( ) 方法上增加降級配置的注解 @HistrixCommand

—旦調用服務方法失敗并拋出了超時或錯誤信息后，會自動調用@HystrixCommand標注好的fallbackMethod調用類中的指定方法。

在@HistrixCommand 指定超時或異常要回調的方法，同時可以指定配置參數，例如使用@HistrixCommand 中的屬性commandProperties 指定默認超時時間，如：

fallbackMethod：指定回調方法是findByIdTimeout
commandProperties： 指定@HystrixProperty 的默認值是默認超時時間是3s

@HystrixCommand(fallbackMethod = "findByIdTimeout", commandProperties = {
        @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000")
})

2、回調(兜底降級)方法

在商品服務ProductController 中增加回調方法findByIdTimeout( ) 和deleteOrderByIdException( )，當訪問ProductController 中的 findById( )和deleteOrderById( ) 發生超時 或 異常時，會調用回調方法。

3、具體代碼

降級配置 和回調(兜底降級)方法的具體代碼如下：

import com.hwadee.springcloud.entity.Product;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.math.BigDecimal;
@RestController
@RequestMapping("/product")
public class ProductController {
    //方便后面講負載均衡，查看ip，此處獲取配置中的端口號和ip
    @Value("${server.port}")
    private String port;
    @Value("${spring.cloud.client.ip-address}")
    private String ip;
    @RequestMapping("/buy/{id}")
    @HystrixCommand(fallbackMethod = "findByIdTimeout", commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000")
    })
    public Product findById(@PathVariable Long id) {
        Product product = new Product();
        product.setId(id);
        // 后面需要測試負載均衡，所以返回 ip 地址及端口號
        product.setName("當前訪問商品服務地址：" + ip + ":" + port + "  " + "查詢商品訂單，訂單號：" + id);
        product.setPrice(new BigDecimal(50000.0));
        System.out.println(product);
        //測試超時熔斷
        try {
            Thread.sleep(5000);
            //測試并發熔斷
            //Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return product;
    }
    @RequestMapping(value = "/delete/{id}")
    @HystrixCommand(fallbackMethod = "deleteOrderByIdException")
    public Product deleteOrderById(@PathVariable Long id) {
        Product product = new Product();
        product.setId(id);
        // 后面需要測試負載均衡，所以返回 ip 地址及端口號
        product.setName("當前訪問商品服務地址：" + ip + ":" + port + "  " + "從購物車刪除訂單，訂單號：" + id);
        product.setPrice(new BigDecimal(10000.0));
        System.out.println(product);
        //測試異常熔斷
        System.out.println(10 / 0);
        return product;
    }
    public Product findByIdTimeout(Long id) {
        Product product = new Product();
        product.setId(id);
        product.setName("當前訪問商品服務地址：" + ip + ":" + port + "  " + "訪問 超時 進行降級服務");
        product.setPrice(new BigDecimal(10000.0));
        System.out.println(product);
        return product;
    }
    public Product deleteOrderByIdException(Long id) {
        Product product = new Product();
        product.setId(id);
        product.setName("當前訪問商品服務地址：" + ip + ":" + port + "  " + "訪問 異常 進行降級服務");
        product.setPrice(new BigDecimal(10000.0));
        System.out.println(product);
        return product;
    }
}

4、主啟動類激活Hstrix

在商品服務的主啟動類 ProductServerApplication 中使用注解@EnableCircuitBreaker 進行激活Hystrix，代碼如下

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
@SpringBootApplication
@EnableEurekaClient// 啟動 eureka 客戶端
@EnableCircuitBreaker // 主啟動類激活 Hystrix
public class ProductServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProductServerApplication.class, args);
    }
}

5、進行測試

將商品服務中ProductController 和 ProductServerApplication復制到 其他所有 商品服務中，進行更新代碼。

分別訪問：http://localhost:9001/product/buy/1 和 http://localhost:9001/product/delete/1 查看超時和異常服務降級。看瀏覽器和內部結果。

三、 訂單服務 Hystrix的 局部降級

1、降級配置

注解 @HistrixCommand

在訂單服務 OrderController 中的方法上增加降級配置的注解 @HistrixCommand

2、回調(兜底降級)方法

在訂單服務 OrderController 定義 回調方法 buyTimeout( Long id) 、deleteOrderException( Long id)，并設置超時服務，超時服務要比將商品服務ProductController 中的 findById( ) 超時時間短。例如：ProductController 中的 findById( ) 超時時間是 3s ，則訂單服務 OrderController 定義 回調方法 buyTimeout( ) 設定的超時時間應是 <3s 。

3、具體代碼

降級配置 和回調(兜底降級)方法的具體代碼如下：

import com.hwadee.springcloud.entity.Product;
import com.hwadee.springcloud.service.IOrderFeignService;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/order")
public class OrderController {
    @Autowired
    IOrderFeignService orderFeignService;
    @RequestMapping("/buy/{id}")
    @HystrixCommand(fallbackMethod = "buyTimeout", commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "1500")
    })
    public Product buy(@PathVariable Long id) {
        System.out.println("進入OrderController的buy方法， orderFeignService 準備調用遠端接口 findById");
        Product product = orderFeignService.findOrderById(id);
        return product;
    }
    @RequestMapping(value = "/delete/{id}")
    @HystrixCommand(fallbackMethod = "deleteOrderException")
    public Product deleteOrderById(@PathVariable Long id) {
        System.out.println("進入OrderController的deleteOrderById方法， orderFeignService 準備調用遠端接口deleteOrderById");
        Product product = orderFeignService.deleteOrderById(id);
        int i =10/0;
        return product;
    }
    public Product buyTimeout( Long id) {
        Product product = new Product();
        product.setId(id);
        product.setName("當前訂單服務訪問/order/buy/1 超時："+id);
        return product;
    }
    public Product deleteOrderException( Long id) {
        Product product = orderFeignService.deleteOrderById(id);
        product.setName("當前訂單服務訪問/order/delete/1 10/0異常："+id);
        return product;
    }
}

4、將商品服務中的超時時間為正常

將商品服務ProductController 中的 findById( ) 超時時間為正常，即程序超時時間是2s，熔斷等待時間是3s，并且要比 訂單服務 OrderController 定義 回調方法 buyTimeout( ) 中的熔斷時間大，代碼如下：

@HystrixCommand(fallbackMethod = "findByIdTimeout", commandProperties = {

// 正常超時時間是 3s 比OrderController 中定義的超時時間長。

@HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000") }) public Product findById(@PathVariable Long id) { 。。。。。

// 超時時間 2s

Thread.sleep(2000); 。。。。。

return product;

}

完整代碼如下：

import com.hwadee.springcloud.entity.Product;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import java.math.BigDecimal;
@RestController
@RequestMapping("/product")
public class ProductController {
    //方便后面講負載均衡，查看ip，此處獲取配置中的端口號和ip
    @Value("${server.port}")
    private String port;
    @Value("${spring.cloud.client.ip-address}")
    private String ip;
    @RequestMapping("/buy/{id}")
    @HystrixCommand(fallbackMethod = "findByIdTimeout", commandProperties = {
            @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000")
    })
    public Product findById(@PathVariable Long id) {
        Product product = new Product();
        product.setId(id);
        // 后面需要測試負載均衡，所以返回 ip 地址及端口號
        product.setName("當前訪問商品服務地址：" + ip + ":" + port + "  " + "查詢商品訂單，訂單號：" + id);
        product.setPrice(new BigDecimal(10000.0));
        System.out.println(product);
        //測試超時熔斷
        try {
            Thread.sleep(5000);
            //測試并發熔斷
            //Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return product;
    }
    @RequestMapping(value = "/delete/{id}")
    @HystrixCommand(fallbackMethod = "deleteOrderByIdException")
    public Product deleteOrderById(@PathVariable Long id) {
        Product product = new Product();
        product.setId(id);
        // 后面需要測試負載均衡，所以返回 ip 地址及端口號
        product.setName("當前訪問商品服務地址：" + ip + ":" + port + "  " + "從購物車刪除訂單，訂單號：" + id);
        product.setPrice(new BigDecimal(10000.0));
        System.out.println(product);
        //測試異常熔斷
        System.out.println(10 / 0);
        return product;
    }
    public Product findByIdTimeout(Long id) {
        Product product = new Product();
        product.setId(id);
        product.setName("當前訪問商品服務地址：" + ip + ":" + port + "  " + "訪問 超時 進行降級服務");
        product.setPrice(new BigDecimal(10000.0));
        System.out.println(product);
        return product;
    }
    public Product deleteOrderByIdException(Long id) {
        Product product = new Product();
        product.setId(id);
        product.setName("當前訪問商品服務地址：" + ip + ":" + port + "  " + "訪問 異常 進行降級服務");
        product.setPrice(new BigDecimal(10000.0));
        System.out.println(product);
        return product;
    }
}

5、主啟動類激活Hstrix

在訂單服務的主啟動類 OrderServerApplication 中使用注解@EnableCircuitBreaker 或 注解@EnableHystrix進行激活Hystrix，注意：@EnableHystrix包括了注解@EnableCircuitBreaker ，代碼如下

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.openfeign.EnableFeignClients;
@SpringBootApplication
@EnableEurekaClient// 啟動 eureka 客戶端
@EnableFeignClients  // 啟動 feign
@EnableCircuitBreaker // 或 @EnableHystrix  啟動 Hystrix
public class OrderServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderServerApplication.class, args);
    }
}

6、進行測試

分別訪問：http://localhost:9000/order/buy/1 和 http://localhost:9000/order/delete/1 查看超時和異常服務降級。

關于“SpringCloud hystrix斷路器與局部降級問題怎么解決”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識，可以關注億速云行業資訊頻道，小編每天都會為大家更新不同的知識點。