spring cloud 使用 Zuul实现过滤器

谁借莪１个温暖的怀抱￠ 2022-06-01 07:35 227阅读 0赞

# 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;
        }