微服务·架构组件之网关- Spring Cloud Gateway

引言

微服务架构已成为构建现代化应用程序的关键范式之一，它将应用程序拆分成多个小型、可独立部署的服务。Spring Cloud Gateway是Spring Cloud生态系统中的一个关键组件，用于构建和管理微服务架构中的网关。本报告旨在调查和介绍Spring Cloud Gateway的核心概念、架构、功能以及其在微服务架构中的作用。

概述

Spring Cloud Gateway 是 Spring 官方基于 Spring 5.0，Spring Boot 2.0 和 Project Reactor 等技术开发的网关，旨在为微服务架构提供一种简单而有效的统一的 API 路由管理方式，统一访问接口。Spring Cloud Gateway 作为 Spring Cloud 生态系中的网关，目标是替代 Netflix ZUUL，其不仅提供统一的路由方式，并且基于 Filter 链的方式提供了网关基本的功能，例如：安全，监控/埋点，和限流等。它是基于Nttey的响应式开发模式。

核心概念


路由（Route）：路由是网关最基础的部分，路由信息由一个ID、一个目标的URL、一组断言工程和一组过滤器组成。如果断言为真，则说明请求URL和配置的路由匹配。

断言（Predicates）：Java8中的断言函数，Spring Cloud Gateway中的断言函数允许开发者去定义函数匹配来自Http Request中的任何信息，比如请求头和参数等。

过滤器（Filter）：一个标准的Spring webFilter， 可以分为Gateway Filter和Global Filter。过滤器Filter可以对请求和响应进行处理。

示例：

server:port: 8080spring:application:name: api-gatewaycloud:gateway:routes:- id: product-serviceuri:http://127.0.0.1:9002predicates:-Path=/product/**
  • id：自定义的路由Id，保持唯一。
  • uri：目标服务地址
  • predicates：路由条件，Predicate接受一个输入参数，返回一个boolean结果。该接口包含多种默认方法来将Predicate组合成其他复杂的逻辑，比如：与、或、非
  • filters：过滤规则。

工作流程

  • 客户端将请求发送到Spring Cloud Gateway上。
  • Spring Cloud Gateway通过Gateway Handler Mapping找到与请求相匹配的路由，并将其发送给Gateway Web Handler。
  • Gateway Web Handler 通过指定的过滤器链（Filter Chain）将请求转发到实际的服务节点中，执行业务逻辑，返回响应结果。
  • 过滤器可能会在转发请求之前（pre）或之后（post）执行业务逻辑。
  • 过滤器可以在请求转发到服务端前，对请求进行拦截和修改，例如参数校验、权限校验、流量监控、日志输出以及协议转换等。
  • 过滤器可以在响应返回客户端之前，对响应进行拦截和再处理，例如修改响应内容或响应头、日志输出、流量监控等。

路由规则

动态路由

动态路由，即自动从注册中心获取服务列表并访问。
现在以spring cloud gateway 集成nacos为例

  1. 添加依赖：在项目的’pom.xml’文件中添加Spring cloud gateway和nacos的相关依赖
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId></dependency>
  1. 配置文件：在’application.properties’或’application.yml’中配置Nacos注册中心的地址以及网关的路由规则
spring:application:name: gateway-servicecloud:nacos:discovery:server-addr: localhost:8848 gateway:discovery:locator:enabled: true # 启用服务发现routes:- id: service-routeuri: lb://service-name # 后端服务名称predicates:- Path=/service-path/** # 匹配的请求路径filters:- StripPrefix=1 # 去掉前缀
  1. 启动服务发现：在Spring Boot应用程序的主类上使用’@EnableDiscoveryClient’注解，以启用服务发现功能。
import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.client.discovery.EnableDiscoveryClient;@SpringBootApplication@EnableDiscoveryClientpublic class GatewayServiceApplication {public static void main(String[] args) {SpringApplication.run(GatewayServiceApplication.class, args);}}

重写转发路径

在Spring Cloud gateway中，路由转发是直接将匹配的路由path直接拼接到映射路径（URL）之后，那么在微服务中开发往往没有那么便利，这里可以通过RewritePath机制来进行路径重写。

spring:application:name: gateway-servicecloud:nacos:discovery:server-addr: localhost:8848 gateway:discovery:locator:enabled: true # 启用服务发现routes:- id: service-routeuri: lb://service-name # 后端服务名称predicates:- Path=/service-path/** # 匹配的请求路径filters:- RewritePath=/serive-path/(" />>.*), /$\{segment}

过滤器

Spring Cloud Gateway的Filter从作用范围可分为两种：GatewayFilter与GlobalFilter

  • GatewayFilter：应用到单个路由或者一个分组的路由上。
  • GlobalFilter：应用到所有的路由上。

局部过滤器（GatewayFilter）

