type
status
date
urlname
summary
tags
category
icon
password
catalog
sort

Gateway

什么是服务网关

API Gateway,顾名思义,是出现在系统边界上的一个面向 API 的、串行集中式的强管控服务,这里的边界是系统服务的边界,可以理解为服务防火墙,主要起到隔离外部访问与内部系统的作用。在微服务概念的流行之前,API 网关就已经诞生了,例如银行、证券等领域常见的前置机系统,它也是解决访问认证、报文转换、访问统计等问题的。
API 网关的流行,源于近几年来移动应用与企业间互联需求的兴起。移动应用、企业互联,使得后台服务支持的对象,从以前单一的Web应用,扩展到多种使用场景,且每种使用场景对后台服务的要求都不尽相同。这不仅增加了后台服务的响应量,还增加了后台服务的复杂性。随着微服务架构概念的提出,API网关成为了微服务架构的一个标配组件
API 网关是一个服务器,是系统对外的唯一入口。API 网关封装了系统内部架构,为每个客户端提供定制的 API。所有的客户端和消费端都通过统一的网关接入微服务,在网关层处理所有非业务功能。API 网关并不是微服务场景中必须的组件,如下图,不管有没有 API 网关,后端微服务都可以通过 API 很好地支持客户端的访问。
notion image
API 网关出现的原因是微服务架构的出现,不同的微服务一般会有不同的网络地址,而外部客户端可能需要调用多个服务的接口才能完成一个业务需求,如果让客户端直接与各个微服务通信,会有以下的问题:
  • 客户端会多次请求不同的微服务,增加了客户端的复杂性。
  • 存在跨域请求,在一定场景下处理相对复杂。
  • 认证复杂,每个服务都需要独立认证。
  • 难以重构,随着项目的迭代,可能需要重新划分微服务。例如,可能将多个服务合并成一个或者将一个服务拆分成多个。如果客户端直接与微服务通信,那么重构将会很难实施。
  • 某些微服务可能使用了防火墙 / 浏览器不友好的协议,直接访问会有一定的困难。
API网关方式的核心要点是,所有的客户端和消费端都通过统一的网关接入微服务, 在网关层处理所有的非业务功能。通常,网关也是提供REST/HTTP的访问API。

网关解决了什么问题

但对于服务数量众多、复杂度比较高、规模比较大的业务来说,引入 API 网关也有一系列的好处:
  • 聚合接口使得服务对调用者透明,客户端与后端的耦合度降低
  • 聚合后台服务,节省流量,提高性能,提升用户体验
  • 提供安全、流控、过滤、缓存、计费、监控等 API 管理功能
notion image
网关应当具备以下功能
  • 性能:API 高可用,负载均衡,容错机制。
  • 安全:权限身份认证、脱敏,流量清洗分发,后端签名(保证全链路可信调用),黑名单(非法调用的限制)。
  • 日志:日志记录,一旦涉及分布式,全链路跟踪必不可少。
  • 缓存:数据缓存。
  • 监控:记录请求响应数据,API 耗时分析,性能监控。
  • 限流:流量控制,错峰流控,可以定义多种限流规则。
  • 灰度:线上灰度部署,可以减小风险。
  • 路由:动态路由规则。
主要功能
  • 数据平面主要功能是接入用户的HTTP请求和微服务被拆分后的聚合。使用微服务网关统一对外暴露后端服务的API和契约,路由和过滤功能正是网关的核心能力模块。另外,微服务网关可以实现拦截机制和专注跨横切面的功能,包括协议转换、安全认证、熔断限流、灰度发布、日志管理、流量监控等。
  • 控制平面主要功能是对后端服务做统一的管控和配置管理。例如,可以控制网关的弹性伸缩;可以统一下发配置;可以对网关服务添加标签;

Spring Cloud Gateway

Spring Cloud Gateway 是基于 Spring 生态系统之上构建的 API 网关,包括:Spring 5,Spring Boot 2 和 Project Reactor。Spring Cloud Gateway 旨在提供一种简单而有效的方法来路由到 API,并为它们提供跨领域的关注点,例如:安全性,监视/指标,限流等。
由于 Spring 5.0 支持 Netty,Http2,而 Spring Boot 2.0 支持 Spring 5.0,因此 Spring Cloud Gateway 天然支持 Netty 和 Http2。
Spring Cloud Gateway 建立在Spring Boot 2.xSpring WebFluxProject Reactor之上(基于⾼性能的Reactor模式响应式通信框架Netty,异步⾮阻塞模型)。因此当使用 Spring Cloud Gateway 时,许多熟悉的同步库(例如 Spring Data 和 Spring Security)和模式可能并不适用。
Spring Cloud Gateway 需要 Spring Boot 和 Spring Webflux 提供的 Netty 运行时。它不适用于传统的 Servlet 容器或构建为 WAR 时。

