SpringCloud 2020.0.4 系列之服務降級

1. 概述

老話說的好：做人要正直，做事要正派，胸懷坦蕩、光明磊落，才會赢得他人的信賴與尊敬。

言歸正傳，之前聊了服務間通信的元件 Feign，今天我們來聊聊服務降級。

服務降級簡單的了解就是給一個備選方案，當服務調用報錯或者逾時時，能終止遠端調用，并很快的傳回備選的結果，避免引發服務雪崩。

今天我們用兩個例子，模拟一下 接口報錯 和 接口逾時 的服務降級實作。

我們使用 hystrix 實作服務降級，雖然從 Spring Cloud 2020.0 版本開始，移除了 hystrix 元件，但并不影響我們對他的使用。

閑話不多說，直接上代碼。

2. 接口報錯的服務降級

2.1 被調用服務

2.1.1 接口代碼

@GetMapping("/exception")
    String exception() throws Exception;      

2.1.2 實作類代碼

@Override
    public String exception() throws Exception {
        if(1==1) {
            throw new Exception("模拟異常");
        }
        return null;
    }      

2.2 調用服務

2.2.1 主要依賴

<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</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-openfeign</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            <version>2.2.9.RELEASE</version>
        </dependency>      

這裡 hystrix 使用目前的最新版本 2.2.9.RELEASE。

2.2.2 主要配置

feign:
  circuitbreaker:
    enabled: true   # 開啟 feign 的斷路器

hystrix:
  command:
    default:
      fallback:
        enabled: true     # 開啟服務降級      

2.2.3 降級工廠類的開發

@Component
public class MyEurekaClientServiceFactory implements FallbackFactory<EurekaClientService> {
    @Override
    public EurekaClientService create(Throwable cause) {

        return new EurekaClientService() {
            
            @Override
            public String exception() throws Exception {
                System.out.println("exception方法 降級");
                return "exception方法 降級";
            }
        };
    }
}      

2.2.4 在 Feign 接口配置降級工廠類

@FeignClient(name = "my-eureka-client", fallbackFactory = MyEurekaClientServiceFactory.class)  // name為 調用服務的名稱
@RequestMapping("/api")
public interface EurekaClientService {

    @GetMapping("/exception")
    String exception() throws Exception;

}      

2.2.5 啟動類增加 @EnableHystrix 注解

@SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
@EnableHystrix
public class MyFeignApplication {

    public static void main(String[] args) {
        SpringApplication.run(MyFeignApplication.class, args);
    }
}      

2.2.6 啟動服務測試

可以正常進入降級方法。

3. 接口逾時的服務降級

3.1 被調用服務

3.1.1 接口代碼

@GetMapping("/timeout")
    String timeout(@RequestParam Integer timeoutSecond);      

3.1.2 實作類代碼

@Override
    public String timeout(Integer timeoutSecond) {
        System.out.println("調用timeout方法");
        try {
            Thread.sleep(timeoutSecond * 1000L);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return "success：" + port;
    }      

3.2 調用服務

3.2.1 主要配置

feign:
  client:
    config:
      # 全局配置
      default:
        connectTimeout: 1000   # 連接配接逾時時間，機關ms
        readTimeout: 3000         # 擷取Response響應逾時時間，機關ms

      # 針對 my-eureka-client 的 feign 配置，優先級高于全局配置
      my-eureka-client:
        connectTimeout: 300   # 連接配接逾時時間，機關ms
        readTimeout: 5000         # 擷取Response響應逾時時間，機關ms
  circuitbreaker:
    enabled: true   # 開啟 feign 的斷路器


hystrix:
  command:
    default:
      fallback:
        enabled: true     # 開啟服務降級
      execution:
        timeout:
          enabled: true   # 全局逾時配置
        isolation:
          thread:
            timeoutInMilliseconds: 3000    # 逾時時間配置
            interruptOnTimeout: true       # 逾時後是否終止線程
            interruptOnFutureCancel: true  # 取消後是否終止線程      

注意：feign 的 readTimeout 屬性和 hystrix 的 timeoutInMilliseconds 屬性會同時生效，以逾時時間最短的為準。

3.2.2 降級工廠類的開發

@Component
public class MyEurekaClientServiceFactory implements FallbackFactory<EurekaClientService> {
    @Override
    public EurekaClientService create(Throwable cause) {

        return new EurekaClientService() {
            
            @Override
            public String exception() throws Exception {
                System.out.println("exception方法 降級");
                return "exception方法 降級";
            }

            @Override
            public String timeout(Integer timeoutSecond) {
                return "timeout方法 降級";
            }
        };
    }
}      

3.2.3 啟動服務測試

4. 綜述

今天聊了一下 服務降級 的相關知識，希望可以對大家的工作有所幫助。

歡迎幫忙點贊、評論、轉發、加關注 ：）

關注追風人聊Java，每天更新Java幹貨。

5. 個人公衆号