Spring Cloud Zuul动态修改路由后的请求url

淩亂°似流年 2023-07-12 03:35 10阅读 0赞

**场景：**

根据路由规则分发请求到相应子系统；but有些子系统有context-path的前缀；

**解决办法：**

自定义filter继承ZuulFilter，在run方法中重新指向新的URI地址：

package com.mortals.iot.module.common.interceptor;
    
    import com.netflix.zuul.ZuulFilter;
    import com.netflix.zuul.context.RequestContext;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants;
    import org.springframework.stereotype.Component;
    
    /**
     * @Description Zuul过滤器，分析记录请求
     * @Date 2020/3/6 11:55
     * @Version 1.0
     */
    @Component
    public class MyZuulFilter extends ZuulFilter {
    
        private static Logger logger = LoggerFactory.getLogger(MyZuulFilter.class);
    
        @Override
        public String filterType() {
            //四种类型：pre,routing,error,post
            //pre：主要用在路由映射的阶段是寻找路由映射表的
            //routing:具体的路由转发过滤器是在routing路由器，具体的请求转发的时候会调用
            //error:一旦前面的过滤器出错了，会调用error过滤器。
            //post:当routing，error运行完后才会调用该过滤器，是在最后阶段的
            return FilterConstants.PRE_TYPE;
        }
    
        /**
         * 自定义过滤器执行的顺序，数值越大越靠后执行，越小就越先执行
         */
        @Override
        public int filterOrder() {
            //执行顺序晚于自带filter
            return FilterConstants.PRE_DECORATION_FILTER_ORDER + 1;
        }
    
        /**
         * 控制过滤器生效不生效，未来扩展可以在里面写一串逻辑来控制
         */
        @Override
        public boolean shouldFilter() {
            return true;
        }
    
        /**
         * 执行过滤逻辑（动态路由拼接子系统前缀context-path）
         * @return
         */
        @Override
        public Object run() {
    
            RequestContext context = RequestContext.getCurrentContext();
            String originalRequestPath = context.get(FilterConstants.REQUEST_URI_KEY).toString();
    
            String modifiedRequestPath = originalRequestPath;
            //TODO 后续继续完善各子系统前缀
            if (originalRequestPath.contains("/api/portal")){
                modifiedRequestPath = "/m" + originalRequestPath;
            }else if(originalRequestPath.contains("/api/wallet") || originalRequestPath.contains("/api/ego")){
                modifiedRequestPath = "/h" + originalRequestPath;
            }
            context.put(FilterConstants.REQUEST_URI_KEY, modifiedRequestPath);
            return null;
        }
    }

路由规则：

ribbon:
      ReadTimeout: 10000
      ConnectTimeout: 10000
    hystrix:
      command:
        default:
          execution:
            isolation:
              thread:
                timeoutInMilliseconds: 60000
    
    zuul:
      ignored-services: "*"
      prefix: /api
      strip-prefix: false
      routes:
        test-partner-provider:
          path: /test/**
          serviceId: test-partner-provider
          strip-prefix: false
        portal:
          path: /portal/**
          serviceId: iot-portal-api
          strip-prefix: false

[感谢思路][Link 1]

[Link 1]: https://www.jianshu.com/p/1d7fe321649a