SpringCloud系列教程：微服务的未来（十四）网关登录校验、自定义过滤器GlobalFilter、GatawayFilter

前言

在微服务架构中，API 网关扮演着至关重要的角色，负责路由请求、执行安全验证、流量控制等任务。Spring Cloud Gateway 作为一个强大的网关解决方案，提供了灵活的方式来实现这些功能。

本篇博客将重点介绍如何在 Spring Cloud Gateway 中实现网关登录校验，以及如何利用自定义过滤器（GlobalFilter 和 GatewayFilter）来处理请求和响应。通过这些技术，开发者可以在网关层统一处理认证、授权等功能，同时保持对路由的细粒度控制。

网关登录校验

登录是基于JWT实现的，JWT的校验算法较为复杂，并且需要使用秘钥。如果每个微服务都独立进行JWT校验，会面临两个主要问题：

每个微服务都必须持有JWT的秘钥，这样会带来安全隐患。
每个微服务需要重复编写登录校验和权限验证的代码，增加了开发和维护的复杂度。

网关是所有微服务的统一入口，所有请求都会先经过网关，可以将JWT的校验工作集中到网关中进行处理。这样做能够有效解决上述问题：

秘钥只需在网关和用户服务中存储，避免了在每个微服务中重复存储秘钥的风险。
登录校验功能只需要在网关中实现，简化了开发流程并避免了代码的重复编写。

网络请求处理流程图：

在 Spring Cloud 微服务中，如果你想在网关转发请求之前进行登录校验（例如，验证JWT令牌），通常可以通过在网关中配置全局过滤器（GlobalFilter）来完成。Spring Cloud Gateway 提供了一种简便的方式来处理这一需求。

实现步骤：

创建一个全局过滤器
Spring Cloud Gateway 提供了GlobalFilter接口，你可以通过实现该接口来定义网关请求的拦截和处理逻辑。
提取并验证 JWT
在全局过滤器中，提取请求头中的Authorization字段中的JWT令牌，并使用签名密钥验证JWT是否合法。
决定是否继续转发请求
根据JWT的有效性，如果令牌合法且未过期，则继续请求的转发。如果无效或过期，则直接返回401 Unauthorized响应。

自定义过滤器

自定义GlobalFilter

网关过滤器有两种，分别是:

GatewayFilter:路由过滤器，作用于任意指定的路由;默认不生效，要配置到路由后生效。
GlobalFilter:全局过滤器，作用范围是所有路由;声明后自动生效。

两种过滤器的方法签名一致:

/*** 处理请求并将其传递给下一个过滤器* @param exchange 当前请求的上下文，其中包含request、response等各种数据* @param chain 过滤器链，基于它向下传递请求* @return 根据返回值标记当前请求是否被完成或拦截，chain.filter(exchange)就放行了。*/
Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain);

创建MyGlobalFilter类

package com.hmall.gateway.filters;import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.HttpHeaders;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;@Component
public class MyGlobalFilter implements GlobalFilter , Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {//模拟登录逻辑ServerHttpRequest request = exchange.getRequest();HttpHeaders headers = request.getHeaders();System.out.println("headers = "+headers);//放行return chain.filter(exchange);}@Overridepublic int getOrder() {//返回值越小，优先级越高return 0;}
}

在通常业务过程中GlobalFilter比自定义GatewayFilter更容易实现。

自定义过滤器GatewayFilter

自定义GatewayFilter不是直接实现GatewayFilter，而是实现AbstractGatewayFilterFactory，示例如下:

@Component
public class PrintAnyGatewayFilterFactory extends AbstractGatewayFilterFactory<Object> {@Overridepublic GatewayFilter apply(Object config) {return new GatewayFilter() {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {// 编写过滤器逻辑System.out.println("PrintAny filter执行了");// 放行return chain.filter(exchange);}};}
}

对应的配置文件application.yaml如下：

spring:cloud:gateway:default-filters:- AddRequestHeader=a,b # AddRequestHeader：这个过滤器会将指定的请求头添加到每个请求中。a,b 代表的是要添加的请求头和它的值，a 是请求头的名字，b 是请求头的值。- PrintAny=1,2,3 # 注意，这里多个参数以","隔开，将来会按照shortcutFieldOrder()方法返回的参数顺序依次复制

在这里插入图片描述
实现的PrintAnyGatewayFilterFactory类

package com.hmall.gateway.filters;import org.springframework.cloud.gateway.filter.GatewayFilter;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;@Component
public class PrintAnyGatewayFilterFactory extends AbstractGatewayFilterFactory<Object> {@Overridepublic GatewayFilter apply(Object config) {return new GatewayFilter() {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {System.out.println("PrintAny filter执行成功");return chain.filter(exchange);}};}
}

如果需要设置对用的优先级，代码如下：

	@Overridepublic GatewayFilter apply(Object config) {return new OrderedGatewayFilter(new GatewayFilter() {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {System.out.println("PrintAny filter执行成功");return chain.filter(exchange);}},1);}

当然，这种过滤器还支持配置参数，在PrintAnyGatewayFilterFactory类里面

    // 自定义配置属性，成员变量名称很重要，下面会用到@Datastatic class Config{private String a;private String b;private String c;}// 将变量名称依次返回，顺序很重要，将来读取参数时需要按顺序获取@Overridepublic List<String> shortcutFieldOrder() {return List.of("a", "b", "c");}public PrintAnyGatewayFilterFactory(){super(Config.class);}// 返回当前配置类的类型，也就是内部的Config@Overridepublic Class<Config> getConfigClass() {return Config.class;}