局部过滤器是针对单个路由的过滤器，可以对访问的URL过滤，进行切面处理。常见的局部过滤器：

  • AddRequestHeader，为原始请求添加Header。
  • Hystrix：为路由引入Hystrix的断路器保护。
  • FallbackHeaders：为fallbackUri的请求头中添加具体的异常信息。
  • RequestRateLiiter：对于请求限流，限流算法为令牌桶算法。

全局过滤器（GlobalFilter）

全局过滤器作用于所有路由，Spring Cloud Gateway定义了GlobalFilter接口，用户可以自定义实现自己的Global Filter。通过全局过滤器可以实现对权限的统一检验，安全性验证等功能。

高级应用

鉴权


角色：

  • 客户端：访问微服务资源
  • 网关：负责转发、认证、鉴权
  • OAuth2.0授权服务：负责认证授权颁发令牌
  • 微服务集合：提供资源

流程：

  • 客户端发送请求给网关获取令牌
  • 网关收到请求，直接转发给授权服务
  • 授权服务验证用户名、密码等，验证通过颁发令牌给客户端
  • 客户端携带令牌请求资源，请求直接到网关层
  • 网关层对令牌及性能校验、鉴权和访问资源所需的权限进行比较。如果权限有交集则通过校验，直接转发给微服务
  • 微服务处理逻辑

网关限流

常见的限流算法

  • 计数器法
    一般我们会限制一秒钟能够通过的请求数，比如限流的qps为100，算法的实现思路就从从第一请求进来开始，在接下来的1s内，每来一个请求，就把计数加1，如果累加的数字达到100，那么或许的请求就会被全部拒绝。等到1s结束后，计数器恢复成0，重新开始计数。
  • 漏斗算法
    匀速处理请求。不管调用方多么不稳定，通过漏斗算法进行限流，每10ms处理一次请求，因为处理的速度是固定的，请求进来的速度是未知的，可能突然进来很多请求，没来得及处理请求就先放到桶里。如果桶满了，那么新进来的请求就丢弃。
  • 令牌桶算法
    令牌桶算法是对漏斗算法的一个改进，存在一个桶，用来存放固定数量的令牌，然后以一定的速率往桶中放令牌。每次请求进来的时候需要先获取令牌，只有拿到令牌才有机会继续执行，否则选择等待可用的令牌或者直接拒绝。
  • Gateway令牌桶
    Spring Cloud Gateway 官方提供了RequestRateLimiterGatewayFilterFactory类，使用redis和lua脚本实现了令牌桶的方式。

实现步骤

  • 引入依赖
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis-reactive</artifactId><version>2.2.10.RELEASE</version></dependency>
  • 创建限流标示
    限流通常要根据某个参数值作为参考依据来进行线路的，例如每个IP只能只能访问2次，创建根据IP限流的对象，该对象需要实现KeyResolver接口
public class IpKeyResolver implements KeyResolver {/*** * 根据IP限流 * @param exchange * @return */@Overridepublic Mono<String> resolve(ServerWebExchange exchange) {return Mono.just(exchange.getRequest().getRemoteAddress().getAddress().getHostAddress());}}

需要将IpKeyResolver的实例交给Spring容器管理。

@Configurationpublic class GatewayRateLimitConfig {@Bean("ipKeyResolver")public KeyResolver userIpKeyResolver(){return new IpKeyResolver();}}
  • 配置限流速率
spring:cloud:gateway:routes:#商品服务- id: goods_routeuri: lb://mall-goodspredicates:- Path=/mall/brand/**filters:- StripPrefix=1# 指定过滤器- name: RequestRateLimiterargs:# 指定限流标识key-resolver: '#{@ipKeyResolver}'# 速率限流redis-rate-limiter.replenishRate: 1# 能容纳的并发流量总数redis-rate-limiter.burstCapacity: 2

监控

监控每个请求的响应参数是否包含手机号码
首先，您需要创建一个自定义过滤器类，该类将检查响应参数中是否包含手机号码。这可以通过解析响应内容并搜索手机号码的正则表达式来完成。下面是一个示例：

import org.springframework.cloud.gateway.filter.GlobalFilter;import org.springframework.core.annotation.Order;import org.springframework.stereotype.Component;import org.springframework.web.server.ServerWebExchange;import reactor.core.publisher.Mono;@Component@Order(1) // 设置过滤器顺序public class PhoneNumberCheckFilter implements GlobalFilter {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {// 检查响应内容是否包含手机号码的逻辑// 解析响应内容并搜索手机号码的正则表达式// 如果包含手机号码，则可以进行相关处理，例如记录日志或触发警报// 这里仅提供示例框架，具体实现需要根据需求编写return chain.filter(exchange);}}

然后配置过滤器

spring:cloud:gateway:routes:- id: route-nameuri: http://example.comfilters:- PhoneNumberCheck= # 这里填写自定义过滤器的名字