• 首页 首页 icon
  • 工具库 工具库 icon
    • IP查询 IP查询 icon
  • 内容库 内容库 icon
    • 快讯库 快讯库 icon
    • 精品库 精品库 icon
    • 问答库 问答库 icon
  • 更多 更多 icon
    • 服务条款 服务条款 icon

SpringCloud GateWay 相关图形,文档、网站

武飞扬头像
aiwokache
帮助1

一 业务:多个微服务的应用可能部署在不同机房,不同地区,不同域名下。 

二 需求:统一入口、路由、权限认证......

三 解决方案:

1 集群与架构(11)

(1)逻辑

学新通

(2)物理

学新通

图1 

学新通

图2 

2 功能“集”:网关

3 “神”工具:spring cloud gateway

 四 完成学习

1 体系组织

学新通

图1 

学新通

图2 

  1. 基于:Spring Framework 5、Spring Boot 2.0、WebFlux框架(reactor-netty、Netty、Loop线程)、Project Reactor 
  2. 集成:Hystrix 断路器、Spring Cloud DiscoveryClient
  3. 包含:Predicates 、 Filters链
  4. 提供:网关的高级功能:
    1. 跨域请求问题(jf-驾驶舱项目)
    2. 服务降级
    3. 熔断
    4. 路由
    5. 负载均衡

网关 = 路由转发 过滤器(编写额外功能)

