腳本之家服務器常用軟件

快捷導航

SpringCloud?hystrix斷路器與局部降級全面介紹

更新時間：2022年10月24日 16:46:23 作者：愛吃面的貓

什么是服務降級？當服務器壓力劇增的情況下，根據實際業(yè)務情況及流量，對一些服務和頁面有策略的不處理或換種簡單的方式處理，從而釋放服務器資源以保證核心交易正常運作或高效運作

服務降級

服務壓力劇增的時候，根據當前的業(yè)務情況及流量對一些服務和頁面有策略的降級，以此緩解服務器的壓力，以保證核心任務的進行。同時保證部分甚至大分客戶能得到正確的響應。也就是當前的請求處理不了或者出錯了，給一個默認的返回。例如：雙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);
            //測試并發(fā)熔斷
            //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、訪問查看效果

訪問http://localhost:9000/order/buy/1

訪問http://localhost:9000/order/delete/1

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

?

3、問題分析

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

?

二、商品服務 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( ) 發(fā)生超時或異常時，會調用回調方法。

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);
            //測試并發(fā)熔斷
            //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 查看超時和異常服務降級?？礊g覽器和內部結果。

?

三、訂單服務 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);
            //測試并發(fā)熔斷
            //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斷路器與服務降級全面介紹的文章就介紹到這了,更多相關SpringCloud hystrix斷路器內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

SpringCloud?hystrix斷路器與局部降級全面介紹

目錄

服務降級

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

1、ProductController 中方法異常和超時

2、訪問查看效果

3、問題分析

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

1、降級配置

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

3、具體代碼

4、主啟動類激活Hstrix

5、進行測試

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

1、降級配置

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

3、具體代碼

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

5、主啟動類激活Hstrix

6、進行測試

相關文章

最新評論

大家感興趣的內容

最近更新的內容

常用在線小工具

亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

SpringCloud?hystrix斷路器與局部降級全面介紹

目錄

服務降級

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

1、ProductController 中方法異常和超時

2、訪問查看效果

3、問題分析

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

1、降級配置

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

3、具體代碼

4、主啟動類激活Hstrix

5、進行測試

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

1、降級配置

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

3、具體代碼

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

5、主啟動類激活Hstrix

6、進行測試

相關文章

最新評論

大家感興趣的內容

最近更新的內容

常用在線小工具

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

1、ProductController 中方法異常和超時

2、訪問查看效果

3、問題分析

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

1、降級配置

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

4、主啟動類激活Hstrix

5、進行測試

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

1、降級配置

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

3、具體代碼

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

5、主啟動類激活Hstrix

6、進行測試