SpringCloud - Gateway网关 - 《小羊的图书馆》

什么是网关
SpringCloud Gateway
- WebFlux
- 工作流程
测试项目搭建
Predicate是什么
Filter

什么是网关

如上图所示
API网关是一个搭建在客户端和微服务之间的服务，我们可以在API网关中处理一些非业务功能的逻辑，比如权限验证、监控、缓存、请求路由等等

客户端在发起请求的时候，会将请求发送到微服务网关中，然后再由网关将请求转发到微服务实例。因此，客户端只用知道网关的地址即可，而不需要维护大量的服务地址，简化了客户端的配置。在网关中，我们进行一些额外的操作，比如鉴权、流控、过滤等等

SpringCloud Gateway

SpringCloud Gateway是基于WebFlux框架实现的，而WebFlux框架底层则是使用了高性能的Reactor模式的通信框架Netty

WebFlux

与传统的SpringMVC等基于Servlet API和Servlet容器基础之上运行的，WebFlux是一个典型的非阻塞异步的框架

工作流程

路由（Route）：路由是构建网关的基本模块，它由ID,目标URI,一系列的断言和过滤器组成,如断言为true则匹配该路由；
断言（Predicate）：参考的是Java8的java.util.function.Predicate，开发人员可以匹配HTTP请求中的所有内容(例如请求头或请求参数),如果请求与断言相匹配则进行路由；
过滤（Filter）：指的是Spring框架中的GatewayFilter的实例，使用过滤器,可以在请求被路由前或者之后对请求进行修改。

先说断言，这个东西其实可以看成一个布尔表达式。如果为真就啥都不干，放你过去。如果为假，即断言不成立，就不让你过去接着说下路由，首先一个请求进来之后，网关会根据请求的URL转发到对应的路由上。而每个路由上又会有对应的断言，上文说了，断言就是个布尔表达式。它会判断请求的路径是否符合要求。如果符合要求则让你进路由，否则，哪凉快去哪里。

测试项目搭建

新建模块

新建Module - cloud-gateway-gateway9527

<dependencies>
  <!--gateway-->
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-gateway</artifactId>
  </dependency>
  <!--eureka-client-->
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  </dependency>
  <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
  <dependency>
    <groupId>com.lun.springcloud</groupId>
    <artifactId>cloud-api-commons</artifactId>
    <version>${project.version}</version>
  </dependency>
  <!--一般基础配置类-->
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-devtools</artifactId>
    <scope>runtime</scope>
    <optional>true</optional>
  </dependency>
  <dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
  </dependency>
</dependencies>

server:
  port: 9527
spring:
  application:
    name: cloud-gateway
eureka:
  instance:
    hostname: cloud-gateway-service
  client: #服务提供者provider注册进eureka服务列表内
    service-url:
      register-with-eureka: true
      fetch-registry: true
      defaultZone: http://eureka7001.com:7001/eureka

配置网关

server:
  port: 9527
spring:
  application:
    name: cloud-gateway
#############################新增网关配置###########################
  cloud:
    gateway:
      routes:
        - id: payment_routh #payment_route    #路由的ID，没有固定规则但要求唯一，建议配合服务名
          uri: http://localhost:8001          #匹配后提供服务的路由地址
          #uri: lb://cloud-payment-service #匹配后提供服务的路由地址
          predicates:
            - Path=/payment/get/**         # 断言，路径相匹配的进行路由
####################################################################
eureka:
  instance:
    hostname: cloud-gateway-service
  client: #服务提供者provider注册进eureka服务列表内
    service-url:
      register-with-eureka: true
      fetch-registry: true
      defaultZone: http://eureka7001.com:7001/eureka

分别访问http://localhost:8001/payment/get/one/31和http://localhost:9527/payment/get/one/31
会发现两者都可以访问成功，并且返回相同的结果

配置网关的方式

通过yml配置文件的方式

通过yml配置文件进行配置的方式如上代码块所示

通过Bean注入配置类的方式

新建GatewayConfig的类
通过路由的方式，将http://news.baidu.com/guonei映射到http://localhost:9527/guonei上

/**
 * Created By Intellij IDEA
 *
 * @author ssssheep
 * @package org.example.springcloud.config
 * @datetime 2022/8/11 星期四
 */
@Configuration
public class GatewayConfig {
    @Bean
    public RouteLocator customRouteLocator(RouteLocatorBuilder builder) {
        RouteLocatorBuilder.Builder routes = builder.routes();
        return routes.route("path_route_payment",
                        r -> r.path("/guonei").uri("http://news.baidu.com/guonei"))
                .build();
    }
}

可以发现，能够正常访问。

配置动态路由

在我们的yaml配置文件中，我们将请求的实际地址固定写死了，然而实际上我们提供服务的机器可能不止一台，这样的话，我们实际请求的地址应该是从注册中心处获取的，而不是固定写死的

因此，我们应这样来配置动态路由：
请求路径只写我们的服务名称，实际调用的是哪个微服务，由负载均衡的算法来决定

再次请求网关上的接口，可以发现8001和8002两个端口切换出现

未完待续

Gateway网关