GateWay网关自定义全局过滤器

GateWay网关自定义全局过滤器

简介

Gateway 的核心是一系列的过滤器，主要作用：过滤和路由。作为整个微服务最前沿的防火墙和代理器，可隐藏微服务结点IP端口信息。
Geteway 本身就是一个微服务，需要注册到Eureka / nacos中心。
不管是来自于客户端（PC或移动端）的请求，还是服务内部调用，一切服务的请求都可以经过网关实现鉴权，动态路由和服务的统一入口。

自定义全局过滤器

实现接口

GlobalFilter接口 重写filter方法 拿到token，判断token是否为空，是否有效，不为空且有效则放行，如果token为null、不存在或无效则设置返回的状态码为：未授权

Order接口 重写getOrder()方法 系统调用该方法获得过滤器的优先级，返回的数字越小优先级越高

实现filter

@Slf4j
public class MyGlobalFilter implements GlobalFilter , Ordered {
    
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        
        // 1：拦截方法，拦截到请求后，自动执行
        log.info("filter 拦截方法，拦截到请求后，自动执行");
        
        // 获取token，token可能在请求头，请求体，cookie中
        // token在请求体中情况，form-data参数方式
        String jwt =  exchange.getRequest().getQueryParams().getFirst("token");
        
        // token为空
        if(jwt == null || "".equals(jwt)){
            // 未登录 跳转到登录页
            log.info("----跳到登录页面");
            
            // 设置401状态码，提示用户没有权限
            exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
            return exchange.getResponse().setComplete();
        }
        
        // token不为空
        if (!JWTUtils.verifyJWT(jwt)) {
            // 登录token失效 跳转到登录页
            log.info("----跳到登录页面");
            
            // 无效令牌
            exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED);
            // 响应空数据
            return exchange.getResponse().setComplete();
        }
        
        // 2：全部放行
        return chain.filter(exchange);
    }

    @Override
    public int getOrder() {
        // 3：系统调用该方法获得过滤器的优先级
        // 数字越小，越优先
        return 1; 
    }
}