我们专注攀枝花网站设计 攀枝花网站制作 攀枝花网站建设
成都网站建设公司服务热线:400-028-6601

网站建设知识

十年网站开发经验 + 多家企业客户 + 靠谱的建站团队

量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决

spring-cloud-gateway降级的实现

前言

十年的南昌网站建设经验,针对设计、前端、开发、售后、文案、推广等六对一服务,响应快,48小时及时工作处理。成都营销网站建设的优势是能够根据用户设备显示端的尺寸不同,自动调整南昌建站的显示方式,使网站能够适用不同显示终端,在浏览器中调整网站的宽度,无论在任何一种浏览器上浏览网站,都能展现优雅布局与设计,从而大程度地提升浏览体验。创新互联从事“南昌网站设计”,“南昌网站推广”以来,每个客户项目都认真落实执行。

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

当下游接口负载很大,或者接口不通等其他原因导致超时,如果接口不熔断的话将会影响到下游接口得不到喘息,网关也会因为超时连接一直挂起,很可能因为一个子系统的问题导致整个系统的雪崩。所以我们的网关需要设计熔断,当因为熔断器打开时,网关将返回一个降级的应答。

Maven 配置

添加 hystrix 依赖

pom.xml

    
      org.springframework.cloud
      spring-cloud-starter-netflix-hystrix
    

项目实战

在 provider1 服务中添加一个方法,延时 2 秒返回响应。

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

修改网关配置文件

server:
 port: 2000
spring:
 application:
  name: idc-gateway2
 redis:
  host: localhost
  port: 6379
  timeout: 6000ms # 连接超时时长(毫秒)
  jedis:
   pool:
    max-active: 1000 # 连接池最大连接数(使用负值表示没有限制)
    max-wait: -1ms   # 连接池最大阻塞等待时间(使用负值表示没有限制)
    max-idle: 10   # 连接池中的最大空闲连接
    min-idle: 5    # 连接池中的最小空闲连接
 cloud:
  consul:
   host: localhost
   port: 8500
  gateway:
   discovery:
    locator:
     enabled: true # gateway可以通过开启以下配置来打开根据服务的serviceId来匹配路由,默认是大写
   routes:
    - id: provider1
     uri: lb://idc-provider1
     predicates:
      - Path=/p1/**
     filters:
      - StripPrefix=1
      - name: Hystrix
       args:
        name: default
        fallbackUri: forward:/defaultfallback # 只有该id下的服务会降级
    - id: provider2
     uri: lb://idc-provider2
     predicates:
      - Path=/p2/**
     filters:
      - StripPrefix=1

# hystrix 信号量隔离,1.5秒后自动超时
hystrix:
 command:
  default:
   execution:
    isolation:
     strategy: SEMAPHORE
     thread:
      timeoutInMilliseconds: 1500

网关添加降级处理类

@RestController
public class FallbackController {

@RequestMapping("/defaultfallback")
public Map defaultfallback(){
System.out.println("降级操作...");
Map map = new HashMap<>();
map.put("code",200);
map.put("msg","服务超时降级");
map.put("data",null);
return map;
}
}

降级测试

超时服务降级

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

返回

{"msg":"服务超时降级","code":200,"data":null}

其他异常

spring-cloud-gateway 调用下游服务返回的异常,网关不做任何处理,会直接返回。大家想一下为什么在网关不去处理下游异常呢? 因为很多时候下游的异常是包含有效信息的(异常信息千千万),如果在网关处做了统一返回,就失去了返回异常的意义。

spring-cloud-starter-netflix-hystrix 内置的 Hystrix 过滤器是
HystrixGatewayFilterFactory。 感兴趣的小伙伴可以自行阅读相关源码。

到此这篇关于spring-cloud-gateway降级的实现的文章就介绍到这了,更多相关spring-cloud-gateway降级 内容请搜索创新互联以前的文章或继续浏览下面的相关文章希望大家以后多多支持创新互联!


文章名称:spring-cloud-gateway降级的实现
标题URL:http://mswzjz.cn/article/jigdpd.html

其他资讯