使用Nacos实现Spring Cloud Zuul的动态路由

  <dependency>
    <groupId>com.alibaba.nacos</groupId>
    <artifactId>nacos-client</artifactId>
    <version>0.4.0</version>
  </dependency>

@Component
public class PropertiesAssemble{

  public Map<String, ZuulRoute> getProperties() {
    Map<String, ZuulRoute> routes = new LinkedHashMap<>();
    List<ZuulRouteEntity> results = listenerNacos("zuul-server","zuul_route");
    for (ZuulRouteEntity result : results) {
      if (StringUtils.isBlank(result.getPath())
          /*|| org.apache.commons.lang3.StringUtils.isBlank(result.getUrl())*/) {
        continue;
      }
      ZuulRoute zuulRoute = new ZuulRoute();
      try {
        BeanUtils.copyProperties(result, zuulRoute);
      } catch (Exception e) {
      }
      routes.put(zuulRoute.getPath(), zuulRoute);
    }
    return routes;
  }

  private List<ZuulRouteEntity> listenerNacos (String dataId, String group) {
    try {
      Properties properties = new Properties();
      properties.put(PropertyKeyConst.SERVER_ADDR, "localhost:8848");
      ConfigService configService = NacosFactory.createConfigService(properties);
      String content = configService.getConfig(dataId, group, 5000);
      System.out.println("从Nacos返回的配置：" + content);
      //注册Nacos配置更新监听器，用于监听触发
//            configService.addListener(dataId, group, new Listener()  {
//                @Override
//                public void receiveConfigInfo(String configInfo) {
//                    System.out.println("Nacos更新了！");
//
//                }
//                @Override
//                public Executor getExecutor() {
//                    return null;
//                }
//            });
      return JSONObject.parseArray(content, ZuulRouteEntity.class);
    } catch (NacosException e) {
      e.printStackTrace();
    }
    return new ArrayList<>();
  }
}