关于javascript:SpringCloud第十四篇Spring-Cloud-Gateway高级应用

• 熔断
• 限流
• 重试

1. 限速路由器

限速在高并发场景中比拟罕用的伎俩之一，能够无效的保障服务的整体稳定性，Spring Cloud Gateway 提供了基于 Redis 的限流计划。所以咱们首先须要增加对应的依赖包 spring-boot-starter-data-redis-reactive（理解源码可 + 求求: 1791743380）

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-redis-reactive</artifactId>
</dependency>

配置文件中须要增加 Redis 地址和限流的相干配置

server:
  port: 8080
spring:
  application:
    name: spring-cloud-gateway
  redis:
    host: localhost
    password: password
    port: 6379
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true
      routes:
        - id: requestratelimiter_route
          uri: http://example.org
          filters:
            - name: RequestRateLimiter
              args:
                redis-rate-limiter.replenishRate: 10
                redis-rate-limiter.burstCapacity: 20
                key-resolver: "#{@userKeyResolver}"
          predicates:
            - Method=GET

• filter 名称必须是 RequestRateLimiter
• redis-rate-limiter.replenishRate：容许用户每秒解决多少个申请
• redis-rate-limiter.burstCapacity：令牌桶的容量，容许在一秒钟内实现的最大申请数
• key-resolver：应用 SpEL 按名称援用 bean

我的项目中设置限流的策略，创立 Config 类。

package com.springcloud.gateway.config;

import org.springframework.cloud.gateway.filter.ratelimit.KeyResolver;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import reactor.core.publisher.Mono;

/**
 * Created with IntelliJ IDEA.
 *
 * @Date: 2019/7/11
 * @Time: 23:45
 * @email: inwsy@hotmail.com
 * Description:
 */
@Configuration
public class Config {
    @Bean
    KeyResolver userKeyResolver() {return exchange -> Mono.just(exchange.getRequest().getQueryParams().getFirst("user"));
    }
}

Config 类须要加 @Configuration 注解。

依据申请参数中的 user 字段来限流，也能够设置依据申请 IP 地址来限流，设置如下:

@Bean
public KeyResolver ipKeyResolver() {return exchange -> Mono.just(exchange.getRequest().getRemoteAddress().getHostName());
}

这样网关就能够依据不同策略来对申请进行限流了。

2. 熔断路由器

Spring Cloud Gateway 也能够利用 Hystrix 的熔断个性，在流量过大时进行服务降级，同样咱们还是首先给我的项目增加上依赖。

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

配置示例

spring:
  cloud:
    gateway:
      routes:
      - id: hystrix_route
        uri: http://example.org
        filters:
        - Hystrix=myCommandName

配置后，gateway 将应用 myCommandName 作为名称生成 HystrixCommand 对象来进行熔断治理。如果想增加熔断后的回调内容，须要在增加一些配置。

spring:
  cloud:
    gateway:
      routes:
      - id: hystrix_route
        uri: lb://spring-cloud-producer
        predicates:
        - Path=/consumingserviceendpoint
        filters:
        - name: Hystrix
          args:
            name: fallbackcmd
            fallbackUri: forward:/incaseoffailureusethis

fallbackUri: forward:/incaseoffailureusethis 配置了 fallback 时要会调的门路，当调用 Hystrix 的 fallback 被调用时，申请将转发到 /incaseoffailureuset 这个 URI。

3. 重试路由器

RetryGatewayFilter 是 Spring Cloud Gateway 对申请重试提供的一个 GatewayFilter Factory。

配置示例

spring:
  cloud:
    gateway:
      routes:
      - id: retry_test
        uri: lb://spring-cloud-producer
        predicates:
        - Path=/retry
        filters:
        - name: Retry
          args:
            retries: 3
            statuses: BAD_GATEWAY

Retry GatewayFilter 通过这四个参数来管制重试机制：retries, statuses, methods, 和 series。

• retries：重试次数，默认值是 3 次
• statuses：HTTP 的状态返回码，取值请参考：org.springframework.http.HttpStatus
• methods：指定哪些办法的申请须要进行重试逻辑，默认值是 GET 办法，取值参考：org.springframework.http.HttpMethod
• series：一些列的状态码配置，取值参考：org.springframework.http.HttpStatus.Series。合乎的某段状态码才会进行重试逻辑，默认值是 SERVER_ERROR，值是 5，也就是 5XX(5 结尾的状态码)，共有 5 个值。