1.上篇 对网关动态路由配置做了简单的分享，本篇将对动态路由进行更深层的实现，实现思路如下：
- 1.创建一个路由信息维护的项目（dynamic-route），实现增删改查路由信息到mysql
- 2.提供发布功能，发布后将路由信息与版本信息保存到redis中，对外提供 rest 接口获取路由信息
- 3.网关（gateway-dynamic-route）开启定时任务，定时拉取 rest 接口中发布的最新版的路由信息，对比版本号，如果网关的版本号与rest接口中的不一致，则获取路由信息后更新网关路由，这样网关发布多个实例后，都会单独的去拉取维护的路由信息
- 4.整体架构设计如下：
根据上面的思路进行代码实现，下面将创建2个项目，都要注册到eureka上
- dynamic-route，路由管理，维护路由信息，并存储到mysql与redis中
- gateway-dynamic-route，网关，通过rest接口定时拉取最新路由信息并更新到网关中
- consumer-service，消费者服务，测试动态路由配置后将请求转发到此服务
2.创建一个路由信息维护的项目 dynamic-route，实现对路由信息的增删改查和发布功能，信息保存到mysql中，发布后保存到redis，对外提供路由数据时返回redis中的路由信息（使用缓存来应对网关定时任务读请求）
- 有2张表，路由信息表与版本发布表，表结构如下：
- 增删改查的实现因篇幅原因就不一一展开了，可查看项目代码，已上传到码云，下面贴出项目的几个页面，页面比较简单
下面是提供的 rest 接口返回版本信息与路由信息，网关先获取版本号，与本地版本号对比，如不一致则通过此接口拉取路由信息
获取维护的路由信息
3.重点是网关项目，创建 gateway-dynamic-route 项目，网关启动时设置默认的版本号为0，通过定时任务每60秒拉取一次远程路由项目提供最新版本号，与网关的版本号对比，如不一致，则拉取远程路由项目最新的路由信息，更新到网关路由上去，同时把本地版本号覆盖为最新的版本号
因代码较多，博客主要分享实现思路和贴出关键代码，已提交至码云，可下载项目查看全部代码
- 1.启动定时任务，注册到erueka，添加RestTemplate Bean且以负载均衡形式访问路由项目
@EnableScheduling
@EnableDiscoveryClient
@SpringBootApplication
public class GatewayDynamicRouteApplication {
public static void main(String[] args) {
SpringApplication.run(GatewayDynamicRouteApplication.class, args);
}
@Bean
@LoadBalanced
public RestTemplate restTemplate(){
return new RestTemplate();
}
}- 2.定时任务实现类
/**
* 定时任务，拉取路由信息
* 路由信息由路由项目单独维护
*/
@Component
public class DynamicRouteScheduling {
@Autowired private RestTemplate restTemplate;
@Autowired private DynamicRouteService dynamicRouteService;//动态路由实现类，与前篇博客中的实现类代码是一样的
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
private static final String dynamicRouteServerName = "dynamic-route-service";
//发布路由信息的版本号
private static Long versionId = 0L;
//每60秒中执行一次
//如果版本号不相等则获取最新路由信息并更新网关路由
@Scheduled(cron = "*/60 * * * * ?")
public void getDynamicRouteInfo(){
try{
System.out.println("拉取时间:" + dateFormat.format(new Date()));
//先拉取版本信息，如果版本号不想等则更新路由
Long resultVersionId = restTemplate.getForObject("http://"+ dynamicRouteServerName +"/version/lastVersion" , Long.class);
System.out.println("路由版本信息：本地版本号：" + versionId + "，远程版本号：" + resultVersionId);
if(resultVersionId != null && versionId != resultVersionId){
System.out.println("开始拉取路由信息......");
String resultRoutes = restTemplate.getForObject("http://"+ dynamicRouteServerName +"/gateway-routes/routes" , String.class);
System.out.println("路由信息为：" + resultRoutes);
if(!StringUtils.isEmpty(resultRoutes)){
List<GatewayRouteDefinition> list = JSON.parseArray(resultRoutes , GatewayRouteDefinition.class);
for(GatewayRouteDefinition definition : list){
//更新路由
RouteDefinition routeDefinition = assembleRouteDefinition(definition);
dynamicRouteService.update(routeDefinition);
}
versionId = resultVersionId;
}
}
}catch (Exception e){
e.printStackTrace();
}
}
//把前端传递的参数转换成路由对象
private RouteDefinition assembleRouteDefinition(GatewayRouteDefinition gwdefinition) {
RouteDefinition definition = new RouteDefinition();
definition.setId(gwdefinition.getId());
definition.setOrder(gwdefinition.getOrder());
//设置断言
List<PredicateDefinition> pdList=new ArrayList<>();
List<GatewayPredicateDefinition> gatewayPredicateDefinitionList=gwdefinition.getPredicates();
for (GatewayPredicateDefinition gpDefinition: gatewayPredicateDefinitionList) {
PredicateDefinition predicate = new PredicateDefinition();
predicate.setArgs(gpDefinition.getArgs());
predicate.setName(gpDefinition.getName());
pdList.add(predicate);
}
definition.setPredicates(pdList);
//设置过滤器
List<FilterDefinition> filters = new ArrayList();
List<GatewayFilterDefinition> gatewayFilters = gwdefinition.getFilters();
for(GatewayFilterDefinition filterDefinition : gatewayFilters){
FilterDefinition filter = new FilterDefinition();
filter.setName(filterDefinition.getName());
filter.setArgs(filterDefinition.getArgs());
filters.add(filter);
}
definition.setFilters(filters);
URI uri = null;
if(gwdefinition.getUri().startsWith("http")){
uri = UriComponentsBuilder.fromHttpUrl(gwdefinition.getUri()).build().toUri();
}else{
uri = URI.create(gwdefinition.getUri());
}
definition.setUri(uri);
return definition;
}
}- 3.网关提供获取所有路由信息的Controller
/**
* 查询网关的路由信息
*/
@RestController
@RequestMapping("/route")
public class DynamicRouteController {
@Autowired private RouteDefinitionLocator routeDefinitionLocator;
//获取网关所有的路由信息
@RequestMapping("/routes")
public Flux<RouteDefinition> getRouteDefinitions(){
return routeDefinitionLocator.getRouteDefinitions();
}
}-
4.启动eureka、dynamic-route、gateway-dynamic-route、consumer-service
-
5.通过 dynamic-route 项目新增一条路由信息，路由的 uri 是consumer-service，且发布路由
发布路由时，会将版本表最新的版本号与路由信息添加到redis中，下图是redis中保存的路由信息，网关定时获取版本信息与路由信息都是先从redis中取出来的
-
6.因网关没有配置路由信息，可通过 localhost:9999/route/routes 获取所有路由信息，此时有两条路由信息，是网关从eureka上拉下来的默认的路由信息，不是配置的路由信息
-
7.等待60秒后，网关通过 RestTemplate 拉取dynamic-route项目的最新版本号，发现不一致，则拉取最新路由信息，并更新到网关路由中
-
8.通过网关访问 consumer-service，验证路由信息是否已更新到网关中，访问：http://localhost:9999/zy/hello?name=zy
-
9.再次查看所有路由信息，可看到consumer-service已被设置到网关路由中了
-
10.每隔60秒再次对比版本号，当有新的版本号发布后，就会拉取维护的路由信息，没有则网关不会更新路由
-
11.修改一下路由信息，把断言Path=/zy/** ， 改为Path=/consumer/** ，并发布，隔了60秒后，网关的控制台拉取到最新的路由信息
此时访问 http://localhost:9999/zy/hello?name=zy 报错，因为路由断言path被更改了路由不到
需要通过 http://localhost:9999/consumer/hello?name=zy 访问，正常返回
好了，动态路由的进阶实现已完成了，因篇幅原因没有全部贴出所有代码，博客主要介绍动态路由的实现思路，代码可根据自己的习惯进行实现
代码已上传至码云：
- eureka-server
- dynamic-route，design中有建表sql
- gateway-dynamic-route
- consumer-service
项目版本信息如下：
- SpringBoot 2.0.6.RELEASE - SpringCloud Finchley.SR2
转自：https://blog.csdn.net/zhuyu19911016520/article/details/86562615?utm_medium=distribute.pc_relevant.none-task-blog-baidujs_baidulandingword-3&spm=1001.2101.3001.4242