Zuul实现过滤器

  • Zuul

    Netflix zuul作为API网关集成在spring cloud分布式集群中,是一个智能的应用服务器,对外暴露分布式中的请求调度和过滤,实现请求路由、负载均衡、与服务治理框架整合、请求转发的熔断机制和服务聚合等功能。

  • 过滤器类型:

    • PRE:请求被路由之前被调用,身份验证
    • ROUTING:将请求路由到微服务。
    • POST:路由到微服务之后执行
    • ERROR:在其他阶段发生错误时执行。
  • 编写zuul过滤器

    public class LogFilter extends ZuulFilter {
      private static final Logger LOGGER = LogFilter.getLogger(PreRequestLogFilter.class);
      @Override
      public String filterType() {
        return "pre";
      }
      @Override
      public int filterOrder() {
        return 0;
      }
      @Override
      public boolean shouldFilter() {
        return true;
      }
      @Override
      public Object run() {
        RequestContext ctx = RequestContext.getCurrentContext();
        HttpServletRequest request = ctx.getRequest();
        LogFilter.LOGGER.info(String.format("send %s request to %s", request.getMethod(), request.getRequestURL().toString()));
        return null;
      }
    }
    
  • zuul实现filter的方法:

    • filterType:返回过滤器的类型:pre、route、post、error
    • filterOrder:返回int值,来确定filter的执行顺序,不同的过滤器允许返回相同的数字
    • shouldFilter:返回boolean确定filter是否执行
    • run:过滤器执行内容
  • 在启动类中注册过滤器

    @Bean  
    public LogFilter logFilter() {  
        return new LogFilter();  
    }  
    
  • 禁用过滤器,在配置文件中添加:

    zuul.<SimpleClassName>.<filterType>.disable = true
    
  • 用户权限验证失败不进行路由:

    @Override
    public Object run() {
        RequestContext ctx = RequestContext.getCurrentContext();
        HttpServletRequest request = ctx.getRequest();
        request.getMethod(), request.getRequestURL().toString()));
        String token = request.getHeader("token");
        if (!ifRight(token)){
            //认证失败
            logger.error("token验证失败");
            HttpServletResponse response = ctx.getResponse();
            response.setCharacterEncoding("utf-8");  //设置字符集
            response.setContentType("text/html; charset=utf-8"); //设置相应格式
            response.setStatus(401);
            ctx.setSendZuulResponse(false); //不进行路由
            try {
                response.getWriter().write("token 验证失败"); //响应体
            } catch (IOException e) {
                loger.error("response io异常")
                e.printStackTrace();
            }
            ctx.setResponse(response);
            return null;
        }
        logger.info("token验证成功");
        return null;
    }
    
Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