随着业务和架构的发展，微服务的开发部署方式已经变成了如今技术发展的趋势，而在微服务流量入口控制上基本都是通过网关来实现的。网关的作用：路由转发、熔断、限流、安全认证、日志监控等，在前面也发布过一篇关于从零开始搭建微服务之网关建设的文章，大家感兴趣的话可以去了解下网关的基本介绍。

背景

目前我们的服务流量入口已统一由网关进行转发，路由信息定义在配置文件中，但是这种方式有一个缺点就是修改路由信息必须重启服务才能生效。网关作为支付全部流量的入口，需要保证其高可用，所以需要做到不重启服务而修改路由信息，现结合Nacos去实现配置动态路由，同时需要转发服务统一注册到Nacos注册中心，网关直接在注册中心中选择机器进行转发。下面介绍具体改造的代码。

网关接入Nacos动态刷新网关路由配置表

如果要实现动态路由配置，主要需要做到2点，

1. Nacos能够监听到客户端前台配置文件的修改；
2. 将修改的配置文件变更新到网关路由中；

针对以上2点，我们需要通过代码来监听Nacos配置文件修改变化，同时利用Spring事件发布将配置文件变更信息动态刷新到路由配置表中，核心代码如下：

@Component @Slf4j public class NacosDynamicRouteService implements ApplicationEventPublisherAware {       @Value("${spring.cloud.nacos.config.server-addr}")     private String serverAddr;       @Value("${nacos.group}")     private String group;       @Value("${nacos.dataId}")     private String routeConfigDataId;       @Value("${nacos.namespace}")     private String namespace;       @Resource     private RouteDefinitionWriter routeDefinitionWriter;       private ApplicationEventPublisher applicationEventPublisher;       private static final List<String> ROUTE_LIST = new ArrayList<>();       @Override     public void setApplicationEventPublisher(@NotNull ApplicationEventPublisher applicationEventPublisher) {         this.applicationEventPublisher = applicationEventPublisher;     }       @PostConstruct     public void dynamicRouteListener() {         try {             Properties properties = new Properties();             properties.put("serverAddr", serverAddr);             properties.put("namespace", namespace);             ConfigService configService = NacosFactory.createConfigService(properties);               // 程序首次启动, 并加载初始化路由配置             String initConfigInfo = configService.getConfig(routeConfigDataId, group, 5000);             addAndPublishBatchRoute(initConfigInfo);               configService.addListener(routeConfigDataId, group, new Listener() {                 @Override                 public void receiveConfigInfo(String configInfo) {                     addAndPublishBatchRoute(configInfo);                 }                   @Override                 public Executor getExecutor() {                     return null;                 }             });         } catch (Exception e) {             e.printStackTrace();         }     }       /**      * 批量 添加及发布 路由      * @param configInfo 配置文件字符串, 必须为json array格式      */     private void addAndPublishBatchRoute(String configInfo) {         try {             clearRoute();             List<RouteDefinition> gatewayRouteDefinitions = JSONObject.parseArray(configInfo, RouteDefinition.class);             for (RouteDefinition routeDefinition : gatewayRouteDefinitions) {                 addRoute(routeDefinition);             }             publish();             log.info(">>>>>>>>>>>>>>>>>Nacos Dynamic config gateway route finished | {}", JSON.toJSONString(gatewayRouteDefinitions));         } catch (Exception e) {             e.printStackTrace();         }     }       /**      * 清空所有路由      */     private void clearRoute() {         for(String id : ROUTE_LIST) {             this.routeDefinitionWriter.delete(Mono.just(id)).subscribe();         }         ROUTE_LIST.clear();     }       /**      * 添加单条路由信息      * @param definition RouteDefinition      */     private void addRoute(RouteDefinition definition) {         routeDefinitionWriter.save(Mono.just(definition)).subscribe();         ROUTE_LIST.add(definition.getId());     }       /**      * 发布路由表变更事件      */     private void publish() {         this.applicationEventPublisher.publishEvent(new RefreshRoutesEvent(this.routeDefinitionWriter));     } } 

配置文件yml

nacos:     group: DEFAULT_GROUP     dataId: gateway-outer-nacos-beta     namespace: beta

Nacos控制台配置路由信息

路由转发JSON