核心概念

  • Route: The basic building block of the gateway. It is defined by an ID, a destination URI, a collection of predicates, and a collection of filters. A route is matched if the aggregate predicate is true.
    • 路由是构建网关的基本模块,它由ID,目标URI,一系列的断言和过滤器组成,如果断言为true则匹配该路由
  • Predicate: This is a Java 8 Function Predicate. The input type is a Spring Framework ServerWebExchange. This lets you match on anything from the HTTP request, such as headers or parameters.
    • 参考的是java8的java.util.function.Predicate开发人员可以匹配HTTP请求中的所有内容(例如请求头或请求参数),如果请求与断言相匹配则进行路由
  • Filter: These are instances of GatewayFilter that have been constructed with a specific factory. Here, you can modify requests and responses before or after sending the downstream request.
    • 指的是Spring框架中GatewayFilter的实例,使用过滤器,可以在请求被路由前或者之后对请求进行修改。
工作流程
notion image
如上图所示,客户端向 Spring Cloud Gateway 发出请求。再由网关处理程序 Gateway Handler Mapping 映射确定与请求相匹配的路由,将其发送到网关 Web 处理程序 Gateway Web Handler。该处理程序通过指定的过滤器链将请求发送到我们实际的服务执行业务逻辑,然后返回。过滤器由虚线分隔的原因是,过滤器可以在发送代理请求之前和之后运行逻辑。所有 pre 过滤器逻辑均被执行。然后发出代理请求。发出代理请求后,将运行 post 过滤器逻辑。

Predicate 断言

SpringCloud Gateway 包括许多内置的Route Predicate工厂。所有这些Predicate都与HTTP请求的不同属性匹配。多个Route Predicate工厂可以进行组合。
SpringCloud Gateway 创建Route对象时,使用RoutePredicateFactory创建Predicate对象,Predicate对象可以赋值给Route。SpringCloud Gateway 包含许多内置的RoutePredicateFactories。
所有这些断言都匹配HTTP请求的不同属性。多种断言工厂可以组合,并通过逻辑and。
SpringCloud Gateway 将路由匹配作为Spring WebFlux HandlerMapping基础架构的一部分。

