SpringCloud系列教程（十二）：网关配置动态路由

除了token以外，还有一个很实用的功能就是把网关的路由配置放到nacos上，并且修改路由配置的时候，网关服务可以动态的更新，这样我们在调整网络配置的时候，就不用重启服务了。所以我们需要用到两个重要的类：NacosConfigManager和RouteDefinitionWriter，NacosConfigManager用来监听nacos上配置的变化，RouteDefinitionWriter会执行路由配置。

1、将原来写在application.yml中的路由配置信息迁移到nacos上，dataId定义为gateway-routes，这里要注意，原来在项目中yml文件解析的时候，会被SpringCloud层层解析后生成RouteDefinition，在这期间SpringCloud会去解析比如Path=/api/*这种形式，但是现在我们要自己解析，就要改成符合RouteDefinition的完全形式，这是一个小难点。

spring:cloud:gateway:routes:- id: nacos-client-demouri: lb://nacos-client-demopredicates: #断言，匹配访问的路径- name: Pathargs:pattern: /nacos-client-demo/api/**filters: # 过滤器- name: AddRequestHeaderargs:_genkey_0: headername_genkey_1: I am a header!- name: Myargs:_genkey_0: zhangsan_genkey_1: lisi_genkey_2: wangwu- id: open-feign-demouri: lb://open-feign-demopredicates:- name: Pathargs:pattern: /open-feign-demo/api/**

2、在application.yml中添加nacos的配置信息就可以了，并且我特意添加了两个参数，用来指明动态路由配置的dataId，这样以后改成其他的也方便。

spring:main:# gateway组件中的spring-boot-starter-webflux和springboot作为web项目启动必不可少的spring-boot-starter-web出现冲突web-application-type: reactiveapplication:name: gateway-democloud:gateway:nacos-data-id: gateway-routesnacos-group: devopsnacos:server-addr: 192.168.3.54:80username: nacospassword: nacosdiscovery:group: devopsnamespace: sitconfig:namespace: sitgroup: devopsconfig:import: nacos:${spring.application.name}?refresh=true
server:port: 8888

3、定义一个component类DynamicRouterLoader，继承ApplicationEventPublisherAware，网上很多教程没有继承，因为版本不同，我用新版的发现必须要用ApplicationEventPublisherAware发布一下才能让路由信息生效。

package com.mj.gateway.router;import cn.hutool.core.lang.Dict;
import cn.hutool.json.JSONUtil;
import cn.hutool.setting.yaml.YamlUtil;
import com.alibaba.cloud.nacos.NacosConfigManager;
import com.alibaba.fastjson2.JSONObject;
import com.alibaba.nacos.api.config.listener.Listener;
import com.alibaba.nacos.api.exception.NacosException;
import jakarta.annotation.PostConstruct;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.gateway.event.RefreshRoutesEvent;
import org.springframework.cloud.gateway.route.RouteDefinition;
import org.springframework.cloud.gateway.route.RouteDefinitionWriter;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationEventPublisherAware;
import org.springframework.stereotype.Component;
import reactor.core.publisher.Mono;import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.InputStreamReader;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.concurrent.Executor;@Slf4j
@Component
@RequiredArgsConstructor
public class DynamicRouterLoader implements ApplicationEventPublisherAware {//nacos配置管理器private final NacosConfigManager nacosConfigManager;//gateway路由规则写入器private final RouteDefinitionWriter writer;private ApplicationEventPublisher publisher;@Value("${spring.cloud.gateway.nacos-data-id:test}")private String dataId;@Value("${spring.cloud.gateway.nacos-group:test}")private String group;private final int timeout = 5000;//保存所有的路由idprivate final Set<String> routeIds = new HashSet<>();//PostConstruct表示实例化之后就会执行@PostConstructpublic void initRouteConfigListener() throws NacosException {//获取配置，服务启动的时候就要加载一次配置String config = nacosConfigManager.getConfigService().getConfigAndSignListener(dataId, group, timeout, new Listener() {@Overridepublic Executor getExecutor() {return null;}@Overridepublic void receiveConfigInfo(String config) {//配置变化时，重新加载配置updateConfig(config);}});//服务启动，加载配置updateConfig(config);}private void updateConfig(String config) {log.info("更新路由信息");//读取nacos中yaml配置Dict dict = YamlUtil.load(new BufferedReader(new InputStreamReader(new ByteArrayInputStream(config.getBytes()))));//转换成Route对象List<RouteDefinition> routeDefinitions = JSONObject.parseObject(JSONUtil.toJsonStr(dict)).getJSONObject("spring").getJSONObject("cloud").getJSONObject("gateway").getJSONArray("routes").toList(RouteDefinition.class);//清理旧的路由规则routeIds.forEach(routeId -> writer.delete(Mono.just(routeId)).subscribe());//清空缓存routeIds.clear();// 遍历添加路由routeDefinitions.forEach(definition -> {//提交路由信息writer.save(Mono.just(definition)).subscribe();//缓存下记录，这样便于清除路由配置routeIds.add(definition.getId());});this.publisher.publishEvent(new RefreshRoutesEvent(this));}@Overridepublic void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) {this.publisher = applicationEventPublisher;}
}

DynamicRouterLoader在服务启动的时候就会实例化并且注入spring中，所以我们给方法initRouteConfigListener添加注解@PostConstruct，这样实例化一完成就会执行该方法。方法里使用NacosConfigManager获取到nacos的数据并做一次更新路由，这次更新是用来启动服务时初始化路由配置，再添加一个监听器，每次nacos修改都会触发这个监听器再次更新路由配置。更新路由其实有两个思路，思路1是能准确判断每次修改、删除的路由信息，然后分别执行update和delete，这就需要我们去做新旧版本配置的区分工作了，工作量比较大，思路2就是每次都清空所有路由，然后把最新版配置信息加载进去。思路2更简单一点，不过我没有测试过路由信息特别大的情况下会不会导致延迟，通常我们的微服务不至于多到会产生延迟，但是这里依旧要警惕，工作中如果发现数量真的很大了，就要多做一些压力测试。

4、重启服务，做测试：http://127.0.0.1:8888/nacos-client-demo/api/login?userid=123&username=zhangsan

这时候是正常的：