简单说明一下三个术语:

  1. Filter(过滤器):
    1. 过滤器将会对请求和响应进行处理。
    2. 在Gateway运行过程中Filter负责在代理服务“之前”或“之后”去做一些事情。
    3. 所有生效的Filter都是GatewayFilter的实例
  2. Route(路由):
    1. 接收外界请求,通过网关的路由转发,转发到后端的服务上。
    2. 一个Route模块由一个 ID,一个目标 URI,一组断言和一组过滤器定义组成。
      1. ID是自定的
      2. URI就是一个地址

      3. Predicate过滤器

      4. Filter过滤器

    3. 如果断言为真,则说明请求的 URI 和配置匹配,目标URI会被访问。
    4. 注意1:Zuul的路由配置模块类似。
    5. 注意2:只讨论路由功能的话,它和nginx反向代理服务器很像(外界访问nginx,由nginx做负载均衡,后把请求转发到对应服务器上)。
  3. Predicate(断言、谓词
    1. 简单点理解谓词就是一些附加条件和内容,可以使用它来匹配来自 HTTP 请求的任何内容,例如 headers 或参数。
    2. 断言的输入类型是一个 ServerWebExchange。

2 思想

  1. 类比应用的防火墙:系统的统一入口,主要起到隔离外部访问与内部系统的作用。
  2. 目标是替代 Zuul:基于servlet之上的一个阻塞式处理模型、高并发下会崩溃宕机
    1. Spring Cloud Gateway和Zuul最主要的区别,还是在底层的通信框架上。

3 原理

  1. 因为spring cloud gateway是一个单独、独立运行的服务器,所以它是一个中间件。
  2. 单体应用:浏览器发起请求到单体应用所在的机器,应用从数据库查询数据原路返回给浏览器,对于单体应用来说是不需要网关的。
  3. 微服务:微服务的应用可能部署在不同机房,不同地区,不同域名下。此时客户端(浏览器/手机/软件工具)想要请求对应的服务,都需要知道机器的具体 IP 或者域名 URL,当微服务实例众多时,这是非常难以记忆的,对于客户端来说也太复杂难以维护。此时就有了网关,所有外部请求率先经过微服务网关,客户端只需要与网关交互(只需要知道网关地址即可),然后由网关根据请求标识解析判断出具体的微服务地址,再把请求转发到微服务实例。这其中的记忆功能就全部交由网关来操作了。

4 流程

学新通

  1. 第一步:客户端向 Spring Cloud Gateway 发出请求。
  2. 第二步:请求首先会被HttpWebHandlerAdapter进行提取组装成网关上下文
  3. 第三步:Gateway中Handler Mapping映射中找到与请求相匹配的路由。
  4. 第四步:将路由发送到网关 Web 处理程序 Gateway Web Handler。
  5. 第五步:Gateway Web Handler 会被Filter进行过滤。
  6. 第六步:Gateway 基于 Filter 链的方式提供了网关基本的功能,Filter中前半部分代码是处理请求的代码。
  7. 第七步:处理完成后调用真实被代理的服务,被代理服务响应结果。
  8. 第八步:结果会被Filter中后半部分代码进行操作。
  9. 第九步:原路返回:
    1. 操作完成后把结果返回给Gateway Web Hanlder,
    2. 在返回给Gateway Handler Mapping,
    3. 最终响应给客户端。

5 实现技术

  1. 基于:Spring Framework 5、Spring Boot 2.0、WebFlux框架(reactor-netty、Netty、Loop线程)、Project Reactor 
  2. 集成:Hystrix 断路器、Spring Cloud DiscoveryClient
  3. 包含:Predicates 、 Filters链

6 具体1:常用网关解决方案

  1. redis
  2. Nginx Lua
  3. kong
  4. Traefik
  5. Spring Cloud Netflix Zuul
  6. Spring Cloud Gateway

7 具体2:高可用spring cloud gateway

        为了保证 Gateway 的高可用性,可以同时启动多个 Gateway 实例进行负载,在 Gateway 的上游使用 Nginx 或者 F5 进行负载转发以达到高可用。

学新通

学新通  

学新通

8 只官配play:nginx实现API网关【乐字节】

  1. 下载nginx:学习,windows版
  2. 安装nginx:解压,运行根路径下的 nginx.exe 
  3. 测试nginx:Nginx 默认端口为 80,访问:http://localhost:80/ 看到下图说明安装成功:
    学新通
  4. 配置路由规则:
    进入 Nginx conf 目录,打开 nginx.conf 文件,配置路由规则:
    学新通
  5. 测试
    访问:http://localhost/api-product/product/1 结果如下:
    学新通
    访问:http://localhost/api-order/order/1 结果如下:
    学新通

9 只官配play:动路由 = gateway eureka【sxt】

  1. 第一步:注册中心服务端项目Eureka Server
    1. 动态路由其实就是面向服务的路由
    2. Spring Cloud Gateway 支持与 Eureka 整合开发
      1. Gateway整合Eureka,需要根据 serviceId 自动从Eureka中获取真实的服务地址并转发请求,在进行访问。
    3. 这样做的好处不仅可以通过单个端点来访问应用的所有服务,而且在添加或移除服务实例时不用修改 Gateway 的路由配置。 
  2. 第二步:DemoOne(项目名:demo-one),注册中心客户端项目Eureka Client
    1. 配置文件:
      1.  
        spring:
      2.  
        application:
      3.  
        name: demo-one
    2. 控制器:
      1.  
        @Controller
      2.  
        public class DemoController {
      3.  
         
      4.  
        @RequestMapping("/one")
      5.  
        @ResponseBody
      6.  
        public String demo(){
      7.  
        System.out.println("执行one控制器");
      8.  
        return "one";
      9.  
        }
      10.  
        @RequestMapping("/demo/one")
      11.  
        @ResponseBody
      12.  
        public String demo2(){
      13.  
        System.out.println("执行demo-one控制器");
      14.  
        return "demo-one";
      15.  
        }
      16.  
        }
      学新通
  3. 第三步:GatewayDemo(项目名:gateway-demo),网关项目
    1. pom.xml:
      1.  
        <parent>
      2.  
        <groupId>org.springframework.boot</groupId>
      3.  
        <artifactId>spring-boot-starter-parent</artifactId>
      4.  
        <version>2.2.5.RELEASE</version>
      5.  
        </parent>
      6.  
        <dependencyManagement>
      7.  
        <dependencies>
      8.  
        <dependency>
      9.  
        <groupId>org.springframework.cloud</groupId>
      10.  
        <artifactId>spring-cloud-dependencies</artifactId>
      11.  
        <version>Hoxton.SR3</version>
      12.  
        <type>pom</type>
      13.  
        <scope>import</scope>
      14.  
        </dependency>
      15.  
        </dependencies>
      16.  
        </dependencyManagement>
      17.  
        <dependencies>
      18.  
        <dependency>
      19.  
        <groupId>org.springframework.cloud</groupId>
      20.  
        <artifactId>spring-cloud-starter-gateway</artifactId>
      21.  
        </dependency>
      22.  
        <dependency>
      23.  
        <groupId>org.springframework.cloud</groupId>
      24.  
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
      25.  
        </dependency>
      26.  
        </dependencies>
      学新通
    2. 配置文件:
      谓词中Path一般会给每个项目前面起一个无意义的别名。
      如Path = /abc/** 当看到abc是知道路由转发到项目abc,后面的内容才是真实要访问abc的内容
      如Path=/jqk/** 表示需要转发到jqk项目。
      要明白:uri中第一部分就是为了防止各个项目中出现重名路径导致路由转发失败。
      1.  
        server:
      2.  
        port: 9000
      3.  
        spring:
      4.  
        application:
      5.  
        name: gateway-demo
      6.  
        cloud:
      7.  
        gateway:
      8.  
        discovery:
      9.  
        locator:
      10.  
        enabled: true # 开启当前项目服务注册与发现功能
      11.  
        lower-case-service-id: true # 把服务名转换为小写,Eureka中默认都是大写
      12.  
        routes:
      13.  
        - id: demo #自定义唯一标识,只要不重复即可
      14.  
        uri: lb://EUREKA-CLIENT # lb:loadBalance EUREKA-CLIENT 代理项目的名
      15.  
        predicates: Path=/demo/** # 路径规则
      16.  
        filters: StripPrefix=1 # 转发后忽略第一层
      学新通
    3. 新建启动器:

      1.  
        @SpringBootApplication
      2.  
        public class GatewayApplication {
      3.  
        public static void main(String[] args) {
      4.  
        SpringApplication.run(GatewayApplication.class,args);
      5.  
        }
      6.  
        }
  4. 第四步:访问GatewayDemo项目。
                  访问测试:http://localhost:9000/demo/one
                  页面会显示:
    学新通
                  通过结果可以看出,用户虽然访问的GatewayDemo网关项目,但是最后真是访问的是DemoOne项目中/one 控制器

10 只官配play:动路由 = gateway nacos

(1)集成nacos前: 

  1. 第一步:引入依赖
    1.  
      <!-- gateway网关 -->
    2.  
      <!-- 注意:会和spring-webmvc的依赖冲突,需要排除spring-webmvc -->
    3.  
      <dependency>
    4.  
      <groupId>org.springframework.cloud</groupId>
    5.  
      <artifactId>spring‐cloud‐starter‐gateway</artifactId>
    6.  
      </dependency>
  2. 第二步:编写yml配置文件
    学新通

(2)集成Nacos:现在在配置文件中写死了转发路径的地址, 前面我们已经分析过地址写死带来的问题, 接下来我们从注册中心获取此地址

  1.  第一步:引入依赖
    1.  
      <!‐‐ nacos服务注册与发现 ‐‐>
    2.  
      <dependency>
    3.  
      <groupId>com.alibaba.cloud</groupId>
    4.  
      <artifactId>spring‐cloud‐starter‐alibaba‐nacos‐discovery</artifactId>
    5.  
      </dependency>
  2. 第二步:修改yml配置文件
    学新通
  3. 第三步:简写版
    学新通

(3)测试

学新通

四 动态路由

1 路由配置方式

  1. 方式一:基础URI路由配置方式
    如果请求的目标地址,是单个的URI资源路径,配置文件示例如下:
    1.  
      server:
    2.  
      port: 8080
    3.  
      spring:
    4.  
      application:
    5.  
      name: api-gateway
    6.  
      cloud:
    7.  
      gateway:
    8.  
      routes:
    9.  
      - id: url-proxy-1 #id:我们自定义的路由 ID,保持唯一
    10.  
      uri: https://blog.csdn.net #uri:目标服务地址
    11.  
      predicates: #predicates:路由条件,Predicate 接受一个输入参数,返回一个布尔值结果。该接口包含多种默认方法来将 Predicate 组合成其他复杂的逻辑(比如:与,或,非)。
    12.  
      - Path=/csdn
    13.  
      #上面这段配置的意思是,配置了一个 id 为 url-proxy-1的URI代理规则,路由的规则为:
    14.  
      #当访问地址http://localhost:8080/csdn/1.jsp时,会路由到上游地址https://blog.csdn.net/1.jsp。
    15.  
      #下面示例中 uri指向了我的CSDN博客,在实际项目使用中可以将 uri 指向对外提供服务的项目地址,统一对外输出接口。
    学新通
  2. 方式二:基于代码的路由配置方式
    转发功能同样可以通过代码来实现,我们可以在启动类 GateWayApplication 中添加方法 customRouteLocator() 来定制转发规则。
    1.  
      package com.springcloud.gateway;
    2.  
       
    3.  
      import org.springframework.boot.SpringApplication;
    4.  
      import org.springframework.boot.autoconfigure.SpringBootApplication;
    5.  
      import org.springframework.cloud.gateway.route.RouteLocator;
    6.  
      import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
    7.  
      import org.springframework.context.annotation.Bean;
    8.  
       
    9.  
      @SpringBootApplication
    10.  
      public class GatewayApplication {
    11.  
       
    12.  
      public static void main(String[] args) {
    13.  
      SpringApplication.run(GatewayApplication.class, args);
    14.  
      }
    15.  
      /**
    16.  
      同理:
    17.  
      下面这段配置的意思是,配置了一个 id 为 url-proxy-1的URI代理规则,路由的规则为:
    18.  
      当访问地址http://localhost:8080/csdn/1.jsp时,会路由到上游地址https://blog.csdn.net/1.jsp。
    19.  
      下面示例中 uri指向了我的CSDN博客,在实际项目使用中可以将 uri 指向对外提供服务的项目地址,统一对外输出接口。
    20.  
      */
    21.  
      @Bean
    22.  
      public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
    23.  
      return builder.routes()
    24.  
      .route("path_route", r -> r.path("/csdn")
    25.  
      .uri("https://blog.csdn.net"))
    26.  
      .build();
    27.  
      }
    28.  
       
    29.  
      }
    学新通
  3. 方式三:和注册中心相结合的路由配置方式

           在uri的schema协议部分为自定义的lb:类型,表示从微服务注册中心(如zoolkepper、Eureka、nacos、阿波罗)订阅服务,并且进行服务的路由。
           注册中心相结合的路由配置方式,与单个URI的路由配置,区别其实很小,仅仅在于URI的schema协议不同。单个URI的地址的schema协议,一般为http或者https协议

    1.  
      server:
    2.  
      port: 8084
    3.  
      spring:
    4.  
      cloud:
    5.  
      gateway:
    6.  
      routes:
    7.  
      - id: seckill-provider-route
    8.  
      uri: lb://seckill-provider
    9.  
      predicates:
    10.  
      - Path=/seckill-provider/**
    11.  
       
    12.  
      - id: message-provider-route
    13.  
      uri: lb://message-provider
    14.  
      predicates:
    15.  
      - Path=/message-provider/**
    16.  
      application:
    17.  
      name: cloud-gateway
    18.  
      eureka:
    19.  
      instance:
    20.  
      prefer-ip-address: true
    21.  
      client:
    22.  
      service-url:
    23.  
      defaultZone: http://localhost:8888/eureka/
    学新通

2 路由匹配规则

(1)生活需求:更加复杂的匹配规则

(2)解决方案:Spring Cloud Gataway 帮我们内置了很多 Predicates 功能、还能使用filter

        Spring Cloud Gateway 的功能很强大,我们仅仅通过 Predicates 的设计就可以看出来,前面我们只是使用了 predicates 进行了简单的条件匹配,其实 Spring Cloud Gataway 帮我们内置了很多 Predicates 功能。

        Spring Cloud Gateway 是通过 Spring WebFlux 的 HandlerMapping 做为底层支持来匹配到转发路由,Spring Cloud Gateway 内置了很多 Predicates 工厂,这些 Predicates 工厂通过不同的 HTTP 请求参数来匹配,多个 Predicates 工厂可以组合使用。

学新通

1)Predicates谓词:当满足条件在进行路由转发。

  1. 其中Route和Predicate必须同时申明
  2. 所有的谓词都设置在predicates属性中,
  3. 当设置多个谓词时取逻辑与条件,
  4. 且一个谓词只能设置一组条件,如果需要有个多条件,添加多个相同谓词。
  5. 案例:Path=/demo/** 实际上使用的就是PathRoutePredicateFactory
  6. 网上有一张图总结了 Spring Cloud 内置的几种 Predicate 的实现:

    学新通

  7. 假设 转发uri都设定为http://localhost:9023学新通


2)过滤器规则(Filter) 

  1. Filter作用:在路由转发到代理服务之前和代理服务返回结果之后额外做的事情。

  2. Filter执行了说明谓词条件通过了。

  3. Spring Cloud Gateway中Filter分类:

    1. 内置Filter,都是GatewayFilter实现类

    2. 自定义GlobalFilter

  4. 学新通

  5. 学新通

  6. GlobalFilter【sxt】:全局过滤器不需要工厂,也不需要配置,直接对所有的路由都生效。
    学新通

  7. 自定义FilterFactory【sxt】:可以定义针对于Router的Filter。

    1. 类名必须叫做XXXGatewayFilterFactory.注入到Spring容器后使用时的名称就叫做XXX。
    2. 类必须继承AbstractGatewayFilterFactory
    3. 所有需要传递进来的参数都配置到当前类的内部类Config中 

五 熔断降级:Gateway Hystrix

1 生活问题

    请求超时、异常。请求失败堆积于网关。需要快速失败并返回给客户端。不然系统崩溃。

2 解决方案:熔断降级

  1. Spring Cloud Gateway 可以利用Hystrix实现服务降级等功能。
  2. 当Gateway进行路由转发时,如果发现下游服务连接超时或产生异常,此时就允许进行服务降级。
  3. 实现原理:当连接超时时,使用Gateway自己的一个降级接口返回托底数据,保证程序继续运行

限流

1 生活问题

        顾名思义,限流就是限制流量,就像你宽带包有 1 G 的流量,用完了就没了。通过限流,我们可以很好地控制系统的 QPS,从而达到保护系统的目的。

        比如 Web 服务、对外 API,这种类型的服务有以下几种可能导致机器被拖垮:

                1.用户增长过快(好事)
                2.因为某个热点事件(微博热搜)
                3.竞争对象爬虫
                4.恶意的请求
        这些情况都是无法预知的,不知道什么时候会有 10 倍甚至 20 倍的流量打进来,如果真碰上这种情况,扩容是根本来不及的。
学新通
        从上图可以看出,对内而言:上游的 A B 服务直接依赖了下游的基础服务 C ,对于 A B 服务都依赖的基础服务 C 这种场景,服务 A B 其实处于某种竞争关系,如果服务 A 的并发阈值设置过大,当流量高峰期来临,有可能直接拖垮基础服务 C 并影响服务 B ,即雪崩效应。

2 解决方案:可以利用Gateway中RequestRateLimiter实现限流。

(1)常见的限流算法

  1. 计数器算法
  2. 漏桶算法
  3. 令牌桶算法

(2)Gateway中限流,RequestRateLimiter是基于Redis和Lua脚本实现的令牌桶算法。

七 健康检查配置:admin-client、actuator

八 统一配置跨域请求【网】【图灵】【乐字节】

       现在的请求通过经过gateWay网关时,需要在网关统一配置跨域请求,需求:所有请求通过,有如下配置:

  1.  
    spring:
  2.  
    cloud:
  3.  
    gateway:
  4.  
    globalcors:
  5.  
    cors-configurations:
  6.  
    '[/**]':
  7.  
    allowed-origins: "*"
  8.  
    allowed-headers: "*"
  9.  
    allow-credentials: true
  10.  
    allowed-methods:
  11.  
    - GET
  12.  
    - POST
  13.  
    - DELETE
  14.  
    - PUT
  15.  
    - OPTION
学新通

九 整合Nacos

十 整合Swagger聚合微服务系统API文档

十一 流控和降级:gateway Sentinel

十二 参考

SpringCloud gateway (史上最全) - 疯狂创客圈 - 博客园

全网最全讲解 Spring Cloud Gateway,认真看完这一篇就够了!

一篇就看懂:SpringCloud网关 - GateWay详解

SpringCloud Gateway获取body参数(一篇就够了)

Spring Cloud Gateway解决跨域问题【理解跨域】

这篇好文章是转载于:学新通技术网

  • 版权申明: 本站部分内容来自互联网,仅供学习及演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,请提供相关证据及您的身份证明,我们将在收到邮件后48小时内删除。
  • 本站站名: 学新通技术网
  • 本文地址: /boutique/detail/tanhfjbjai
系列文章
更多 icon
同类精品
更多 icon
继续加载