快捷導(dǎo)航

spring-cloud-gateway降級(jí)的實(shí)現(xiàn)

更新時(shí)間：2020年04月08日 08:34:29 作者：當(dāng)我遇上你

這篇文章主要介紹了spring-cloud-gateway降級(jí)的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

前言

本文主要研究一下 spring cloud gateway 如何集成 hystrix。

當(dāng)下游接口負(fù)載很大，或者接口不通等其他原因?qū)е鲁瑫r(shí)，如果接口不熔斷的話將會(huì)影響到下游接口得不到喘息，網(wǎng)關(guān)也會(huì)因?yàn)槌瑫r(shí)連接一直掛起，很可能因?yàn)橐粋€(gè)子系統(tǒng)的問題導(dǎo)致整個(gè)系統(tǒng)的雪崩。所以我們的網(wǎng)關(guān)需要設(shè)計(jì)熔斷，當(dāng)因?yàn)槿蹟嗥鞔蜷_時(shí)，網(wǎng)關(guān)將返回一個(gè)降級(jí)的應(yīng)答。

Maven 配置

添加 hystrix 依賴

pom.xml

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

項(xiàng)目實(shí)戰(zhàn)

在 provider1 服務(wù)中添加一個(gè)方法，延時(shí) 2 秒返回響應(yīng)。

  @GetMapping("/timeout")
  public String timeout() {
    try {
      Thread.sleep(2000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    System.out.println("休眠了2秒");
    return "timeout test";
  }

修改網(wǎng)關(guān)配置文件

server:
 port: 2000
spring:
 application:
  name: idc-gateway2
 redis:
  host: localhost
  port: 6379
  timeout: 6000ms # 連接超時(shí)時(shí)長(zhǎng)（毫秒）
  jedis:
   pool:
    max-active: 1000 # 連接池最大連接數(shù)（使用負(fù)值表示沒有限制）
    max-wait: -1ms   # 連接池最大阻塞等待時(shí)間（使用負(fù)值表示沒有限制）
    max-idle: 10   # 連接池中的最大空閑連接
    min-idle: 5    # 連接池中的最小空閑連接
 cloud:
  consul:
   host: localhost
   port: 8500
  gateway:
   discovery:
    locator:
     enabled: true # gateway可以通過開啟以下配置來打開根據(jù)服務(wù)的serviceId來匹配路由,默認(rèn)是大寫
   routes:
    - id: provider1
     uri: lb://idc-provider1
     predicates:
      - Path=/p1/**
     filters:
      - StripPrefix=1
      - name: Hystrix
       args:
        name: default
        fallbackUri: forward:/defaultfallback # 只有該id下的服務(wù)會(huì)降級(jí)
    - id: provider2
     uri: lb://idc-provider2
     predicates:
      - Path=/p2/**
     filters:
      - StripPrefix=1

# hystrix 信號(hào)量隔離，1.5秒后自動(dòng)超時(shí)
hystrix:
 command:
  default:
   execution:
    isolation:
     strategy: SEMAPHORE
     thread:
      timeoutInMilliseconds: 1500

網(wǎng)關(guān)添加降級(jí)處理類

@RestController
public class FallbackController {

@RequestMapping("/defaultfallback")
public Map<String,Object> defaultfallback(){
System.out.println("降級(jí)操作...");
Map<String,Object> map = new HashMap<>();
map.put("code",200);
map.put("msg","服務(wù)超時(shí)降級(jí)");
map.put("data",null);
return map;
}
}

降級(jí)測(cè)試

超時(shí)服務(wù)降級(jí)

curl http://localhost:2000/p1/timeout

返回

{"msg":"服務(wù)超時(shí)降級(jí)","code":200,"data":null}

其他異常

spring-cloud-gateway 調(diào)用下游服務(wù)返回的異常，網(wǎng)關(guān)不做任何處理，會(huì)直接返回。大家想一下為什么在網(wǎng)關(guān)不去處理下游異常呢? 因?yàn)楹芏鄷r(shí)候下游的異常是包含有效信息的(異常信息千千萬)，如果在網(wǎng)關(guān)處做了統(tǒng)一返回，就失去了返回異常的意義。

spring-cloud-starter-netflix-hystrix 內(nèi)置的 Hystrix 過濾器是
HystrixGatewayFilterFactory。感興趣的小伙伴可以自行閱讀相關(guān)源碼。

到此這篇關(guān)于spring-cloud-gateway降級(jí)的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)spring-cloud-gateway降級(jí) 內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: