• 「SpringCloud」07 Gateway服务网关

    SpringCloud—Gateway服务网关

    笔记整理自【尚硅谷】周阳SpringCloud框架开发教程

    gateway
    image-20220801123922304

    1. 概述

    Ⅰ. SpringCloud Gateway是什么？

    服务网关还可以用Zuul网关，但是Zuul网关由于一些维护问题，所以这里我们学习Gateway网关。

    SpringCloud全家桶里有个很重要的组件就是网关， 在1.x的版本中都是采用Zuul网关；但在2.x版本中，Zuul的升级一直跳票，SpringCloud最后自己研发了一个网关代替Zuul，那就是SpringCloud Gateway，一句话：Gateway是原zuul1.x版的替代。

    image-20220907121856907

    SpringCloud Gateway是在Spring生态系统之上构建的API网关服务，基于Spring5，SpringBoot2和Project Reactor等技术。Gateway旨在提供一种简单而有效的方式来对API进行路由，以及提供一些强大的过滤功能，例如熔断、限流、重试等。

    SpringCloud Gateway 作为 Spring Cloud 生态系统中的网关，目标是替代 Zuul，在Spring Cloud 2.0以上版本中，没有对新版本的Zuul 2.0以上最新高性能版本进行集成，仍然还是使用的Zuul 1.x非Reactor模式的老版本。而为了提升网关的性能，SpringCloud Gateway是基于WebFlux框架实现的，而WebFlux框架底层则使用了高性能的Reactor模式通信框架Netty。

    SpringCloud Gateway的目标是提供统一的路由方式且基于Filter链的方式提供了网关基本的功能，例如：安全、监控/指标、限流等。

    一句话：SpringCloud Gateway 使用的Webflux中的reactor-netty响应式编程组件，底层使用了Netty通讯框架。

    源码架构

    image-20220907121821177

    Ⅱ. SpringCloud Gateway能做什么？

    反向代理、鉴权、流量控制、熔断、日志监控等等。

    Ⅲ. 微服务架构中网关在哪里

    image-20220907122117509

    Ⅳ. 我们为什么选择Gateway？

    1️⃣ Neflix不太靠谱，Zuul2.0一直跳票，迟迟不发布

    一方面因为Zuul1.0已经进入了维护阶段，而且Gateway是SpringCloud团队研发的，是亲儿子产品，值得信赖。而且很多功能Zuul都没有用起来也非常的简单便捷。

    Gateway是基于异步非阻塞模型上进行开发的，性能方面不需要担心。虽然Netflix早就发布了最新的 Zuul 2.x，但 Spring Cloud 貌似没有整合计划。而且Netflix相关组件都宣布进入维护期；不知前景如何？

    多方面综合考虑Gateway是很理想的网关选择。

    2️⃣ SpringCloud Gateway具有如下特性
    • 基于Spring Framework 5， Project Reactor和SpringBoot 2.x进行构建；
    • 动态路由：能够匹配任何请求属性；
    • 可以对路由指定Predicate（断言）和Filter（过滤器）；
    • 集成Hystrix的熔断器功能；
    • 集成SpringCloud服务发现功能；
    • 请求限流功能；
    • 支持路径重写等待。
    3️⃣ SpringCloud Gateway 与 Zuul的区别

    在SpringCloud Finchley 正式版之前，Spring Cloud 推荐的网关是 Netflix 提供的Zuul：

    • Zuul 1.x，是一个基于阻塞 I/O 的 API Gateway
    • Zuul 1.x 基于Servlet 2. 5使用阻塞架构它不支持任何长连接（如 WebSocket）Zuul 的设计模式和Nginx较像，每次 I/ O 操作都是从工作线程中选择一个执行，请求线程被阻塞到工作线程完成，但是差别是Nginx 用C++ 实现，Zuul 用 Java 实现，而 JVM 本身会有第一次加载较慢的情况，使得Zuul 的性能相对较差。
    • Zuul 2.x理念更先进，想基于Netty非阻塞和支持长连接，但SpringCloud目前还没有整合。 Zuul 2.x的性能较 Zuul 1.x 有较大提升。在性能方面，根据官方提供的基准测试， Spring Cloud Gateway 的 RPS（每秒请求数）是Zuul的1.6倍。
    • Spring Cloud Gateway 建立 在 Spring Framework 5、 Project Reactor 和 Spring Boot 2 之上， 使用非阻塞 API。
    • Spring Cloud Gateway 还 支持 WebSocket， 并且与Spring紧密集成拥有更好的开发体验
    4️⃣ Zuul1.x模型

    SpringCloud中所集成的Zuul版本，采用的是Tomcat容器，使用的是传统的Servlet IO处理模型。

    学过尚硅谷web中期课程都知道一个题目，Servlet的生命周期？Servlet由Servlet Container进行生命周期管理。Container启动时构造servlet对象并调用servlet init()进行初始化；Container运行时接受请求，并为每个请求分配一个线程（一般从线程池中获取空闲线程）然后调用service()。Container关闭时调用servlet destory()销毁servlet；

    image-20220907123903801

    上述模式的缺点：

    servlet是一个简单的网络IO模型，当请求进入Servlet Container时，Servlet Container就会为其绑定一个线程，在并发不高的场景下这种模型是适用的。但是一旦高并发（比如抽风用jemeter压测），线程数量就会上涨，而线程资源代价是昂贵的（上线文切换，内存消耗大）严重影响请求的处理时间。在一些简单业务场景下，不希望为每个request分配一个线程，只需要1个或几个线程就能应对极大并发的请求，这种业务场景下servlet模型没有优势

    所以Zuul 1.X是基于servlet之上的一个阻塞式处理模型，即spring实现了处理所有request请求的一个servlet（DispatcherServlet）并由该servlet阻塞式处理处理。所以Springcloud Zuul无法摆脱servlet模型的弊端

    5️⃣ GateWay模型

    WebFlux是什么

    image-20220907124012942

    传统的Web框架，比如说：Struts2，SpringMVC等都是基于Servlet API与Servlet容器基础之上运行的。

    但是，在Servlet3.1之后有了异步非阻塞的支持。而WebFlux是一个典型非阻塞异步的框架，它的核心是基于Reactor的相关API实现的。相对于传统的web框架来说，它可以运行在诸如Netty，Undertow及支持Servlet3.1的容器上。非阻塞式+函数式编程（Spring5必须让你使用java8）

    Spring WebFlux 是 Spring 5.0 引入的新的响应式框架，区别于 Spring MVC，它不需要依赖Servlet API，它是完全异步非阻塞的，并且基于 Reactor 来实现响应式流规范。

    2. 三大核心概念

    Ⅰ. 路由 (Route)

    路由是构建网关的基本模块，它由ID、目标URI、一系列的断言和过滤器组成，如果断言为true则匹配路由。

    Ⅱ. 断言 (Predicate)

    参考的是Java8的java.util.function.Predicate，开发人员可以匹配HTTP请求中的所有内容（例如请求头或请求参数），如果请求与断言匹配则进行路由。

    Ⅲ. 过滤器 (Filter)

    Spring框架中GatewayFilter的实例，使用过滤器，可以在请求被路由之前或者之后对请求进行修改。

    总体

    image-20220907125636618

    客户当发送Web请求，通过一些匹配条件，定位到真正的服务节点，并在这个转发过程的前后，进行一些精细化的控制，而断言Predicate就是这些匹配条件；

    而过滤器Filter，就可以理解为一个无所不能的拦截器。有了断言和过滤器，再加上目标的uri，就可以实现一个具体的路由了。

    3. Gateway网关工作流程

    客户端向 Spring Cloud Gateway 发出请求。然后在 Gateway Handler Mapping 中找到与请求相匹配的路由，将其发送到 Gateway Web Handler。

    Handler 再通过指定的过滤器链来将请求发送到我们实际的服务执行业务逻辑，然后返回。

    过滤器之间用虚线分开是因为过滤器可能会在发送代理请求之前("pre") 或 之后("post")执行业务逻辑。

    Filter在("pre")类型的过滤器可以做参数校验、权限校验、流量监控、日志输出、协议转换等；在("post")类型的过滤器中可以做响应内容、响应头的修改，日志的输出，流量监控等有着非常重要的作用。

    image-20220907130005452

    核心逻辑：路由转发 + 执行过滤器链

    4. 入门配置

    • 建Module

      cloud-gateway-gateway9527

    • 改POM

      
