{"id":1738,"date":"2023-03-26T21:12:47","date_gmt":"2023-03-26T13:12:47","guid":{"rendered":"https:\/\/www.appblog.cn\/?p=1738"},"modified":"2023-04-23T21:30:46","modified_gmt":"2023-04-23T13:30:46","slug":"zuul-dynamic-routing-source-code-and-several-implementation-methods","status":"publish","type":"post","link":"https:\/\/www.appblog.cn\/index.php\/2023\/03\/26\/zuul-dynamic-routing-source-code-and-several-implementation-methods\/","title":{"rendered":"Zuul\u52a8\u6001\u8def\u7531\u6e90\u7801\u53ca\u51e0\u79cd\u5b9e\u73b0\u65b9\u5f0f"},"content":{"rendered":"

\u4ecb\u7ecdZuul\u8def\u7531\u7684\u6e90\u7801\u4ee5\u53ca\u5b9e\u73b0\u52a8\u6001\u8def\u7531\u7684\u51e0\u79cd\u65b9\u5f0f\uff0c\u8def\u7531\u4fe1\u606f\u53ef\u4ee5\u6765\u81eaProperties\u6587\u4ef6\u3001DB\u3001Apollo\u7b49\u3002<\/p>\n

\u901a\u8fc7\u9605\u8bfb Spring Cloud\u6e90\u7801\u5b66\u4e60\u4e4bZuul \u7b80\u8981\u4e86\u89e3\u8def\u7531\u6e90\u7801\u6d41\u7a0b\u3002<\/p>\n

\u8def\u7531\u6e90\u7801<\/h2>\n

<\/p>\n

\u672c\u6587\u57fa\u4e8e\u4e0b\u56fe\u573a\u666f\u505a\u6f14\u793a\uff0c\u6587\u4e2d\u4ee3\u7801\u6765\u81ea\u6e90\u7801\uff0c\u4f46\u5b58\u5728\u5927\u5e45\u5220\u51cf\u3002<\/p>\n

\"Zuul\u8def\u7531\u6d41\u7a0b\"<\/p>\n

\u8bf7\u6c42\u8fbe\u5230ZuulServlet\u540e\uff0cZuulServlet \u7ec4\u7ec7\u8def\u7531\u7684\u5904\u7406\u903b\u8f91\uff0c\u5982\u4e0b\uff1a<\/p>\n

public void service(servletRequest, servletResponse) {\n   \/\/ \u6267\u884c "pre" \u7c7b\u578b ZuulFilter\n   preRoute();\n   \/\/ \u6267\u884c "route" \u7c7b\u578b ZuulFilter\n   route();\n   \/\/ \u6267\u884c "post" \u7c7b\u578b ZuulFilter\n   postRoute();\n}<\/code><\/pre>\n
\u9884\u5904\u7406<\/h3>\n
pre<\/code>\u7c7b\u578bZuulFilter<\/code>\u4e2d\uff0cPreDecorationFilter<\/code>\u4f1a\u6839\u636e\u8def\u7531\u4fe1\u606f\u8fdb\u884c\u9884\u5904\u7406\uff0c\u5176\u5904\u7406\u7ed3\u679c\u51b3\u5b9a\u4e86\u4f7f\u7528\u54ea\u4e2aroute<\/code>\u7c7b\u578bZuulFilter<\/code>\u6765\u5b9e\u9645\u5904\u7406\u8bf7\u6c42\u3002<\/p>\n
\u5148\u770b\u770broute<\/code>\u7c7b\u578b\u7684SimpleHostRoutingFilter<\/code>\u3001RibbonRoutingFilter<\/code>\u7684\u5904\u7406\u6761\u4ef6(shouldFilter<\/code>)\uff0c\u5b83\u4eec\u8d1f\u8d23\u5b9e\u9645\u7684\u8bf7\u6c42\u8f6c\u53d1\u3002<\/p>\n
\/\/ SimpleHostRoutingFilter\npublic boolean shouldFilter() {\n  return RequestContext.getCurrentContext().getRouteHost() != null\n      && RequestContext.getCurrentContext().sendZuulResponse();\n}\n\n\/\/ RibbonRoutingFilter\npublic boolean shouldFilter() {\n  RequestContext ctx = RequestContext.getCurrentContext();\n  return (ctx.getRouteHost() == null && ctx.get("serviceId") != null\n      && ctx.sendZuulResponse());\n}<\/code><\/pre>\n
    \n
  • \u76f8\u540c\u70b9<\/strong>\uff1a\u90fd\u9700\u8981\u6ee1\u8db3sendZuulResponse()<\/code>\u5373\u9700\u8981\u5c06Response\u53cd\u9988\u7ed9\u5ba2\u6237\u7aef.<\/li>\n
  • \u4e0d\u540c\u70b9<\/strong>\uff1aSimpleHostRoutingFilter<\/code>\u9700\u8981RouteHost<\/code>\u4e0d\u4e3a\u7a7a\uff0cRibbonRoutingFilter<\/code>\u9700\u8981serviceId<\/code>\u4e0d\u4e3a\u7a7a\u800c\u4e14RouteHost<\/code>\u4e3a\u7a7a\u3002<\/li>\n<\/ul>\n
    \u4e0b\u9762\u662fapplication.yml<\/code>\u4e2dZuul<\/code>\u7684\u914d\u7f6e\u793a\u4f8b\uff1a<\/p>\n
    zuul:\n  servlet-path:\n  routes:\n    service1:\n      path: \/api\/service1\/**\n      serviceId: service1\n    github:\n      path: \/github\/**\n      url: https:\/\/github.com\/<\/code><\/pre>\n
    routes<\/code>\u4e2dservice1<\/code>\u6709serviceId<\/code>\u6ee1\u8db3RibbonRoutingFilter<\/code>\uff0cgithub<\/code>\u6709host<\/code>\u6ee1\u8db3SimpleHostRoutingFilter<\/code>\u3002<\/p>\n
    \u518d\u770b\u770bPreDecorationFilter<\/code>\u662f\u5982\u4f55\u9884\u5904\u7406\u5f97\u5230RouteHost<\/code>\u3001serviceId<\/code>\u7684\uff0c\u4e0b\u9762\u662f\u5176run()<\/code><\/p>\n
    @Override\npublic Object run() {\n    RequestContext ctx = RequestContext.getCurrentContext();\n    final String requestURI = \u6839\u636e request \u63d0\u53d6requestURI;\n\n    \/\/ \u6839\u636erequestURI\u83b7\u53d6\u8def\u7531\u4fe1\u606f\n    Route route = this.routeLocator.getMatchingRoute(requestURI);\n    if (route != null) {\n        String location = route.getLocation();\n        if (location != null) {\n            \/\/ \u4ee5https\u6216http\u5f00\u5934, \u8bbe\u7f6eRouteHost\n            if (location.startsWith("http:") || location.startsWith("https:")) {\n                ctx.setRouteHost(getUrl(location));\n            }\n            \/\/ \u4ee5 forward: \u5f00\u5934\n            else if (location.startsWith("forward:")) {\n                ctx.setRouteHost(null);\n                return null;\n            }\n            \/\/ \u8bbe\u7f6e serviceId, RouteHost\u7f6e\u7a7a\n            else {\n                ctx.set(SERVICE_ID_KEY, location);\n                ctx.setRouteHost(null);\n            }\n        }\n    }\n}<\/code><\/pre>\n
    routeLocator.getMatchingRoute<\/code>\u662f\u91cd\u70b9\uff0c\u6839\u636e\u8bf7\u6c42URI<\/code>\u83b7\u53d6Route<\/code>\uff0c\u518d\u6839\u636eRoute<\/code>\u7684location<\/code>\u662f\u5426\u5339\u914dhttp:<\/code>\u3001https:<\/code>\u3001forward:<\/code>\u524d\u7f00\u6765\u8bbe\u7f6e\u5c5e\u6027\u3002<\/p>\n
    \u4f8b\u5982\u8bbf\u95eehttp:\/\/localhost:8080\/service1\/echo<\/code>\u3001http:\/\/localhost:8080\/github\/echo<\/code>\u83b7\u53d6\u7684Route<\/code>\uff0c\u5176location<\/code>\u5206\u522b\u4e3a\uff1aservice1<\/code>\u3001https:\/\/github.com<\/code>\u3002<\/p>\n
    Route{id='service1', fullPath='\/service1\/echo', path='\/echo', location='service1', prefix='\/service1'}\nRoute{id='github', fullPath='\/github\/echo', path='\/echo', location='https:\/\/github.com\/', prefix='\/github'}<\/code><\/pre>\n
    \u8bf7\u6c42\u8f6c\u53d1<\/h3>\n
    \u8bf7\u6c42\u8f6c\u53d1\u7531SimpleHostRoutingFilter<\/code>\u3001RibbonRoutingFilter<\/code>\u5b8c\u6210\uff0c\u524d\u8005\u901a\u8fc7Apache HttpClient<\/code>\u6765\u8f6c\u53d1\u8bf7\u6c42\uff0c\u540e\u8005\u4e0eRibbon<\/code>\u3001Hystrix<\/code>\u4e00\u8d77\uff0c\u5b8c\u6210\u5ba2\u6237\u7aef\u8d1f\u8f7d\u5747\u8861\u53ca\u5e94\u7528\u5b88\u62a4\u5de5\u4f5c\u3002<\/p>\n
    \u8def\u7531\u5b9a\u4f4d<\/h3>\n
    PreDecorationFilter<\/code>\u4e2d\u901a\u8fc7RouteLocator<\/code>\u6839\u636eURI<\/code>\u83b7\u53d6Route<\/code>\uff0c\u52a8\u6001\u8def\u7531\u53ef\u4ee5\u901a\u8fc7\u62d3\u5c55RouteLocator<\/code>\u6765\u5b8c\u6210\u3002<\/p>\n
    public interface RouteLocator {\n  Collection<String> getIgnoredPaths();\n  List<Route> getRoutes();\n  Route getMatchingRoute(String path);\n}<\/code><\/pre>\n
    RouteLocator \u4e3b\u8981\u80fd\u529b\u6709\uff1a<\/p>\n
      \n
    • \u6839\u636epath<\/code>\u83b7\u53d6Route<\/code><\/li>\n
    • \u83b7\u53d6\u6240\u6709Route<\/code><\/li>\n<\/ul>\n
      \u4e0b\u9762\u662f\u7c7b\u56fe\uff0c\u7a0d\u5fae\u7b80\u4ecb\u4e0b\u5404\u5b50\u7c7b\u3002<\/p>\n
      \"RouteLocator\u7c7b\u56fe\"<\/p>\n
      SimpleRouteLocator<\/h4>\n
      \u7b80\u5355\u8def\u7531\u5b9a\u4f4d\u5668\uff0c\u8def\u7531\u4fe1\u606f\u6765\u81eaZuulProperties<\/code>\uff0clocateRoutes()<\/code>\u662f\u5b9a\u4f4d\u8def\u7531\u7684\u6838\u5fc3\uff0c\u4eceZuulProperties<\/code>\u4e2d\u52a0\u8f7d\u4e86\u8def\u7531\u6570\u636e\u3002<\/p>\n
      public class SimpleRouteLocator implements RouteLocator, Ordered {\n    \/\/ routes \u7528\u4e8e\u5b58\u50a8\u8def\u7531\u4fe1\u606f\n    private AtomicReference<Map<String, ZuulRoute>> routes = new AtomicReference<>();\n\n    \/\/ \u67e5\u627e\u8def\u7531\u4fe1\u606f\n    @Override\n    protected Map<String, ZuulRoute> locateRoutes() {\n        LinkedHashMap<String, ZuulRoute> routesMap = new LinkedHashMap<>();\n        \/\/ \u63d0\u53d6ZuulProperties\u4e2d\u7684ZuulRoute\n        for (ZuulRoute route : this.properties.getRoutes().values()) {\n            routesMap.put(route.getPath(), route);\n        }\n        return routesMap;\n    }\n}<\/code><\/pre>\n
      DiscoveryClientRouteLocator<\/h4>\n
      \u5b83\u57fa\u4e8eDiscoveryClient<\/code>\uff0c\u8def\u7531\u6570\u636e\u6765\u81eaproperties<\/code>\u4e2d\u7684\u9759\u6001\u914d\u7f6e\u548cDiscoveryClient<\/code>\u4ece\u6ce8\u518c\u4e2d\u5fc3\u83b7\u53d6\u7684\u6570\u636e\u3002<\/p>\n
      DiscoveryClientRouteLocator<\/code>\u62e5\u6709\u51e0\u4e2a\u91cd\u8981\u7684\u80fd\u529b\uff1a<\/p>\n
        \n
      • \u52a8\u6001\u6dfb\u52a0Route<\/code><\/li>\n
      • \u5237\u65b0\u8def\u7531<\/li>\n
      • \u4eceDiscoveryClient<\/code>\u83b7\u53d6\u8def\u7531\u4fe1\u606f\uff0c\u4f46\u7528\u9014\u4e0d\u5927<\/li>\n<\/ul>\n
        public interface RefreshableRouteLocator extends RouteLocator {\n    void refresh();\n}\n\npublic class DiscoveryClientRouteLocator extends SimpleRouteLocator\n    implements RefreshableRouteLocator {\n\n    \/\/ \u52a8\u6001\u6dfb\u52a0\u8def\u7531\u80fd\u529b,\u4f1a\u540c\u6b65\u628a\u8def\u7531\u4fe1\u606f\u6dfb\u52a0\u5230ZuulProperties,\u53c2\u6570\u4e5f\u53ef\u4ee5\u662fZuulRoute\n    public void addRoute(String path, String location) {\n        this.properties.getRoutes().put(path, new ZuulRoute(path, location));\n        refresh();\n    }\n\n    @Override\n    protected LinkedHashMap<String, ZuulRoute> locateRoutes() {\n    LinkedHashMap<String, ZuulRoute> routesMap = new LinkedHashMap<>();\n    \/\/ \u901a\u8fc7\u7236\u7c7b\u83b7\u53d6\u9759\u6001\u8def\u7531\u4fe1\u606f\n    routesMap.putAll(super.locateRoutes());\n    if (this.discovery != null) {\n      \/\/ \u901a\u8fc7DiscoveryClient\u83b7\u53d6\u8def\u7531\u4fe1\u606f\n      List<String> services = this.discovery.getServices();\n    }\n    return values;\n  }\n\n  \/\/ \u5237\u65b0\u65f6\u4f1a\u8c03\u7528 locateRoutes()\n  @Override\n  public void refresh() {\n    doRefresh();\n  }\n}<\/code><\/pre>\n
        \u4ee5service1\u4e3a\u4f8b\uff0c\u914d\u7f6e\/api\/service1\/** -> service1<\/code>\uff0c\u5b58\u50a8\u7684\u8def\u7531\u4fe1\u606f\u4e3a\uff1a<\/p>\n
        \/api\/service1\/** -> service1\n\/service1\/** -> service1<\/code><\/pre>\n
        \/service1\/** -> service1<\/code>\u5c31\u662f\u5229\u7528DiscoveryClient<\/code>\u63d0\u53d6\u540e\u6839\u636e\u9ed8\u8ba4\u89c4\u5219\u751f\u6210\u7684\u8def\u7531\u4fe1\u606f\uff0c\u7528\u5904\u4e0d\u5927\u3002<\/p>\n
        CompositeRouteLocator<\/h4>\n
        \u5177\u5907\u7ec4\u5408\u591a\u4e2aRouteLocator<\/code>\u7684\u80fd\u529b\uff0c\u7528Collection<\/code>\u5b58\u50a8\u591a\u4e2aRouteLocator<\/code>\uff0c\u8c03\u7528getRoutes()<\/code>\u3001getMatchingRoute()<\/code>\u3001refresh()<\/code>\u65f6\u90fd\u4f1a\u9010\u4e00\u8c03\u7528\u6bcf\u4e2aRouteLocator<\/code>\u76f8\u5e94\u7684\u65b9\u6cd5\u3002<\/p>\n
        public class CompositeRouteLocator implements RefreshableRouteLocator {\n    private final Collection<? extends RouteLocator> routeLocators;\n    private ArrayList<RouteLocator> rl;\n\n    @Override\n    public List<Route> getRoutes() {\n        List<Route> route = new ArrayList<>();\n        for (RouteLocator locator : routeLocators) {\n            route.addAll(locator.getRoutes());\n        }\n        return route;\n    }\n\n    @Override\n    public Route getMatchingRoute(String path) {}\n\n    @Override\n    public void refresh() {}\n}<\/code><\/pre>\n
        \u52a8\u6001\u8def\u7531<\/h2>\n
        \u901a\u8fc7\u4e0a\u9762\u7684\u5185\u5bb9\uff0c\u53ef\u4ee5\u77e5\u9053RouteLocator<\/code>\u7684Routes<\/code>\u6570\u636e\u51e0\u4e2a\u6765\u6e90\uff1a<\/p>\n
          \n
        • \u6765\u6e90\u4e8eZuulProperties<\/code>\uff0c\u5b83\u7531@ConfigurationProperties<\/code>\u6807\u8bb0<\/li>\n<\/ul>\n
          @ConfigurationProperties("zuul")\npublic class ZuulProperties {}<\/code><\/pre>\n
            \n
          • \n
            DiscoveryClientRouteLocator<\/code>\u63d0\u4f9b\u4e86addRoute()<\/code>\u652f\u6301\u52a8\u6001\u6dfb\u52a0\u8def\u7531\uff0c\u4f46\u6ca1\u6709\u5220\u9664\u65b9\u6cd5<\/p>\n<\/li>\n
          • \n
            \u6765\u6e90\u4e8eDiscoveryClient<\/code><\/p>\n<\/li>\n<\/ul>\n
            \u65e0\u8bba\u6765\u6e90\u4e8e\u90a3\u91cc\uff0c\u5728\u66f4\u65b0\u8def\u7531\u4fe1\u606f\u540e\uff0c\u90fd\u9700\u8981\u6267\u884crefresh()<\/code>\u64cd\u4f5c\u624d\u80fd\u628a\u8def\u7531\u4fe1\u606f\u66f4\u65b0\u5230RouteLocator<\/code>\u7684\u79c1\u6709\u5c5e\u6027routes<\/code>\u4e2d\u3002<\/p>\n
            \u5b9e\u9645\u573a\u666f<\/h3>\n
            \u5b9e\u9645\u4f7f\u7528\u4e2d\uff0c\u4f1a\u7edf\u4e00\u7ba1\u7406\u8def\u7531\u4fe1\u606f\uff0c\u5305\u542b\u52a8\u6001\u6dfb\u52a0\u3001\u91cd\u7f6e\u64cd\u4f5c\uff0c\u8def\u7531\u4fe1\u606f\u7684\u53ef\u4ee5\u6765\u81ea\uff1a<\/p>\n
              \n
            • Spring Cloud Config<\/li>\n
            • \u643a\u7a0b\u7684 Apollo<\/li>\n
            • \u963f\u91cc\u7684 Nacos<\/li>\n
            • \u767e\u5ea6\u7684 Disconf<\/li>\n
            • \u81ea\u5b9a\u4e49\u7684\u6570\u636e\u5e93\u6570\u636e<\/li>\n<\/ul>\n
              \u5176\u5b9e\u8def\u7531\u4fe1\u606f\u6765\u81ea\u4e8e\u54ea\u90fd\u53ef\u4ee5\uff0c\u53ea\u662f\u4e00\u4e2a\u6570\u636e\u6e90\u800c\u5df2\uff0c\u6700\u540e\u90fd\u4f1a\u8fdb\u5165ZuulProperties<\/code>\uff0c\u518d\u6267\u884crefresh()<\/code><\/p>\n
              \u5237\u65b0\u8def\u7531\u7684\u65b9\u5f0f<\/h3>\n
              \u6709\u4e24\u79cd\u5237\u65b0\u65b9\u5f0f\u3002<\/p>\n
                \n
              • \u5728\u4efb\u610fBean<\/code>\u4e2d\u6ce8\u5165CompositeRouteLocator<\/code>\u6216\u81ea\u5b9a\u4e49\u7684RouteLocator<\/code>\uff0c\u7136\u540e\u8c03\u7528refresh()<\/code><\/li>\n<\/ul>\n
                @Autowired\nprivate CompositeRouteLocator compositeRouteLocator;<\/code><\/pre>\n
                  \n
                • \u53d1\u5e03RoutesRefreshedEvent<\/code>\u4e8b\u4ef6<\/li>\n<\/ul>\n
                  Zuul<\/code>\u63d0\u4f9b\u4e86ZuulRefreshListener<\/code>\uff0c\u76d1\u542c\u5230RoutesRefreshedEvent<\/code>\u540e\uff0c\u4f1a\u8c03\u7528ZuulHandlerMapping<\/code>\u7684reset()<\/code>\u65b9\u6cd5\uff0c\u8fdb\u800c\u8c03\u7528RouteLocator<\/code>\u7684refresh()<\/code>\u65b9\u6cd5\u3002<\/p>\n
                  private static class ZuulRefreshListener\n    implements ApplicationListener<ApplicationEvent> {\n\n    @Autowired\n    private ZuulHandlerMapping zuulHandlerMapping;\n\n    @Override\n    public void onApplicationEvent(ApplicationEvent event) {\n        if (event instanceof ContextRefreshedEvent\n            || event instanceof RefreshScopeRefreshedEvent\n            || event instanceof RoutesRefreshedEvent\n            || event instanceof InstanceRegisteredEvent) {\n            reset();\n        }\n    }\n\n    private void reset() {\n        this.zuulHandlerMapping.setDirty(true);\n    }\n}\n\n\/\/ setDirty() \u4f1a\u8c03\u7528refresh()\u65b9\u6cd5\npublic class ZuulHandlerMapping extends AbstractUrlHandlerMapping {\n    public void setDirty(boolean dirty) {\n        this.dirty = dirty;\n        if (this.routeLocator instanceof RefreshableRouteLocator) {\n            ((RefreshableRouteLocator) this.routeLocator).refresh();\n        }\n    }\n}<\/code><\/pre>\n
                  \u52a8\u6001\u8def\u7531\u7684\u5b9e\u73b0<\/h3>\n
                  \u81ea\u5b9a\u4e49PropertySource\u5b9e\u73b0<\/h4>\n
                  \n
                  \u601d\u8def\u6765\u81ea\u4e8e Apollo \u7684\u8bbe\u8ba1\u5b9e\u73b0<\/p>\n<\/blockquote>\n
                  PropertySource<\/code>\u4ee3\u8868name\/value<\/code>\u5c5e\u6027\u5bf9\uff0c\u5e38\u89c1\u7684\u5982\u547d\u4ee4\u884c\u53c2\u6570\u3001\u73af\u5883\u53d8\u91cf\u3001properties\u6587\u4ef6\u3001yaml\u6587\u4ef6\u7b49\u6700\u7ec8\u90fd\u4f1a\u8f6c\u4e3aPropertySource<\/code>\uff0c\u518d\u63d0\u4f9b\u7ed9\u5e94\u7528\u4f7f\u7528\u3002<\/p>\n
                  \u7531@ConfigurationProperties<\/code>\u6807\u8bb0\u7684\u7c7b\uff0c\u5176\u6570\u636e\u6e90\u5c31\u662fPropertySource<\/code>\u3002\u5f53\u591a\u4e2aPropertySource<\/code>\u4e2d\u5b58\u5728\u76f8\u540c\u503c\u65f6\uff0c\u9ed8\u8ba4\u4ece\u7b2c\u4e00\u4e2aPropertySource<\/code>\u4e2d\u83b7\u53d6<\/strong>\u3002\u4e0b\u9762\u662fPropertySource<\/code>\u7684\u90e8\u5206\u5e38\u89c1\u5b50\u7c7b\uff1a<\/p>\n
                  \"PropertySource\u5e38\u89c1\u5b50\u7c7b\"<\/p>\n
                  \u5176\u4e2dOriginTrackedMapPropertySource<\/code>\u6765\u81ea\u4e8eclasspath<\/code>\u4e0b\u7684application.yml<\/code>\u6587\u4ef6\u3002<\/p>\n
                  \u5982\u679cPropertySource<\/code>\u6709\u66f4\u65b0\uff0c\u901a\u8fc7\u53d1\u5e03EnvironmentChangeEvent<\/code>\u4e8b\u4ef6\uff0cConfigurationPropertiesRebinder<\/code>\u4f1a\u76d1\u542c\u8be5\u4e8b\u4ef6\uff0c\u7136\u540e\u5229\u7528\u6700\u65b0\u7684\u6570\u636e\u5c06@ConfigurationProperties<\/code>\u6807\u8bb0\u7684Bean<\/code>\u91cd\u65b0\u7ed1\u5b9a\u4e00\u4e0b\uff0c\u4ece\u800c\u8fbe\u5230\u52a8\u6001\u66f4\u65b0\u7684\u6548\u679c\u3002<\/p>\n
                  \u4e0b\u9762\u5199\u4e00\u4e2aDemo\u7c7b\u6765\u5b9e\u73b0\u52a8\u6001\u8def\u7531\uff0c\u652f\u6301\u4ece\u4efb\u610f\u6570\u636e\u6e90\u52a0\u8f7d\u6570\u636e\u6765\u521d\u59cb\u5316\u8def\u7531\uff0c\u7136\u540e\u652f\u6301\u52a8\u6001\u8c03\u6574\u8def\u7531\u3002<\/p>\n
                  @Component\npublic class DynamicRoutesProcessor implements BeanFactoryPostProcessor, EnvironmentAware, ApplicationContextAware, PriorityOrdered {\n\n    private static final String ZUUL_PROPERTY_SOURCE = "custom.zuul.routes";\n    private ConfigurableEnvironment environment;\n    private ApplicationContext applicationContext;\n    private MapPropertySource routePropertySource = null;\n\n    @Autowired\n    private CompositeRouteLocator compositeRouteLocator;\n\n    \/\/ \u521d\u59cb\u5316\u8def\u7531\n    @Override\n    public void postProcessBeanFactory(ConfigurableListableBeanFactory configurableListableBeanFactory) throws BeansException {\n        MutablePropertySources propertySources = environment.getPropertySources();\n\n        \/\/ \u53ef\u4ee5\u4ece\u4efb\u4f55\u5730\u65b9\u52a0\u8f7d\u6570\u636e, \u5982: DB\u3001Redis\u3001\u914d\u7f6e\u4e2d\u5fc3\u7b49, \u4e0b\u9762\u505a\u793a\u4f8b\u6570\u636e\n        Map<String, Object> data = new HashMap<>();\n        data.put("zuul.routes.service4.path", "\/api\/service4\/**");\n        data.put("zuul.routes.service4.serviceId", "service4");\n\n        routePropertySource = new MapPropertySource(ZUUL_PROPERTY_SOURCE, data);\n\n        \/\/ \u8bbe\u7f6e\u6700\u9ad8\u4f18\u5148\u7ea7\n        propertySources.addFirst(routePropertySource);\n    }\n\n    \/\/ \u52a8\u6001\u5237\u65b0\n    @Override\n    public void refreshRoutes(List<ZuulProperties.ZuulRoute> routeList) {\n        \/\/ \u63d0\u53d6 routeList \u6570\u636e\u5e76\u8986\u76d6\u5230 routePropertySource\n\n        \/\/ \u5c06 @ConfigurationProperties \u6807\u8bb0\u7684\u7c7b\u91cd\u65b0\u4e0ePropertySources\u7ed1\u5b9a, \u5305\u542bZuulProperties\n        applicationContext.publishEvent(new EnvironmentChangeEvent(new HashSet<>()));\n\n        \/\/ \u5237\u65b0\u8def\u7531, \u4e5f\u53ef\u4ee5\u76f4\u63a5\u8c03\u7528 compositeRouteLocator.refresh()\n        applicationContext.publishEvent(new RoutesRefreshedEvent(compositeRouteLocator));\n    }\n}<\/code><\/pre>\n
                  \u4e0a\u9762Demo\u7c7b\u7684\u601d\u8def\u662f\uff1a<\/p>\n
                  \u81ea\u5b9a\u4e49PropertySource<\/code>(\u6570\u636e\u6765\u6e90\u53ef\u4ee5\u81ea\u5b9a\u4e49)\u5e76\u63d0\u5347\u4e3a\u6700\u9ad8\u4f18\u5148\u7ea7\uff0cZuulProperties<\/code>\u6570\u636e\u6765\u81ea\u4e8e\u6b64\uff0c\u5b8c\u6210\u8def\u7531\u521d\u59cb\u5316<\/p>\n
                  \u52a8\u6001\u5237\u65b0\u65f6\uff0c\u76f4\u63a5\u66f4\u65b0PropertySource<\/code>\u4e2d\u6570\u636e\uff0c\u7136\u540e\u5229\u7528EnvironmentChangeEvent<\/code>\u6765\u66f4\u65b0ZuulProperties<\/code>\u6570\u636e\uff0c\u518d\u5237\u65b0\u8def\u7531<\/p>\n
                  \u76f4\u63a5\u66f4\u65b0\u8def\u7531<\/h4>\n
                  \u53ef\u4ee5\u76f4\u63a5\u5f80ZuulProperties<\/code>\u4e2d\u6dfb\u52a0\u8def\u7531\u4fe1\u606f\uff0c\u7136\u540e\u4f7f\u7528RouteLocator<\/code>\u8fdb\u884crefresh()<\/code><\/p>\n
                  @Component\npublic class DynamicRoutesProcessor implements InitializingBean {\n\n    @Autowired\n    private CompositeRouteLocator compositeRouteLocator;\n    @Autowired\n    private ZuulProperties zuulProperties;\n\n    \/**\n     * \u52a8\u6001\u5237\u65b0\n     *\n     * @param routeList \u8def\u7531\u4fe1\u606f\n     *\/\n    public void refreshRoutes(List<ZuulProperties.ZuulRoute> routeList) {\n        Map<String, ZuulProperties.ZuulRoute> routes = zuulProperties.getRoutes();\n\n        \/\/ \u63d0\u53d6 routeList \u6570\u636e\u5e76\u6dfb\u52a0\u5230routes\u4e2d\n        for (ZuulProperties.ZuulRoute route : routeList) {\n            routes.put(route.getId(), route);\n        }\n\n        compositeRouteLocator.refresh();\n    }\n\n    \/**\n     * \u521d\u59cb\u5316\u8def\u7531\u4fe1\u606f, \u53ef\u4ee5\u52a0\u8f7d\u4efb\u610f\u6570\u636e\u6e90\n     *\n     * @throws Exception\n     *\/\n    @Override\n    public void afterPropertiesSet() throws Exception {\n        Map<String, ZuulProperties.ZuulRoute> routes = zuulProperties.getRoutes();\n        routes.put("service4", new ZuulProperties.ZuulRoute("\/api\/service4\/**", "service4"));\n        compositeRouteLocator.refresh();\n    }\n}<\/code><\/pre>\n
                  \u81ea\u5b9a\u4e49RouteLocator<\/h4>\n
                  \u4e5f\u53ef\u4ee5\u901a\u8fc7\u81ea\u5b9a\u4e49RouteLocator<\/code>\u6765\u5b9e\u73b0\u52a8\u6001\u8def\u7531\uff0c\u81ea\u5b9a\u4e49\u7684RouteLocator<\/code>\u4f1a\u6dfb\u52a0\u5230CompositeRouteLocator<\/code>\u4e2d\u3002<\/p>\n
                  \u4e0b\u9762\u662f\u4f8b\u5b50\uff0c\u81ea\u884c\u5b9e\u73b0locateRoutes()<\/code>\u5373\u53ef\uff0c\u53ef\u4ee5\u53c2\u8003DiscoveryClientRouteLocator<\/code>\u7684\u5b9e\u73b0\u3002<\/p>\n
                  public class DynamicZuulRouteLocator extends SimpleRouteLocator implements RefreshableRouteLocator {\n\n    private ZuulProperties properties;\n\n    public DynamicZuulRouteLocator(String servletPath, ZuulProperties properties) {\n        super(servletPath, properties);\n        this.properties = properties;\n    }\n\n    @Override\n    public void refresh() {\n        doRefresh();\n    }\n\n    @Override\n    protected Map<String, ZuulProperties.ZuulRoute> locateRoutes() {\n        Map<String, ZuulProperties.ZuulRoute> routesMap = new LinkedHashMap<>();\n\n        \/\/ \u9759\u6001\u8def\u7531\u4fe1\u606f\n        routesMap.putAll(super.locateRoutes());\n\n        \/\/ \u52a8\u6001\u52a0\u8f7d\u8def\u7531\u4fe1\u606f, \u8fd9\u91cchardcode\u505a\u6f14\u793a\n        Map<String, ZuulProperties.ZuulRoute> dynamicRoutes = new LinkedHashMap<>();\n        dynamicRoutes.put("service4", new ZuulProperties.ZuulRoute("service4", "\/api\/service4\/**"));\n        routesMap.putAll(dynamicRoutes);\n\n        Map<String, ZuulProperties.ZuulRoute> values = new LinkedHashMap<>();\n        for (Map.Entry<String, ZuulProperties.ZuulRoute> entry : routesMap.entrySet()) {\n            String path = entry.getKey();\n            if (!path.startsWith("\/")) {\n                path = "\/" + path;\n            }\n            if (StringUtils.hasText(this.properties.getPrefix())) {\n                path = this.properties.getPrefix() + path;\n                if (!path.startsWith("\/")) {\n                    path = "\/" + path;\n                }\n            }\n            values.put(path, entry.getValue());\n        }\n        return values;\n    }\n}<\/code><\/pre>\n
                  \u7136\u540e\u6ce8\u5165\u5230IoC\u5bb9\u5668\u3002<\/p>\n
                  @Bean\npublic DynamicZuulRouteLocator dynamicZuulRouteLocator(ServerProperties serverProperties, ZuulProperties zuulProperties) {\n    return new DynamicZuulRouteLocator(serverProperties.getServlet().getContextPath(), zuulProperties);\n}<\/code><\/pre>\n
                  \u5728ZuulServerAutoConfiguration<\/code>\u6ce8\u5165\u4e86CompositeRouteLocator<\/code>\uff0c\u53c2\u6570\u662fCollection<RouteLocator> routeLocators<\/code>\uff0c\u4f1a\u628a\u5f53\u524dIoC\u5bb9\u5668\u4e2d\u7684RouteLocator<\/code>\u4f5c\u4e3a\u53c2\u6570\uff0c\u76ee\u524d\u5305\u542b\uff1aDynamicZuulRouteLocator<\/code>\u3001DiscoveryClientRouteLocator<\/code>\uff0c\u81ea\u5b9a\u4e49\u7684RouteLocator<\/code><\/p>\n
                  @Bean\n@Primary\npublic CompositeRouteLocator primaryRouteLocator(\n    Collection<RouteLocator> routeLocators) {\n  return new CompositeRouteLocator(routeLocators);\n}<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"
                  \u4ecb\u7ecdZuul\u8def\u7531\u7684\u6e90\u7801\u4ee5\u53ca\u5b9e\u73b0\u52a8\u6001\u8def\u7531\u7684\u51e0\u79cd\u65b9\u5f0f\uff0c\u8def\u7531\u4fe1\u606f\u53ef\u4ee5\u6765\u81eaProperties\u6587\u4ef6\u3001DB\u3001Apollo […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[42],"tags":[250],"class_list":["post-1738","post","type-post","status-publish","format-standard","hentry","category-spring-cloud","tag-zuul"],"_links":{"self":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1738","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/comments?post=1738"}],"version-history":[{"count":0,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/posts\/1738\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/media?parent=1738"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/categories?post=1738"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.appblog.cn\/index.php\/wp-json\/wp\/v2\/tags?post=1738"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}