SpringCloud-Gateway 动态路由之 Nacos,BATJ 等企业 Java 面试知识分享
当我们的网关 Gateway 程序开发完成之后,需要部署到生产环境,这个时候你的程序不能是单点运行的,肯定是多节点启动(独立部署或者 docker 等容器部署),防止单节点故障导致整个服务不能访问,网关是对客户端的入口与出口,在生产运行中极为重要,哪怕是简单的重启也会导致部分请求的丢失。
网关的路由配置这个时候就是一个大问题,是代码里面编写还是配置文件配置?他们都有一个致命的缺点,当有新的程序需要接入到网关进行路由或者有服务需要下线时候需要修改代码或者配置,然后重启整个网关程序,导致其他正常的服务路由受到了影响。
所以在实际生产环境中为了保证高可靠和高可用,是尽量要避免重启网关,所以实现动态路由是非常有必要的;
本文主要介绍 Spring Cloud Gateway 实现的思路,并且把路由信息存放在外部源中,这里以 Nacos 为数据源来讲解。
实现要点
要实现动态路由只需关注下面 4 个点
网关启动时,动态路由的数据怎样加载进来
静态路由与动态路由以那个为准
监听动态路由的数据源变化
数据有变化时怎样通知 gateway 刷新路由
ps:静态路由指的是配置文件里写死的路由配置
具体实现
Spring Cloud Gateway 中加载路由信息分别由以下几个类负责:
PropertiesRouteDefinitionLocator:从配置文件中读取路由信息(如 YML、Properties 等)
RouteDefinitionRepository:从存储器中读取路由信息(如内存、配置中心、Redis、MySQL 等)
DiscoveryClientRouteDefinitionLocator:从注册中心中读取路由信息(如 Nacos、Eurka、Zookeeper 等)
我们可以通过自定义 RouteDefinitionRepository 的实现类来实现
动态路由的目的。
实现动态路
有的数据加载我们可以查看源码 RouteDefinitionRepository 的存储的实现类,只有 InMemoryRouteDefinitionRepository,此实现类是存放在内存中的。
我们可以重新定义一个 nacos 作为存储的实现,看下面的代码
上面代码核心的是重写 getRouteDefinitions 方法实现路由信息的读取;这个方法中涉及到了 ConfigService 对象 Api 的方法。
管理 Api 方法,这个老顾这里不详细说了;小伙伴们可以理解为就是操作 nacos config 的对象
配置 Nacos 监听器,监听路由配置信息的变化,也是利用 api 方法,也就是 addListener 方法;此方法一看就知道,就是用来监听 config 信息变化的。
此 addListener 方法中路由变化只需要往 ApplicationEventPublisher 推送一个 RefreshRoutesEvent 事件,即刻 gateway 会自动监听该事件并调用 getRouteDefinitions 方法更新路由信息。
这样就达到了动态更新路由了。
配置类
为了更好的把此动态路由作为公共 core,我们需要利用配置类,达到是否启用的方式;可以让开发者自行配置。
上面的配置类,有两个重要的**@ConditionalOnProperty,这个就是用来控制是否启用动态路由,以及是否用 nacos 作为存储。**
里面还有 @Value 注解定义我们存储路由信息的 DataId 和 Group,application.yml 如果不配置默认值为 scg-routes 和 SCG_GATEWAY
添加 Nacos 路由配置
在同一个 namespace 中创建 scg-routes 和 SCG_GATEWAY
格式选择 json,json 体里面的格式其实就是 RouteDefinition 类的属性
注意上面的配置的 json 是数组格式哦,也就是可以有很多路由哦
[{"id": "baidu","order": 0,"predicates": [{"args": {"pattern": "/baidu/"}, "name": "Path"}], "uri": "https://www.baidu.com"},{ "id": "sina","order": 2,"predicates": [{"args": {"pattern": "/sina/"}, "name": "Path"}], "uri": "http://www.sina.com.cn"}]
评论