Spring Cloud Gateway高级应用

• 熔断
• 限流
• 重试

1. 限速路由器

---

限速在高并发场景中比较经常使用的手段之一，能够有效的保障服务的总体稳定性，Spring Cloud Gateway 提供了基于 Redis 的限流方案。因此咱们首先须要添加对应的依赖包spring-boot-starter-data-redis-reactive

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

配置文件中须要添加 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`COPY

• 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"));
    }
}` COPY

Config类须要加@Configuration注解。

根据请求参数中的 user 字段来限流，也能够设置根据请求 IP 地址来限流，设置以下:

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

这样网关就能够根据不一样策略来对请求进行限流了。

1. 熔断路由器

---

在以前的 Spring Cloud 系列文章中，你们对熔断应该有了必定的了解，如过不了解能够先读这篇文章：《跟我学SpringCloud | 第四篇：熔断器Hystrix》

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

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

配置示例

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

配置后，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`COPY

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

1. 重试路由器

---

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`COPY

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 个值。
• （企业架构源码能够加求球：三五三六二四七二五九）