<dependency>
	<groupId>org.springframework.cloudgroupId>
	<artifactId>spring-cloud-starter-gatewayartifactId>
dependency>

      • 1
      • 2
      • 3
      • 4
      • 5

      image-20220907131250875

      后面可能会遇到一个小坑，就是Gateway不要引入spring-boot-starter-web，需要之前经常引入的这两个依赖删除：

      <dependency>
    <groupId>org.springframework.bootgroupId>
    <artifactId>spring-boot-starter-webartifactId>
dependency>
<dependency>
    <groupId>org.springframework.bootgroupId>
    <artifactId>spring-boot-starter-actuatorartifactId>
dependency>

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8

    • 写YML

      image-20220907131143825

    • 主启动

      image-20220907131401374

    • 9527网关如何做路由映射？

      ➢ cloud-provider-payment8001看看controller的访问地址(get、lb)

      ➢ 我们目前不想暴露8001端口，希望在8001外面套一层9527

    • YML新增网关配置

      image-20220907145905030

    • 测试

      ➢ 添加网关前：http://localhost:8001/payment/get/31

      ➢ 添加网关后：http://localhost:9527/payment/get/31

      访问说明

      image-20220907150846719

      这样的话用网关对微服务进行路由访问，就可以不再对外暴露微服务的真实地址，而是统一暴露网关的地址。

    YML配置说明

    Gateway网关路由有两种配置方式：

    • 在配置文件yml中配置（见前面的步骤）

    • 代码中注入 RouteLocator 的Bean

      用编码的方式，实现通过9527网关对 百度新闻http://news.baidu.com/guonei 的访问

      ➢ Config

      image-20220907151514772

      上面的配置类注入RouteLocator的Bean，其配置的一个id为"path_route"的路由，当访问地址 http://localhost:9527/guonei 时，该路由会将访问自动转发到 http://news.baidu.com/guonei：

      image-20220907152457643

    5. 通过微服务名实现动态路由

    在上面的yml配置文件中，我们把路由地址写死了，这明显应该是程序中避免的。所以更好的方式是通过微服务名来实现动态路由。

    image-20220907152707334

    以前使用Ribbon实现负载均衡，现在使用网关实现负载均衡。

    image-20220907153308761

    默认情况下Gateway会根据注册中心注册的服务列表，以注册中心上微服务名为路径创建动态路由进行转发，从而实现动态路由的功能。

    • 启动

      一个eureka7001 + 两个服务提供者8001/8002

    • YML

      需要注意的是uri的协议为lb，表示启用Gateway的负载均衡功能。

      lb://serviceName是spring cloud gateway在微服务中自动为我们创建的负载均衡uri。

      image-20220907152944612

    • 测试

      http://localhost:9527/payment/lb

      8001/8002两个端口切换

      7

    6. Predicate的使用

    我们注意：Predicates这是一个复数，其实有多种Predicate。 我们这里用的Predicate的是[Path]，它是路由规则的其中一个。作用是，如果cloud-payment-service 的微服务实例中有/payment/get/**的接口，就会返回true，路由规则生效。

    启动我们的gateway9527并观察：

    image-20220907154314563

    Route Predicate Factories是什么？

    image-20220907154330135

    每一个断言Predicate都有它独特的规则，多个Predicate断言是一个与&组合

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

    官网对Gateway的断言每个都写了例子。

    常用的Route Predicate

    image-20220907161101229

    常用的Predicate断言使用 参考

    小总结

    说白了，Predicate就是为了实现一组匹配规则，让请求过来找到对应的Route进行处理。

    7. Filter的使用

    Ⅰ. 是什么

    image-20220907162630477

    路由过滤器可用于修改进入的HTTP请求和返回的HTTP响应，路由过滤器只能指定路由进行使用。

    Spring Cloud Gateway 内置了多种路由过滤器，他们都由GatewayFilter的工厂类来产生。

    Ⅱ. Spring Cloud Gateway的Filter

    • 生命周期

      ➢ pre

      ➢ post

    • 种类

      ➢ GatewayFilter 单一的，31种

      image-20220907162843120

      ➢ GlobalFilter 全局的

      image-20220907162933457

    • 常用的GatewayFilter

      ➢ AddRequestParameter

      image-20220907163311217

      ➢ …

    Ⅲ. 自定义Filter

    自定义全局GlobalFilter

    • 作用：全局日志记录，统一网关鉴权，…

    • 创建MyLogGateWayFilter

    • 实现两个接口 implements GlobalFilter, Ordered

      前者实现了全局过滤器，而后者规定了过滤器的执行顺序，该顺序数字越小，过滤器越先被执行。

      @Component
@Slf4j
public class MyLogGateWayFilter implements GlobalFilter, Ordered {

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        log.info("************come in MyLogGateWayFilter: " + new Date());
        // 取出请求参数的uname对应的值
        String uname = exchange.getRequest().getQueryParams().getFirst("uname");
        // 如果uanme为空，就直接过滤掉，不走路由
        if (uname == null) {
            log.info("************* 用户名为Null 非法用户 o(╥﹏╥)o");
            // 判断该请求不通过时：给一个回应，返回
            exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);
            return exchange.getResponse().setComplete();
        }
        // 反之，调用下一个过滤器，也就是放行：在该环节判断通过的exchange放行，交给下一个filter判断
        return chain.filter(exchange);
    }

    /**
     * 这个过滤器的加载顺序，数字越小，优先级越高
     * 设置这个过滤器在Filter链中的加载顺序。
     */
    @Override
    public int getOrder() {
        return 0;
    }
}

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18
      • 19
      • 20
      • 21
      • 22
      • 23
      • 24
      • 25
      • 26
      • 27
      • 28
      • 29

    • 测试

      ➢ 正确

      http://localhost:9527/payment/lb?uname=z3

      image-20220907164844218

      ➢ 错误

      http://localhost:9527/payment/lb

      没有参数uname，无法正常使用转发

      image-20220907164914537

  • 相关阅读:
    k8s上部署seata-server集群并注册到nacos上
    【数据结构与算法】---OJ手撕链表题
    多项式回归算法模拟
    【uiautomation】微信群发消息，获取全部聊天记录
    【Linux网络】DHCP原理与配置
    乐优商城_第3章_-认识微服务(Feign+Zuul)
    基于Python的51job的招聘信息可视化分析系统的设计与实现
    A2l文件解析
    Mac 使用paralles 从零搭建hadoop集群
    vue2 生命周期钩子函数
  • 原文地址：https://blog.csdn.net/weixin_53407527/article/details/126751332