Spring Cloud(Kilburn 2022.0.2版本)系列教程(五) 服务网关(SpringCloud Gateway)

Spring Cloud(Kilburn 2022.0.2版本)系列教程(五) 服务网关(SpringCloud Gateway)

一、服务网关

1.1 什么是网关

在微服务架构中，服务网关是一个至关重要的组件。它作为系统的入口，负责接收客户端的请求，并将这些请求路由到相应的后端服务。API网关是一个搭建在客户端和微服务之间的服务，可以在API网关中处理一些非业务功能的逻辑，例如权限验证、监控、缓存、请求路由等。API网关就像整个微服务系统的门面一样，是系统对外的唯一入口。有了它，客户端会先将请求发送到API网关，由API网关根据请求的标识信息将请求转发到微服务实例。Spring Cloud Gateway是Spring Cloud提供的一个强大的服务网关解决方案。

Spring Cloud Gateway 底层使用了高性能的通信框架Netty。Netty 是高性能中间件的通讯底座， rocketmq 、seata、nacos 、sentinel、redission 、dubbo 等太多、太多的的大名鼎鼎的中间件，无一例外都是基于netty。

与 Spring Cloud Netflix Zuul 相比，Spring Cloud Gateway具有更好的性能和更丰富的功能。例如，Gateway 基于WebFlux构建，支持响应式编程，能够更好地处理高并发场景。同时，它的路由和过滤配置更加灵活和简洁。Spring Cloud Gateway替换掉Zuul的成本上是非常低的，几乎可以无缝切换。Spring Cloud Gateway几乎包含了Zuul的所有功能。随着时间的发展，Spring Cloud Netflix Zuul会被Spring Cloud Gateway取代，想学点新技术的小伙伴，就去玩转Spring Cloud Gateway吧，别再死死抓住Zuul不放了。

1.2 网关的作用

作用说明
路由接口服务的统一代理，实现前端对接口服务的统一访问。
过滤对用户请求进行拦截、过滤、用户鉴权、监控等。
限流限制用户的访问流量。

1.3 常用的网关

网关名称优点缺点
Spring Cloud Gateway1. 基于 Spring 框架，与 Spring 生态系统集成方便，如和 Spring Boot、Spring Cloud 等配合良好。
2. 支持多种路由匹配方式，包括路径、请求头、请求参数等，灵活性高。
3. 可以方便地通过 Java 代码实现自定义的过滤器，用于实现诸如安全认证、日志记录、请求修改等功能。
4. 具备较好的性能，能处理高并发请求。		1. 对于不熟悉 Spring 框架的开发者有一定的学习成本。
2. 配置相对复杂，尤其是大规模复杂场景下，路由和过滤器的配置可能变得繁琐。
Spring Cloud Netflix Zuul1. 是 Spring Cloud 早期的网关解决方案，和 Spring Cloud 生态融合度较好。
2. 支持动态路由、监控、弹性和安全等功能，能够方便地对请求进行路由和过滤。
3. 可以通过编写 Zuul Filter 来扩展功能。		1. 相比一些新兴的网关，性能在高并发场景下可能稍逊一筹。
2. 新功能更新速度相对较慢，社区活跃度不如一些其他网关。
Kong1. 开源的、轻量级的高性能 API 网关，基于 Nginx 和 OpenResty 构建。
2. 支持插件机制，可以轻松扩展功能，如身份验证、限流、日志记录等。
3. 可用于微服务架构中，对前后端分离的应用进行有效的请求转发和管理。
4. 提供了良好的可扩展性和分布式部署能力。		1. 文档在某些方面可能不够详细，对于初次使用者有一定的学习门槛。
2. 复杂的插件配置可能会影响性能，如果插件使用不当可能出现一些难以排查的问题。
Nginx + Lua1. Nginx 本身性能卓越，处理高并发能力强，可以高效地处理大量的网络请求。
2. Lua 脚本可以方便地嵌入到 Nginx 中实现自定义的业务逻辑，如动态路由、请求过滤等。
3. 可以灵活地进行配置和优化，适用于各种规模的网络架构。		1. 开发和维护需要对 Nginx 和 Lua 都有深入的了解，技术门槛较高。
2. Lua 脚本编写不当可能会导致内存泄漏等问题，影响系统的稳定性。
Traefik1. 自动发现后端服务，支持多种容器编排工具(如 Docker、Kubernetes 等)，配置简单。
2. 具有动态配置更新能力，无需重启即可应用新的配置。
3. 提供了简洁直观的 Web UI 用于监控和管理。
4. 性能较好，能有效处理大规模流量。		1. 一些高级功能可能需要额外的配置和学习，对复杂场景的支持可能需要更多探索。
2. 在处理某些特殊的业务逻辑定制方面可能不如一些基于编程实现的网关灵活。

