Spring Cloud Gateway的动态路由怎样做?集成Nacos实现很简单

一、说明

网关的核心概念就是路由配置和路由规则,而作为所有请求流量的入口,在实际生产环境中为了保证高可靠和高可用,是尽量要避免重启的,所以实现动态路由是非常有必要的;本文主要介绍 Spring Cloud Gateway 实现的思路,并且以Nacos为数据源来讲解

PS:关于 Spring Cloud Zuul 的动态路由请看文章《Spring Cloud Zuul的动态路由怎样做?集成Nacos实现很简单》

 

二、实现要点

要实现动态路由只需关注下面4个点

    网关启动时,动态路由的数据怎样加载进来
    静态路由动态路由以那个为准,ps:静态路由指的是配置文件里写死的路由配置
    监听动态路由的数据源变化
    数据有变化时怎样通知gateway刷新路由

 

三、具体实现

Spring Cloud Gateway 中加载路由信息分别由以下几个类负责

    PropertiesRouteDefinitionLocator:从配置文件中读取路由信息(如YML、Properties等)
    RouteDefinitionRepository:从存储器中读取路由信息(如内存、配置中心、Redis、MySQL等)
    DiscoveryClientRouteDefinitionLocator:从注册中心中读取路由信息(如Nacos、Eurka、Zookeeper等)

 

我们可以通过自定义 RouteDefinitionRepository 的实现类来实现动态路由的目的

 

3.1. 实现动态路由的数据加载

创建一个NacosRouteDefinitionRepository实现类

NacosRouteDefinitionRepository类可查看:NacosRouteDefinitionRepository.java

重写 getRouteDefinitions 方法实现路由信息的读取

 

配置Nacos监听器,监听路由配置信息的变化

路由变化只需要往 ApplicationEventPublisher 推送一个 RefreshRoutesEvent 事件即刻,gateway会自动监听该事件并调用 getRouteDefinitions 方法更新路由信息

 

3.2. 创建配置类

DynamicRouteConfig类可查看:DynamicRouteConfig.java

 

3.3. 添加Nacos路由配置

新增配置项:

Data Id:scg-routes
Group:SCG_GATEWAY
配置内容:

[
{
"id": "csdn",
"predicates": [{
"name": "Path",
"args": {
"pattern": "/csdn/**"
}
}],
"uri": "https://www.csdn.net/",
"filters": []
},
{
"id": "github",
"predicates": [{
"name": "Path",
"args": {
"pattern": "/github/**"
}
}],
"uri": "http://github.com/",
"filters": []
}
]

添加两条路由数据

 

四、测试

启动网关通过 /actuator/gateway/routes 端点查看当前路由信息

可以看到 Nacos 里配置的两条路由信息

 

完整的Spring Cloud Gateway代码请查看

https://gitee.com/zlt2000/microservices-platform/tree/master/zlt-gateway/sc-gateway

 

推荐阅读

日志排查问题困难?分布式日志链路跟踪来帮你
zuul集成Sentinel最新的网关流控组件
Spring Cloud Zuul的动态路由怎样做?集成Nacos实现很简单
Spring Cloud开发人员如何解决服务冲突和实例乱窜?
Spring Cloud同步场景分布式事务怎样做?试试Seata
Spring Cloud异步场景分布式事务怎样做?试试RocketMQ

 

扫码关注有惊喜!

Spring Cloud Gateway的动态路由怎样做?集成Nacos实现很简单的相关教程结束。

相关推荐:

如何根据前一个连续段的值动态修改数值序列

本文介绍如何在pandas中识别数值连续段(streak),并基于前一段的值条件性地修改当前段——例如,将紧随“1”段之后的所有“2”段统一替换为1。 本文介绍如何在pandas中识别数值连续段(streak),并基于前一段的值条件性地修改当前段——例如,将紧随“1”段之后的所有“2”段统一替换为1...

如何在Python Flask中实现数据库的动态查询与组合筛选?

正确路径是利用SQLAlchemy的Query对象链式调用动态添加filter()等子句,且须经字段白名单校验与类型转换,否则引发InvalidRequestError或SQL注入。 Flask中用SQLAlchemy构建动态查询的底层逻辑 直接拼接SQL字符串或用eval()解析前端传参是危险且不...

如何在Python中实现基于异步IO的轻量级动态代理?

asyncio+aiohttp不能直接做动态代理,因其是应用层HTTP客户端,无法透传TLS握手、丢弃原始请求头、不支持CONNECT方法,必须用asyncio.open_connection实现TCP层字节级双向桥接。 为什么asyncio+aiohttp不能直接做动态代理 直接用aiohttp....