SpringCloud-Gateway 网关路由断言过滤

Posted 2021-02-21 农夫三拳有点疼

Gateway 简介

是什么？

Spring Cloud 全家桶中有个很重要的组件：网关。在 1.x 版本中使用的是 Zuul 网关，但是到了 2.x，由于Zuul的升级不断跳票，Spring Cloud 自己研发了一套网关组件：Spring Cloud Gateway。

Spring Cloud Gateway基于 Spring Boot 2.x，Spring WebFlux 和 Project Reactor 构建，使用了 Webflux 中的 reactor-netty 响应式编程组件，底层使用了 Netty 通讯框架。

详见：官网

能干嘛？

反向代理

鉴权

流量控制

熔断

日志监控

......

网关在微服务架构中的位置

Gateway 的三大概念

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

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

Filter（过滤）：指的是 Spring 框架中 GatewayFilter 的实例，使用过滤器，可以在请求被路由之前或之后对请求进行修改

工作流程

Clients make requests to Spring Cloud Gateway. If the Gateway Handler Mapping determines that a request matches a route, it is sent to the Gateway Web Handler. This handler runs the request through a filter chain that is specific to the request. The reason the filters are divided by the dotted line is that filters can run logic both before and after the proxy request is sent. All “pre” filter logic is executed. Then the proxy request is made. After the proxy request is made, the “post” filter logic is run.

翻译：客户端向 Spring Cloud Gateway 发出请求。如果网关处理程序映射确定请求与路由匹配，则将其发送到网关 Web 处理程序。该处理程序通过特定于请求的过滤器链来运行请求。 筛选器由虚线分隔的原因是，筛选器可以在发送代理请求之前和之后运行逻辑。所有 “前置“ 过滤器逻辑均被执行，然后发出代理请求，发出代理请求后，将运行“ 后置 ”过滤器逻辑。

总结：路由转发 + 执行过滤器链

两种配置方式

配置文件方式

我们以访问「百度新闻网」为例，添加如下配置

server:
  port: 9527
spring:
  application:
    name: cloud-gateway9527
  cloud:
    gateway:
      routes:
        - id: news						# 路由id
          uri: http://news.baidu.com	# 真实调用地址
          predicates:
            - Path=/guonei				# 断言，符合规则进行路由

浏览器虽然输入 localhost:9527/guonei，却会转发到指定的地址

编码方式

新增配置文件

@Configuration
public class GatewayConfig {
    @Bean
    public RouteLocator routes(RouteLocatorBuilder builder) {
        return builder.routes()
                .route("news2", r -> r.path("/guoji").uri("http://news.baidu.com"))
                .build();
    }
}

效果：

动态路由

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

spring:
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true #开启从注册中心动态创建路由的功能，利用微服务名进行路由
      routes:
        - id: payment_routh1
          #uri: http://localhost:8001     #静态，写死了地址，只能调用一个服务
          uri: lb://CLOUD-PAYMENT-SERVICE #动态，lb://微服务名
          predicates:
            - Path=/payment/get/**
        - id: payment_routh2
          #uri: http://localhost:8001
          uri: lb://CLOUD-PAYMENT-SERVICE
          predicates:
            - Path=/payment/lb/**

Predicate 的使用

时间相关配置

After：在指定时间之后进行路由

Before：在指定时间之前进行路由

Between：在指定时间之间进行路由

predicates:
    - Path=/payment/lb/**
    #- After=2020-04-25T16:30:58.215+08:00[Asia/Shanghai]
    #- Before=2020-04-25T16:40:58.215+08:00[Asia/Shanghai]
    - Between=2020-04-25T16:35:58.215+08:00[Asia/Shanghai],2020-04-25T16:40:58.215+08:00[Asia/Shanghai]

上述配置的时间格式可以通过以下代码得到

@Test
public void test(){
    ZonedDateTime now = ZonedDateTime.now();
    System.out.println(now);
}

请求相关配置

Cookie

配置说明：【Cookie=cookie名, cookie值的正则表达式规则】

predicates:
  - Path=/payment/lb/**
  - Cookie=id, [0-9]

使用 curl 工具模拟携带 cookie 发送请求

Header

配置说明：【Header=header名, header值的正则表达式规则】

predicates:
  - Path=/payment/lb/**
  - Header=h, [a-h]

Host

配置说明：【Host=主机名（可配置多个，也可以使用通配符）】

predicates:
  - Path=/payment/lb/**
  - Host=**.a.com,**.b.cn

Method

配置说明：【Method=请求类型】

predicates:
  - Path=/payment/lb/**
  - Method=GET

Path

配置说明：【Path=请求路径】

predicates:
  - Path=/payment/lb/**

Query

配置说明：【Query=参数名，参数值】

predicates:
  - Path=/payment/lb/**
  - Query=name, zhangsan

详见：官网

Filter 的使用

• 生命周期：pre、post
• 种类：GatewayFilter、GlobalFilter

GatewayFilter 在官方文档有几十种！详细配置可参考 官网，这里主要介绍自定义全局过滤器。

@Component
@Slf4j
public class MyGlobalFilter implements GlobalFilter, Ordered {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        String username = exchange.getRequest().getQueryParams().getFirst("username");
        //用户名为空时，给出错误响应
        if (username == null) {
            log.info("用户名为空，非法登录");
            exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);
            return exchange.getResponse().setComplete();
        }
        return chain.filter(exchange);
    }

    @Override
    public int getOrder() {
        return 0;
    }
}

---

获取完整代码