SpringCloud GateWay的主要功能之一是转发请求，转发规则的定义主要包含三大核心概念

术语功能
Route(路由)路由是网关的基本单元，由ID、URI、一组Predicate、一组Filter组成，根据Predicate进行匹配转发。
Predicate(谓语、断言)路由转发的判断条件，目前SpringCloud Gateway支持多种方式，常见如：Path、Query、Method、Header等，写法必须遵循 key=vlue的形式。
Filter(过滤器)过滤器是路由转发请求时所经过的过滤逻辑，可用于修改请求、响应内容。

二、SpringCloud Gateway路由

复制eurekaClient工程，修改名称为hepGatewayEntrance。

修改pom.xml文件：

<artifactId>hepGatewayEntrance</artifactId>
<name>hepGatewayEntrance</name>
<description>hepGatewayEntrance</description>

引入以下依赖：

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

修改系统的hosts，Windows10的hosts文件路径为：C:\Windows\System32\drivers\etc\hosts。Linux和macOS的文件路径为/etc/hosts。增加一行：127.0.0.1 hepGatewayEntrance。

2.1 基础URI路由配置

修改application.yml文件为：

server:port: 8005 # 端口号spring:main:web-application-type: reactivecloud:gateway:discovery:locator:enabled: trueroutes:- id: hep-api-userServiceuri: http://localhost:8000predicates:- Path=/**application:name: hepGatewayEntrance #Gateway名称eureka:instance:prefer-ip-address: falsehostname: hepGatewayEntrancelease-renewal-interval-in-seconds: 5lease-expiration-duration-in-seconds: 10client:healthcheck:enabled: truefetch-registry: trueregister-with-eureka: trueservice-url:defaultZone: http://eureka:eurekapwd@eurekaServer:8761/eureka/ registry-fetch-interval-seconds: 5

Spring Cloud Gateway配置各字段含义如下：

  • id：自定义的路由 ID，保持唯一

  • uri：目标服务地址

  • Predicate断言： 这是一个Java 8 Function Predicate。输入类型是Spring Framework ServerWebExchange。允许开发人员匹配来自HTTP请求的任何内容，例如Header或参数。Predicate接受一个输入参数，返回一个布尔值结果。Spring Cloud Gateway内置了许多Predicate，这些Predicate的源码在org.springframework.cloud.gateway.handler.predicate包中。

上面这段配置的意思是，配置了一个 id 为 hep-api-userService的URI代理规则，路由的规则为：当访问地址http://localhost:8005/getUserById时，会路由到上游地址http://localhost:8000/getUserById。

在这里插入图片描述

常见的 Predicate 断言如下

