总结

路由=ID+目标URL+断言+过滤器
路由可以在yaml配置文件中配置也可以在代码中配置
有多重HTTP断言方式
两种过滤器全局过滤器和局部过滤器
路由负载均衡
统一网关日志/鉴权：实现GlobalFilter接口的filter方法

作用

路由=ID+目标URL+断言+过滤器
断言：如果HTTP请求和断言匹配则进行路由
过滤器：在HTTP请求被路由前后对HTTP请求进行处理

功能：

动态路由
统一网关日志：通过全局过滤器实现
统一网关鉴权：通过全局过滤器实现
服务发现
负载均衡
反向代理
熔断限流

使用/路由入门

pom.xml

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-gateway</artifactId>
</dependency>

路由配置方式1：在yaml文件中配置
application.yaml

spring:
  application:
    name: gateway
  cloud:
    gateway:
      routes: # 路由=ID+目标URL+断言+过滤器
        - id: payment_route # 路由ID，要求唯一
          uri: http://localhost:8001  # 匹配此路由后需要路由的地址
          predicates:
            - Path=/payment/get/** # 断言，HTTP请求是否匹配此路径
        - id: payment_route2
          uri: http://localhost:8001
          predicates:
            Path=/payment/lb/**

路由配置方式2：在代码中配置

package com.xcrj.springcloud.configuration;

import org.springframework.cloud.gateway.route.RouteLocator;
import org.springframework.cloud.gateway.route.builder.RouteLocatorBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class GateWayConfiguration {

    @Bean
    public RouteLocator customRouteLocator(RouteLocatorBuilder routeLocatorBuilder){
        RouteLocatorBuilder.Builder routes=routeLocatorBuilder.routes();
		// 路由ID，断言，再路由地址
        routes.route("payment_route ",r->r.path("/payment/get/**").uri("http://localhost:8001")).build();
        return routes.build();
    }
}

main

package com.xcrj.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

@SpringBootApplication
@EnableEurekaClient
public class GatewayMain9527 {
    public static void main(String[] args) {
        SpringApplication.run(GatewayMain9527.class, args);
    }
}

使用/路由负载均衡

application.yaml

spring:
  application:
    name: gateway
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true # 动态路由，开启从注册中心动态创建路由的功能，利用微服务名称进行路由
      routes:
        - id: payment_route
          uri: lb://cloud-payment-service #注意:以lb开头，不是HTTP开头；使用微服务名
          predicates:
            - Path=/payment/get/**
        - id: payment_route2
          uri: lb://cloud-payment-service #注意:以lb开头，不是HTTP开头；使用微服务名
          predicates:
            - Path=/payment/lb/**

使用/断言

官网所有断言规则

application.yaml

spring:
  application:
    name: gateway
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true # 动态路由，开启从注册中心动态创建路由的功能，利用微服务名称进行路由
      routes:
        - id: payment_route
          uri: lb://cloud-payment-service #注意:以lb开头，不是HTTP开头；使用微服务名
          predicates:
            - Path=/payment/lb/**
            - Method=Get
            - Header=X-Request-Id,\d+ #请求头要有X-Request-Id属性；并且属性值为整数（正则匹配）
            - Cookie=username,xcrj
            - After=2022-05-06T17:52:11.834+08:00[Asia/Shanghai]
            - Before=2022-04-06T17:52:11.834+08:00[Asia/Shanghai]
            - Between=2022-04-06T17:52:11.834+08:00[Asia/Shanghai],2020-04-06T17:52:11.834+08:00[Asia/Shanghai]

使用/过滤器

官网局部过滤器: GatewayFilter
官网全局过滤器: GlobalFilter

application.yaml

spring:
  application:
    name: gateway
  cloud:
    gateway:
      discovery:
        locator:
          enabled: true
      routes:
        - id: payment_route
          uri: lb://cloud-payment-service
          predicates:
            - Path=/payment/lb/**
          filters:
            - AddRequestParameter=name,xcrj # URL增加请求参数

使用/统一网关鉴权全局过滤器

package com.xcrj.springcloud.filter;

import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
import java.util.Date;

@Component
@Slf4j
// 实现GlobalFilter接口的filter方法
public class GlobalGatewayAuthFilter implements GlobalFilter, Ordered {
    /**功能描述:思想跟servlet的filter一样<br>
     * 1.servlet-filter：
     *  初始化（可获取配置参数）：public void  init(FilterConfig config);
     *  执行过滤（入参Request、Response）：public void  doFilter(ServletRequest request, ServletResponse response, FilterChain chain);
     *          // 把请求传回过滤链
     *         chain.doFilter(request,response);
     *  销毁filter：public void destroy();
     * 2.spring cloud gateway:
     *  类似于servlet-filter的doFilter()方法，ServerWebExchange exchange可以获取request和response
     */
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        log.info("进入 GlobalGatewayLogFilter");
        String username=exchange.getRequest().getQueryParams().getFirst("username");
		// 如果是非法用户不往后传递
        if(StringUtils.isBlank(username)){
            log.info("非法用户");
            exchange.getResponse().setStatusCode(HttpStatus.NOT_ACCEPTABLE);
            return exchange.getResponse().setComplete();
        }
        return chain.filter(exchange);
    }

	/**
	 * order值最小为-1，越小优先级越高
	 */
    @Override
    public int getOrder() {
        return 0;
    }
}