SpringCloud（十二）zuul网关 filter过滤器

痛定思痛。 2022-05-22 02:11 261阅读 0赞

前言：

zuul网关还可以实现过滤器功能，比如进行安全控制等，网关进行统一拦截。

网关的过滤有三个阶段，1.路由被请求前   2.路由被请求时  3.路由被请求后 4.处理请求发生错误时

下面举一个简单的例子，路由请求前：

代码实现：

在上一篇的基础上，加一个过滤器类

package com.xhx.springcloud.filter;
    
    import com.alibaba.fastjson.JSONObject;
    import com.netflix.zuul.ZuulFilter;
    import com.netflix.zuul.context.RequestContext;
    import com.netflix.zuul.exception.ZuulException;
    import org.apache.commons.lang.StringUtils;
    import org.springframework.http.HttpStatus;
    import org.springframework.http.MediaType;
    import org.springframework.stereotype.Component;
    
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    
    /**
     * xuhaixing
     * 2018/6/12 22:29
     */
    @Component
    public class AccessFilter extends ZuulFilter {
        /**
         *     pre：可以在请求被路由之前调用
         *     route：在路由请求时候被调用
         *     post：在route和error过滤器之后被调用
         *     error：处理请求时发生错误时被调用
         * @return
         */
        @Override
        public String filterType() {
            return "pre";  //请求前被调用
        }
    
        @Override
        public int filterOrder() {
            return 0; //越小越先执行
        }
    
        /**
         * 是否执行过滤器，过滤器是否执行的开关
         * 如果有多个过滤器时，上一个过滤器返回为true,下一个过滤器需要执行，如果为false就没必要执行了
         *
         */
        @Override
        public boolean shouldFilter() {
            return true; //此过滤器始终执行
           // return (boolean)RequestContext.getCurrentContext().get("isSuccess");
    
        }
    
        /**
         * 具体执行的逻辑
         * @return
         * @throws ZuulException
         */
        @Override
        public Object run() throws ZuulException {
            RequestContext requestContext = RequestContext.getCurrentContext();
            HttpServletRequest request = requestContext.getRequest(); //获取request
    
            System.out.println(String.format("%s AccessPasswordFilter request to %s", request.getMethod(), request.getRequestURL().toString()));
            String author = request.getHeader("author");
    
            if(StringUtils.isNotEmpty(author)){
                requestContext.setSendZuulResponse(true);  //对该请求进行路由
                requestContext.setResponseStatusCode(HttpStatus.OK.value());
                requestContext.set("isSuccess",true); //设置一个状态，下一个过滤器可能会用到的
                return null;
            }else {
                requestContext.setSendZuulResponse(false); //过滤该请求，不进行路由
                requestContext.setResponseStatusCode(HttpStatus.UNAUTHORIZED.value());
                JSONObject json = new JSONObject();
                json.put("msg","用户令牌错误");
                requestContext.setResponseBody(json.toJSONString());  //返回前端内容
                HttpServletResponse response = requestContext.getResponse();
                response.setContentType(MediaType.APPLICATION_JSON_UTF8_VALUE);
                requestContext.set("isSuccess",false);
                return null;
            }
        }
    }

上面代码中如果请求头中没没有author或者author获取为空，则不进行路由转发，返回到前端提示“用户令牌错误”

![70][]

**实时内容请关注微信公众号，公众号与博客同时更新：程序员星星**

![实时内容请关注微信公众号，公众号与博客同时更新][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTIzMjY0NjI_size_16_color_FFFFFF_t_70]

[70]: /images/20220522/652da21c5d814a4892e7bbd387f1aecb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTIzMjY0NjI_size_16_color_FFFFFF_t_70]: /images/20220522/7ad786706ab7416985264d6fffa72412.png