断言示例说明
Path- Path=/user/**当请求路径与 /user/** 匹配时，该请求才能被转发到 http://localhost:8000/ 上。
Before- Before=2024-10-20T11:47:34.255+08:00[Asia/Shanghai]在 2024 年 10 月 20 日 11 时 47 分 34.255 秒之前的请求，才会被转发到 http://localhost:8000/ 上。
After- After=2024-10-20T11:47:34.255+08:00[Asia/Shanghai]在 2024 年 10 月 20 日 11 时 47 分 34.255 秒之后的请求，才会被转发到http://localhost:8000/ 上。
Between- Between=2024-10-20T15:18:33.226+08:00[Asia/Shanghai],2024-10-20T15:23:33.226+08:00[Asia/Shanghai]在 2024 年 10 月 20 日 15 时 18 分 33.226 秒 到 2024年 10 月 20 日 15 时 23 分 33.226 秒之间的请求，才会被转发到http://localhost:8000/服务器上。
Cookie- Cookie=name,c.biancheng.net携带 Cookie 且 Cookie 的内容为 name=c.biancheng.net 的请求，才会被转发到http://localhost:8000/上。
Header- Header=X-Request-Id,\d+请求头上携带属性 X-Request-Id 且属性值为整数的请求，才会被转发到http://localhost:8000/上。
Method- Method=GET只有 GET 请求才会被转发到http://localhost:8000/上。

当然我们也可以把EurekaClient的接口修改一下，使其前面增加一个/user/的路径

@RestController
@RequestMapping("/user")
public class UserController {@RequestMapping("/getUserById")public String getUserById() throws Exception{return "{id:1,name:jason,age:23,sex: man}";}
}

在Spring Cloud Gateway中也设置一下/user/路径Path=/user/**

spring:main:web-application-type: reactivecloud:gateway:discovery:locator:enabled: trueroutes:- id: hep-api-userServiceuri: http://localhost:8000predicates:- Path=/user/**

当访问地址http://localhost:8005/user/getUserById时，会路由到上游地址http://localhost:8000/user/getUserById。

在这里插入图片描述

2.2 动态路由配置

Spring Cloud Gateway 会根据Eureka Server服务注册中心中维护的服务列表，以服务名(spring.application.name)作为路径创建动态路由进行转发，从而实现动态路由功能。

我们把Spring Cloud Gateway的uri修改为uri: lb://EUREKACLIENT，其中lb标识负载均衡，为uri的协议，表示开启 Spring Cloud Gateway 的负载均衡功能，EUREKACLIENT是服务的名称，注意一般是大写。

spring:main:web-application-type: reactivecloud:gateway:discovery:locator:enabled: trueroutes:- id: hep-api-userServiceuri: lb://EUREKACLIENTpredicates:- Path=/user/**

三、SpringCloud Gateway 过滤器

3.1 GatewayFilter 网关过滤器

我们来使用一下PrefixPath GatewayFilter吧，当我们增加一项PrefixPath=/user，并把Path中的/user/去掉，改成Path=/**

spring:main:web-application-type: reactivecloud:gateway:discovery:locator:enabled: trueroutes:- id: hep-api-userServiceuri: lb://EUREKACLIENTpredicates:- Path=/**filters:- PrefixPath=/user

所有匹配该路由的请求路径都会被添加/user前缀。例如，一个原本请求/getUserById的请求，经过该过滤器后，实际请求路径会变为/user/getUserById，然后被转发到http://localhost:8000/user/getUserById。

在这里插入图片描述

Spring Cloud Gateway 内置了多达 31 种 GatewayFilter，下表中列举了几种常用的网关过滤器及其使用示例。

路由过滤器描述参数使用示例
AddRequestHeader拦截传入的请求，并在请求上添加一个指定的请求头参数。name：需要添加的请求头参数的 key； value：需要添加的请求头参数的 value。- AddRequestHeader=my-request-header,1024
AddRequestParameter拦截传入的请求，并在请求上添加一个指定的请求参数。name：需要添加的请求参数的 key； value：需要添加的请求参数的 value。- AddRequestParameter=my-request-param,c.biancheng.net
AddResponseHeader拦截响应，并在响应上添加一个指定的响应头参数。name：需要添加的响应头的 key； value：需要添加的响应头的 value。- AddResponseHeader=my-response-header,c.biancheng.net
PrefixPath拦截传入的请求，并在请求路径增加一个指定的前缀。prefix：需要增加的路径前缀。- PrefixPath=/consumer
PreserveHostHeader转发请求时，保持客户端的 Host 信息不变，然后将它传递到提供具体服务的微服务中。无- PreserveHostHeader
RemoveRequestHeader移除请求头中指定的参数。name：需要移除的请求头的 key。- RemoveRequestHeader=my-request-header
RemoveResponseHeader移除响应头中指定的参数。name：需要移除的响应头。- RemoveResponseHeader=my-response-header
RemoveRequestParameter移除指定的请求参数。name：需要移除的请求参数。- RemoveRequestParameter=my-request-param
RequestSize配置请求体的大小，当请求体过大时，将会返回 413 Payload Too Large。maxSize：请求体的大小。- name: RequestSize args: maxSize: 5000000

31 种 GatewayFilter列表

1. AddRequestHeader 在请求头中添加参数
2. AddRequestParameter 添加请求参数
3. AddResponseHeader
4. The DedupeResponseHeader GatewayFilter Factory
5. The Hystrix GatewayFilter Factory
6. Spring Cloud CircuitBreaker GatewayFilter Factory
7. The FallbackHeaders GatewayFilter Factory
8. The MapRequestHeader GatewayFilter Factory
9. The PrefixPath GatewayFilter Factory
10. The PreserveHostHeader GatewayFilter Factory
11. The RequestRateLimiter GatewayFilter Factory
12. The RedirectTo GatewayFilter Factory
13. The RemoveRequestHeader GatewayFilter Factory
14. RemoveResponseHeader GatewayFilter Factory
15. The RemoveRequestParameter GatewayFilter Factory
16. The RewritePath GatewayFilter Factory
17. RewriteLocationResponseHeader GatewayFilter Factory
18. The RewriteResponseHeader GatewayFilter Factory
19. The SaveSession GatewayFilter Factory
20. The SecureHeaders GatewayFilter Factory
21. The SetPath GatewayFilter Factory
22. The SetRequestHeader GatewayFilter Factory
23. The SetResponseHeader GatewayFilter Factory
24. The SetStatus GatewayFilter Factory
25. The StripPrefix GatewayFilter Factory
26. The Retry GatewayFilter Factory
27. The RequestSize GatewayFilter Factory
28. The SetRequestHostHeader GatewayFilter Factory
29. Modify a Request Body GatewayFilter Factory
30. Modify a Response Body GatewayFilter Factory
31. Default Filters
3.2 GlobalFilter 全局过滤器

GlobalFilter 是一种作用于所有的路由上的全局过滤器，通过它，我们可以实现一些统一化的业务功能，例如权限认证、IP 访问限制等。当某个请求被路由匹配时，那么所有的 GlobalFilter 会和该路由自身配置的 GatewayFilter 组合成一个过滤器链。 GlobalFilter 全局过滤器有Gateway Metrics Filter、Local Response Cache Filter、Forward Routing Filter、Netty Routing Filter、Netty Write Response Filter、ReactiveLoadBalancerClientFilter、RouteToRequestUrl Filter、Websocket Routing Filter等。

3.3 GlobalFilter和GatewayFilter的区别

FilteringWebHandler在处理请求时，会将GlobalFilter装饰为GatewayFilter，然后放到同一个过滤器链中，排序以后依次执行。

Spring Cloud Gateway 根据作用范围划分为 GatewayFilter 和 GlobalFilter，二者区别如下：

GatewayFilter：网关过滤器，需要通过 spring.cloud.routes.filters 配置在具体路由下，只作用在当前路由上或通过 spring.cloud.default-filters 配置在全局，作用在所有路由上。
GlobalFilter：全局过滤器，不需要在配置文件中配置，作用在所有的路由上，最终通过 GatewayFilterAdapter 包装成 GatewayFilterChain 可识别的过滤器，它为请求业务以及路由的 URI 转换为真实业务服务请求地址的核心过滤器，不需要配置系统初始化时加载，并作用在每个路由上。

四、自定义过滤器

无论是GatewayFilter还是GlobalFilter都支持自定义，只不过编码方式、使用方式略有差别。

4.1 自定义GatewayFilter

自定义GatewayFilter不是直接实现GatewayFilter，而是实现AbstractGatewayFilterFactory。最简单的方式是这样的：

@Component
public class PrintLogGatewayFilterFactory extends AbstractGatewayFilterFactory<Object> {@Overridepublic GatewayFilter apply(Object config) {return new GatewayFilter() {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {// 获取请求ServerHttpRequest request = exchange.getRequest();// 编写过滤器逻辑System.out.println("PrintLog executed.");// 放行return chain.filter(exchange);}};}
}

注意：该类的名称一定要以GatewayFilterFactory为后缀哈。

然后在yaml配置中这样使用：

spring:cloud:gateway:default-filters:- PrintLog # 此处直接以自定义的GatewayFilterFactory类名称前缀类声明过滤器

另外，这种过滤器还可以支持动态配置参数，不过实现起来比较复杂，示例：

@Component
public class PrintLogGatewayFilterFactory // 父类泛型是内部类的Config类型extends AbstractGatewayFilterFactory<PrintAnyGatewayFilterFactory.Config> {@Overridepublic GatewayFilter apply(Config config) {// OrderedGatewayFilter是GatewayFilter的子类，包含两个参数：// - GatewayFilter：过滤器// - int order值：值越小，过滤器执行优先级越高return new OrderedGatewayFilter(new GatewayFilter() {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {// 获取config值String a = config.getA();String b = config.getB();String c = config.getC();// 编写过滤器逻辑System.out.println("a = " + a);System.out.println("b = " + b);System.out.println("c = " + c);// 放行return chain.filter(exchange);}}, 100);}// 自定义配置属性，成员变量名称很重要，下面会用到@Datastatic class Config{private String a;private String b;private String c;}// 将变量名称依次返回，顺序很重要，将来读取参数时需要按顺序获取@Overridepublic List<String> shortcutFieldOrder() {return List.of("a", "b", "c");}// 返回当前配置类的类型，也就是内部的Config@Overridepublic Class<Config> getConfigClass() {return Config.class;}}

然后在yaml文件中使用：

spring:cloud:gateway:default-filters:- PrintAny=1,2,3 # 注意，这里多个参数以","隔开，将来会按照shortcutFieldOrder()方法返回的参数顺序依次复制

上面这种配置方式参数必须严格按照shortcutFieldOrder()方法的返回参数名顺序来赋值。

还有一种用法，无需按照这个顺序，就是手动指定参数名：

spring:cloud:gateway:default-filters:- name: PrintAnyargs: # 手动指定参数名，无需按照参数顺序a: 1b: 2c: 3
4.2 自定义GlobalFilter

自定义GlobalFilter则简单很多，直接实现GlobalFilter即可，而且也无法设置动态参数：

@Component
public class PrintLogGlobalFilter implements GlobalFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {// 编写过滤器逻辑System.out.println("未登录，无法访问");// 放行// return chain.filter(exchange);// 拦截ServerHttpResponse response = exchange.getResponse();response.setRawStatusCode(401);//设置401无法访问return response.setComplete();}@Overridepublic int getOrder() {// 过滤器执行顺序，值越小，优先级越高return 0;}
}

五、SpringCloud Gateway 限流

Gateway是基于令牌桶算法，使用redis作为“桶”结合过滤器实现了网关限流。

在pom.xml文件中增加依赖：

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

为了简便一点，我们就不单独创建一个Config的java类了，直接在启动类中创建一个ipKeyResolver，并指定@Bean(name = "ipKeyResolver")。

package cc.huerpu.eurekaclient;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.gateway.filter.ratelimit.KeyResolver;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
import java.util.Objects;@SpringBootApplication
@EnableDiscoveryClient
public class HepGatewayEntranceApplication {public static void main(String[] args) {SpringApplication.run(HepGatewayEntranceApplication.class, args);}@Bean(name = "ipKeyResolver")public KeyResolver ipKeyResolver() {return new KeyResolver() {@Overridepublic Mono<String> resolve(ServerWebExchange exchange) {String hostName = Objects.requireNonNull(exchange.getRequest().getRemoteAddress()).getHostName();System.out.println("hostName:" + hostName);return Mono.just(hostName);}};}}

使用 RequestRateLimiter 过滤器可以实现限流功能。首先需要在配置文件中配置限流规则。在application.yml文件中指定过滤器为RequestRateLimiter，key-resolver用于限流的键的解析器的Bean对象的名字。它使用 SpEL 表达式根据#{@ipKeyResolver}从 Spring 容器中获取Bean对象，redis-rate-limiter.replenishRate指定令牌桶每s的填充速度，redis-rate-limiter.burstCapacity指定令牌桶容量，redis-rate-limiter.requestedTokens指定每个请求消耗多少个令牌，当然还要配置好redis相关信息。

server:port: 8005 # 端口号spring:main:web-application-type: reactivecloud:redis:host: 127.0.0.1port: 6379password: database: 0gateway:filter:request-rate-limiter:deny-empty-key: true #如果keyResolver返回空key，则拒绝该请求403，默认true表示拒绝，false则表示允许访问discovery:locator:enabled: true #启用基于服务发现的路由routes:- id: hep-api-userServiceuri: lb://EUREKACLIENTpredicates:- Path=/**filters:- name: RequestRateLimiterargs:key-resolver: '#{@ipKeyResolver}'redis-rate-limiter.replenishRate: 1 #令牌桶每s的填充速度redis-rate-limiter.burstCapacity: 2 #令牌桶容量redis-rate-limiter.requestedTokens: 1 #每个请求消耗多少个令牌- PrefixPath=/userapplication:name: hepGatewayEntrance # Gateway名称

当限流的时候会返回429 Too Many Request，而正当访问会返回正确的结果数据。

在这里插入图片描述

我们使用Postman进行了100次的连续请求，可以看到有成功的，也有429 Too Many Request的，这个限流的表象就跃然纸上了。当我们去Redis服务器查看的时候，也可以看到配置的db0数据库中有限流的相关数据信息。

在这里插入图片描述

5.2 用户限流

根据用户来做限流需要获取当前请求用户的userId，我们在启动类中创建一个userIdResolver，并指定@Bean(name = "userIdResolver")。

package cc.huerpu.eurekaclient;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.gateway.filter.ratelimit.KeyResolver;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;import java.util.Objects;@SpringBootApplication
@EnableDiscoveryClient
public class HepGatewayEntranceApplication {public static void main(String[] args) {SpringApplication.run(HepGatewayEntranceApplication.class, args);}@Bean(name = "userIdResolver")public KeyResolver userKeyResolver() {return exchange -> Mono.just(Objects.requireNonNull(exchange.getRequest().getQueryParams().getFirst("userId")));}}

在application.yml文件中指定key-resolver: '#{@userIdResolver}'。

server:port: 8005 # 端口号spring:main:web-application-type: reactivecloud:redis:host: 127.0.0.1port: 6379password: database: 0gateway:filter:request-rate-limiter:deny-empty-key: true #如果keyResolver返回空key，则拒绝该请求403，默认true表示拒绝，false则表示允许访问discovery:locator:enabled: true #启用基于服务发现的路由routes:- id: hep-api-userServiceuri: lb://EUREKACLIENTpredicates:- Path=/**filters:- name: RequestRateLimiterargs:key-resolver: '#{@userIdResolver}'redis-rate-limiter.replenishRate: 1 #令牌桶每s的填充速度redis-rate-limiter.burstCapacity: 2 #令牌桶容量redis-rate-limiter.requestedTokens: 1 #每个请求消耗多少个令牌- PrefixPath=/userapplication:name: hepGatewayEntrance # Gateway名称

我们在请求参数中增加userId参数并请求http://localhost:8005/getUserById?userId=1111，可以看到当限流的时候会返回429 Too Many Request，而正当访问会返回正确的结果数据。

在这里插入图片描述

5.3 接口限流

接口限流获取请求地址的uri作为限流的key，我们指定一个名为@Bean(name = "apiKeyResolver")的Bean。

package cc.huerpu.eurekaclient;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.gateway.filter.ratelimit.KeyResolver;
import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;import java.util.Objects;@SpringBootApplication
@EnableDiscoveryClient
public class HepGatewayEntranceApplication {public static void main(String[] args) {SpringApplication.run(HepGatewayEntranceApplication.class, args);}@Bean(name = "apiKeyResolver")public KeyResolver apiKeyResolver() {return exchange -> Mono.just(exchange.getRequest().getPath().value());}}

在application.yml文件中指定key-resolver: '#{@apiKeyResolver}'。

server:port: 8005 # 端口号spring:main:web-application-type: reactivecloud:redis:host: 127.0.0.1port: 6379password: database: 0gateway:filter:request-rate-limiter:deny-empty-key: true #如果keyResolver返回空key，则拒绝该请求403，默认true表示拒绝，false则表示允许访问discovery:locator:enabled: true #启用基于服务发现的路由routes:- id: hep-api-userServiceuri: lb://EUREKACLIENTpredicates:- Path=/**filters:- name: RequestRateLimiterargs:key-resolver: '#{@apiKeyResolver}'redis-rate-limiter.replenishRate: 1 #令牌桶每s的填充速度redis-rate-limiter.burstCapacity: 2 #令牌桶容量redis-rate-limiter.requestedTokens: 1 #每个请求消耗多少个令牌- PrefixPath=/userapplication:name: hepGatewayEntrance # Gateway名称

很简单的，这里就不截图了哈。

Reference：

代码共享地址：https://github.com/jinglisen/SpringCloud-Kilburn-2022/tree/master

Spring Cloud Gateway(Kilburn 2022.0.2版本)官方文档：https://docs.spring.io/spring-cloud-gateway/docs/4.0.9/reference/html/
Spring Cloud Gateway官方文档：https://cloud.spring.io/spring-cloud-gateway/reference/html/

Spring Cloud Gateway中文文档：https://springdoc.cn/spring-cloud-gateway/

SpringCloud-Gateway搭建保姆级教程：https://www.cnblogs.com/sun-10387834/p/17719582.html

SpringCloud Gateway史上最全：https://www.cnblogs.com/crazymakercircle/p/11704077.html

深入探索Spring Cloud Gateway：微服务网关的最佳实践：https://blog.csdn.net/zhengzhaoyang122/article/details/142744233

Spring Cloud Gateway API网关组件，非常详细：https://c.biancheng.net/springcloud/gateway.html

spring cloud gateway 之限流篇：https://www.cnblogs.com/chengmr/p/13277824.html

spring cloud gateway网关使用JMeter进行限流测试与熔断：https://cloud.tencent.com/developer/article/2344888
ring Cloud Gateway官方文档：https://cloud.spring.io/spring-cloud-gateway/reference/html/

Spring Cloud Gateway中文文档：https://springdoc.cn/spring-cloud-gateway/

SpringCloud-Gateway搭建保姆级教程：https://www.cnblogs.com/sun-10387834/p/17719582.html

SpringCloud Gateway史上最全：https://www.cnblogs.com/crazymakercircle/p/11704077.html

深入探索Spring Cloud Gateway：微服务网关的最佳实践：https://blog.csdn.net/zhengzhaoyang122/article/details/142744233

Spring Cloud Gateway API网关组件，非常详细：https://c.biancheng.net/springcloud/gateway.html

spring cloud gateway 之限流篇：https://www.cnblogs.com/chengmr/p/13277824.html

spring cloud gateway网关使用JMeter进行限流测试与熔断：https://cloud.tencent.com/developer/article/2344888

深入学习spring cloud gateway 限流熔断：https://zhuanlan.zhihu.com/p/520347258

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/481410.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

MySQL底层概述—7.优化原则及慢查询

MySQL底层概述—7.优化原则及慢查询

大纲 1.Explain概述 2.Explain详解 3.索引优化数据准备 4.索引优化原则详解 5.慢查询设置与测试 6.慢查询SQL优化思路 1.Explain概述 使用Explain关键字可以模拟查询优化器来执行SQL查询语句&#xff0c;从而知道MySQL是如何处理SQL语句的&#xff0c;从而分析出查询语句…
阅读更多...
【前端】Vue3+Vite如何进行多环境配置呢

【前端】Vue3+Vite如何进行多环境配置呢

在项目或产品的迭代过程中需要分不同的环境&#xff0c;那么使用vitevue3开发时&#xff0c;该如何进行配置呢 1、添加配置文件 .env.xxx .env.xxx 需要与src在同一级目录下 例如&#xff1a; 开发环境&#xff1a; .env.development 开发环境&#xff1a; .env.test 生产环…
阅读更多...
FreeSWITCH 简单图形化界面36 -使用mod_sms发送短消息

FreeSWITCH 简单图形化界面36 -使用mod_sms发送短消息

FreeSWITCH 简单图形化界面36 -使用mod_sms发送短消息 0、测试环境1、mod_sms模块安装2、编写聊天规则2.1 使用xml文件测试一下 2.2 使用脚本文件测试一下 0、测试环境 http://myfs.f3322.net:8020/ 用户名&#xff1a;admin&#xff0c;密码&#xff1a;admin FreeSWITCH界面…
阅读更多...
广域网技术

广域网技术

企业需要通过广域网将这些分散在不同地理位置的分支机构连接起来 早期广域网技术概述 广域网&#xff1a;连接不同地区局域网的网络&#xff0c;能够横跨几个洲提供远距离通信&#xff0c;形成国际性的远程网络 广域网设备角色介绍&#xff1a; CE&#xff1a;用户端连接服务…
阅读更多...
[GKCTF 2021]签到

[GKCTF 2021]签到

[GKCTF 2021]签到 wireshark跟踪http流&#xff0c;基本编解码&#xff0c;倒叙&#xff0c;栅栏密码 找到cat /f14g 把包里返回的字符串先hex解码&#xff0c;再base64解码&#xff0c;看到一个时间是倒叙&#xff0c;不含flag 继续往下面翻&#xff0c;可以看到cat%2Ff14g%7…
阅读更多...
ROS VSCode调试方法

ROS VSCode调试方法

VSCode 调试 Ros文档 1.编译参数设置 cd catkin_ws catkin_make -DCMAKE_BUILD_TYPEDebug2.vscode 调试插件安装 可在扩展中安装(Ctrl Shift X): 1.ROS 2.C/C 3.C Intelliense 4.Msg Language Support 5.Txt Syntax 3.导入已有或者新建ROS工作空间 3.1 导入工作…
阅读更多...
Socket编程（TCP/UDP详解）

Socket编程（TCP/UDP详解）

前言&#xff1a;之前因为做项目和找实习没得空&#xff0c;计算机网络模块并没有写成博客&#xff0c;最近得闲了&#xff0c;把计算机网络模块博客补上。 目录 一&#xff0c;UDP编程 1&#xff09;创建套接字 2&#xff09;绑定端口号 3&#xff09;发送与接收数据 4&…
阅读更多...
虚拟机VMware安装OpenWrt镜像

虚拟机VMware安装OpenWrt镜像

前提已经安装VMware Workstation Pro,我使用的是VM16 一.下载OpenWrt系统固件 固件有很多种&#xff0c;我选择下面这个链接的固件: Index of /releases/23.05.3/targets/x86/64/ 二.把固件转换成虚拟机能识别的格式 转换工具下载地址&#xff1a;https://www.starwindsoft…
阅读更多...
【Canvas与雷达】点鼠标可暂停金边蓝屏雷达显示屏

【Canvas与雷达】点鼠标可暂停金边蓝屏雷达显示屏

【成图】 【代码】 <!DOCTYPE html> <html lang"utf-8"> <meta http-equiv"Content-Type" content"text/html; charsetutf-8"/> <head><title>点鼠标可暂停金边蓝屏雷达显示屏 Draft1</title><style typ…
阅读更多...
计算机编码存储+char占用空间+final作用

计算机编码存储+char占用空间+final作用

内存中存储的是对应的编码&#xff0c;与对应的形状库一起能够在显示器显示出来对应的字符。 磁盘中存储的是文件信息。 内存中存储的是变量&#xff08;虽然也是在磁盘里&#xff0c;等到使用的时候再调入进来&#xff09;。 因为编码实质就是二进制串&#xff0c;所以也可以比…
阅读更多...
vue3项目搭建-6-axios 基础配置

vue3项目搭建-6-axios 基础配置

axios 基础配置 安装 axios npm install axios 创建 axios 实例&#xff0c;配置基地址&#xff0c;配置拦截器,目录&#xff1a;utils/http.js 基地址&#xff1a;在每次访问时&#xff0c;自动作为相对路径的根 // axios 基础封装 import axios from "axios";…
阅读更多...
2-2-18-9 QNX系统架构之文件系统（一）

2-2-18-9 QNX系统架构之文件系统（一）

阅读前言 本文以QNX系统官方的文档英文原版资料为参考&#xff0c;翻译和逐句校对后&#xff0c;对QNX操作系统的相关概念进行了深度整理&#xff0c;旨在帮助想要了解QNX的读者及开发者可以快速阅读&#xff0c;而不必查看晦涩难懂的英文原文&#xff0c;这些文章将会作为一个…
阅读更多...
Python基于滑动窗口CNN损伤梁桥数据、故宫城墙图像数据分类可视化|数据分享

Python基于滑动窗口CNN损伤梁桥数据、故宫城墙图像数据分类可视化|数据分享

全文链接&#xff1a;https://tecdat.cn/?p38442 分析师&#xff1a;Yufei Guo 在现代土木结构工程领域&#xff0c;结构损伤的准确识别与定位对于保障基础设施的安全性和耐久性具有极为关键的意义。传统的人工检查方法&#xff0c;如目视检查以及借助专业设备进行检测&#x…
阅读更多...
MyBatis的if标签的基本使用

MyBatis的if标签的基本使用

在MyBatis框架中&#xff0c;if标签用于在构建SQL语句时&#xff0c;根据参数条件判断的结果&#xff0c;动态地选择加入或不加where条件中。 一 常见使用 在使用MyBatis处理查询逻辑的时候&#xff0c;常用的是判断一些参数是否为空&#xff0c;列举常用的几种情况展示 1.1…
阅读更多...
RabbitMQ原理架构解析：消息传递的核心机制

RabbitMQ原理架构解析：消息传递的核心机制

文章目录 一、RabbitMQ简介1.1、概述1.2、特性 二、RabbitMQ原理架构三、RabbitMQ应用场景3.1、简单模式3.2、工作模式3.3、发布订阅3.4、路由模式3.5 主题订阅模式 四、同类中间件对比五、RabbitMQ部署5.1、单机部署5.2、集群部署&#xff08;镜像模式&#xff09;5.3、K8s部署…
阅读更多...
NGO-CNN-BiGRU-Attention北方苍鹰算法优化卷积双向门控循环单元时间序列预测，含优化前后对比

NGO-CNN-BiGRU-Attention北方苍鹰算法优化卷积双向门控循环单元时间序列预测，含优化前后对比

NGO-CNN-BiGRU-Attention北方苍鹰算法优化卷积双向门控循环单元时间序列预测&#xff0c;含优化前后对比 目录 NGO-CNN-BiGRU-Attention北方苍鹰算法优化卷积双向门控循环单元时间序列预测&#xff0c;含优化前后对比预测效果基本介绍模型描述程序设计参考资料 预测效果 基本介…
阅读更多...
【0346】Postgres内核 Startup Process 通过 signal 与 postmaster 交互实现 （5）

【0346】Postgres内核 Startup Process 通过 signal 与 postmaster 交互实现 （5）

1. Startup Process 进程 postmaster 初始化过程中， 在进入 ServerLoop() 函数之前，会先通过调用 StartChildProcess() 函数来开启辅助进程，这些进程的目的主要用来完成数据库的 XLOG 相关处理。 如： 核实 pg_wal 和 pg_wal/archive_status 文件是否存在Postgres先前是否发…
阅读更多...
说说Elasticsearch拼写纠错是如何实现的？

说说Elasticsearch拼写纠错是如何实现的？

大家好&#xff0c;我是锋哥。今天分享关于【说说Elasticsearch拼写纠错是如何实现的&#xff1f;】面试题。希望对大家有帮助&#xff1b; 说说Elasticsearch拼写纠错是如何实现的&#xff1f; 1000道 互联网大厂Java工程师 精选面试题-Java资源分享网 在 Elasticsearch 中&…
阅读更多...
NAT拓展

NAT拓展

NAT ALG&#xff08;NAT应用级网&#xff09; 为某些应用层协议&#xff0c;因为其报文内容可能携带IP相关信息&#xff0c;而普通NAT转化无法将这些IP转化&#xff0c;从而导致协议无法正常运行 例如FTP&#xff0c;DHCP&#xff0c;RSTP&#xff0c;ICMP&#xff0c;IPSEC…
阅读更多...
Flutter：封装发送验证码组件，注册页使用获取验证码并传递控制器和验证码类型

Flutter：封装发送验证码组件，注册页使用获取验证码并传递控制器和验证码类型

验证码&#xff1a;view import package:flutter/material.dart; import package:get/get.dart; import index.dart;class SendcodePage extends GetView<SendcodeController> {// 接收注册页面&#xff0c;传进来的手机号控制器&#xff0c;和发送验证码的类型final Tex…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023