内置谓词断言

  • After Route Predicate Factory 匹配在指定日期时间之后发生的请求
    • 参数:datetime
    • 注意时间格式带时区 ZonedDateTime
    • spring: cloud: gateway: routes: - id: after_route_test uri: <https://www.hehouhui.cn> predicates: - After=2022-07-10T17:42:00.789-07:00[Asia/Shanghai]
  • Before Route Predicate Factory 匹配在指定日期时间之前发生的请求
    注意时间格式带时区 ZonedDateTime
    • Between Route Predicate Factory 匹配在指定范围日期时间发生的请求
      • 参数:datetime1 开始
      • datetime2 结束
      • 注意时间格式带时区 ZonedDateTime
      • spring: cloud: gateway: routes: - id: between_route_test uri: <https://www.hehouhui.cn> predicates: - Between=2022-07-10T17:42:30.789-07:00[Asia/Shanghai],2022-07-10T17:42:59.789-07:00[Asia/Shanghai]
    • Cookie Route Predicate Factory 匹配在指定包含指定cookie 值的请求
    参数:name cookie名称
    • regexp 匹配值的正则
    • spring: cloud: gateway: routes: - id: cookie_route_test uri: <https://www.hehouhui.cn> predicates: - Cookie=token,allow_account
    • Header Route Predicate Factory 匹配在指定包含指定请求头的请求
    参数:name 请求头的名称
    • Host Route Predicate Factory 请求主机地址匹配
      • Method Route Predicate Factory 请求方法的匹配
        • Path Route Predicate Factory 请求路由规则匹配
          • Query Route Predicate Factory 请求参数 url ?后的参数
            • RemoteAddr Route Predicate Factory 客户端请求IP匹配
              默认情况下,RemoteAddr 路由谓词工厂使用来自传入请求的远程地址。如果 Spring Cloud Gateway 位于代理层后面,这可能与实际客户端 IP 地址不匹配。
              可以通过设置自定义来自定义解析远程地址的方式RemoteAddressResolver。Spring Cloud Gateway 带有一个基于X-Forwarded-For 标头的非默认远程地址解析器,XForwardedRemoteAddressResolver.
              XForwardedRemoteAddressResolver有两个静态构造方法,它们采用不同的安全方法:
              • XForwardedRemoteAddressResolver::trustAll返回RemoteAddressResolver始终采用在X-Forwarded-For标头中找到的第一个 IP 地址的 a。这种方法容易受到欺骗,因为恶意客户端可以为 设置初始值,X-Forwarded-For解析器会接受该值。
              • XForwardedRemoteAddressResolver::maxTrustedIndex采用与 Spring Cloud Gateway 前运行的受信任基础架构数量相关的索引。例如,如果 Spring Cloud Gateway 只能通过 HAProxy 访问,则应使用值 1。如果在访问 Spring Cloud Gateway 之前需要两跳可信基础架构,则应使用值 2。
              • Weight Route Predicate Factory 权重路由匹配
                • 参数: group 自定义分组名称
              • XForwarded Remote Addr Route Predicate Factory 根据 X-Forwarded-For请求头匹配
                • 参数:sources 注意此处为cidr格式

              Filter过滤器

              GlobaFilter 全局过滤器

              GlobaFilter 全局过滤器,不需要在配置文件中配置,系统初始化时加载,并作用在每个路由上。 SpringCloud Gateway 核心的功能也是通过内置的全局过滤器来完成
              类名
              作用
              CustomGlobalFilter
              组合所有过滤器的排序,包含GlobaFilter和GatewayFilter。Gateway 区分过滤器逻辑执行的“前”和“后”阶段,具有最高优先级的过滤器是“前”阶段的第一个和“后”阶段的最后一个 -阶段。
              ForwardRoutingFilter
              forward://开头的url协议将会被转发
              ReactiveLoadBalancerClientFilter
              将以lb://开头的url 经过 ReactorLoadBalancer 路由加载转换
              NettyRoutingFilter
              http或者https协议 由Netty 过滤器运行。它使用 NettyHttpClient发出下游代理请求
              NettyWriteResponseFilter
              并将代理响应写回网关客户端响应
              RouteToRequestUrlFilter
              将 Route对象转为URL,并存储原Route信息
              WebsocketRoutingFilter
              将以ws,wss或请求头Upgrade = WebSocket的http,https 以We bsocket协议执行
              GatewayMetricsFilter
              路由指标数据收集用于集成Grafana仪表板

              AbstractGatewayFilterFactory 局部过滤器工厂

              GatewayFilter局部过滤器,是针对单个路由的过滤器。 在SpringCloud Gateway组件中提供了大量内置的局部过滤器,对请求和响应坐过滤操作。
              遵循约定大于配置的思想,只需要在配置文件配置局部过滤器名称,并为其制定对应的值。就可以让其生效。
              名称
              作用
              参数
              AddRequestHeader
              为路由添加请求头
              name,value
              AddRequestParameter
              为路由添加请求query参数(拼接在url后)
              name,value
              AddResponseHeader
              为路由添加响应头
              name,value
              DedupeResponseHeader
              响应头去重,默认取响应头的首个value,最主要是用来处理自2.2.5版本后网关和下游服务都处理了CORS的bug
              name,strategy
              CircuitBreaker
              路由断路器,在服务异常或者返回指定状态码时转发路由至指定 fallbackUri
              name,fallbackUri,routeId,statusCodes
              FallbackHeaders
              在执行请求转发时添加指定的请求头信息
              MapRequestHeader
              copy请求头中指定值到新的请求头中
              fromHeader,toHeader
              PrefixPath
              为路由URL添加统一前缀
              prefix
              PreserveHostHeader
              无特殊逻辑,只是标记一下路由为原始请求
              RequestRateLimiter
              路由限流,由KeyResolver解析出路由细粒度,RateLimiter进行限流处理
              keyResolver, rate-limiter.replenish-rate ,rate-limiter.burst-capacity,rate-limiter.requested-tokens。requestedTokens每次请求消耗多少令牌,burstCapacity令牌桶总容量,replenishRate每多少秒生产一枚令牌
              RedirectTo
              请求转发
              RemoveRequestHeader
              删除请求头
              RemoveResponseHeader
              删除响应头
              RemoveRequestParameter
              删除请求参数
              RequestHeaderSize
              累计请求头value bytes大小不超过最大值
              RewritePath
              重写Path
              RewriteLocationResponseHeader
              修改Location的值
              RewriteResponseHeader
              重写响应头值
              SaveSession
              保存session
              SecureHeaders
              安全生命请求头
              SetPath
              设置新Path
              SetRequestHeader
              设置请求头
              SetResponseHeader
              设置响应头
              SetStatus
              设置状态码
              StripPrefix
              路由摘除以/分割
              parts
              Retry
              路由重试
              retries:重试次数,statuses: 判断可重试的状态吗默认5xx,methods: 支持重试的请求方法,exceptions: 重试的抛出异常列表
              RequestSize
              通过Content-length判断是否超过最大请求大小
              SetRequestHostHeader
              清除原请求头Host,并添加新值
              ModifyRequestBody
              修改请求体
              ModifyResponseBody
              修改响应体
              TokenRelay
              OAuth2标准认证服务,执行授权认证后并将信息传递下游服务
              CacheRequestBody
              缓存请求体

              RouteLocator

              路由配置加载

              ConfigurationService

              路由&谓词&过滤器工程等动态配置等实现
              相关文章
              响应式开发之webFlux & ReactorRedis 入手知识点
              Loading...
              Honesty
              Honesty
              人道洛阳花似锦,偏我来时不逢春
              最新发布
              Java IO — NIO Buffer
              2024-10-21
              Java IO — NIO Channel
              2024-10-21
              Java IO — IO/NIO模型
              2024-10-21
              Java异步编程方式介绍
              2024-10-21
              Elasticsearch — 索引(Mapping Index)
              2024-10-19
              Elasticsearch — 如何存储数据并保持一致性?
              2024-10-19