springCloud项目-分布式项目仓库

package routes; import cn.hutool.json.JSONUtil; import com.alibaba.cloud.nacos.NacosConfigManager; import com.alibaba.nacos.api.config.listener.Listener; import com.alibaba.nacos.api.exception.NacosException; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.cloud.gateway.route.RouteDefinition; import org.springframework.cloud.gateway.route.RouteDefinitionWriter; import org.springframework.stereotype.Component; import reactor.core.publisher.Mono; import javax.annotation.PostConstruct; import java.util.HashSet; import java.util.List; import java.util.Set; import java.util.concurrent.Executor; @Slf4j @Component @RequiredArgsConstructor public class DynamicRouteLoader { //获取congfigservice private final NacosConfigManager nacosConfigManager; //路由跟新工具 private final RouteDefinitionWriter routeDefinitionWriter; //定义一个容器记忆删除的路由 private final Set<String> routesId= new HashSet<>(); private final String dataId="gateway-routes.json"; private final String group ="DEFAULT_GROUP"; @PostConstruct //bean被注入之后就会自动执行这个方法 public void initRouteConfigListener() throws NacosException { //1.项目启动时，会先拉取一次配置，并且添加监听器 String configInfo = nacosConfigManager.getConfigService().getConfigAndSignListener(dataId, group, 5000, new Listener() { @Override public Executor getExecutor() { return null; } @Override public void receiveConfigInfo(String s) { //监听到配置变更后，需要更新路由表 updateConfigInfo(s); } });//获取配置并添加监听器 //2.将第一次拉取到的配置更新到路由表上 updateConfigInfo(configInfo); } //定义一个更新路由表的方法 public void updateConfigInfo(String configInfo){ log.debug("监听到路由配置信息：{}",configInfo); //解析configInfo，转成routedefinition文件 List<RouteDefinition> routeDefinitions = JSONUtil.toList(configInfo, RouteDefinition.class); //先删除旧的全部的路由表 for (String s : routesId) { routeDefinitionWriter.delete(Mono.just(s)).subscribe(); } routesId.clear(); //跟新路由表 for (RouteDefinition routeDefinition : routeDefinitions) { //使用工具来进行更新,mono是一个容器，封装一个数据 routeDefinitionWriter.save(Mono.just(routeDefinition)).subscribe(); //记录路由id，便于下一次更新时删除 routesId.add(routeDefinition.getId()); } } }