• Zuul配置
• 在mysql中创建路由信息表，对于类如下：
• 定义CustomRouteLocator类
• 增加CustomZuulConfig类，主要是为了配置CustomRouteLocator
• RefreshRouteService类，用于实现数据库路由信息的刷新
• 当然也要提供RefreshController，提供从浏览器访问的刷新功能
• 问题
• 后记

上一篇初步记录了Spring Cloud GateWay动态路由配置，这一篇说一下Zuul的动态路由配置。Zuul 是 Netflix 开源的微服务网关，Spring Cloud 对 Zuul 进行了整合和增强。在 SpringCloud 体系中，Zuul 担任着网关的角色，对发送到服务端的请求进行一些预处理，比如安全验证、动态路由、负载分配等。还是那句话，由于水平有限，难免有不当或者错误之处，请大家指正，谢谢。

Zuul配置

一般的，我们如果使用Spring Cloud Zuul 进行路由配置，类似于下面的样子:

zuul:
 routes:
 users:
 path: /myusers/**
 stripPrefix: false

当我们要新增或者改变一个网关路由时，我们不得不停止网关服务，修改配置文件，保存再重新启动网关服务，这样才能让我们新的设置生效。设想一样，如果是在生产环境，为了一个小小的路由变更，这样的停止再重启恐怕谁也受不了吧。接下来，看看我们怎么能做到动态配置网关路由，让网关路由配置在服务不需要重启的情况生效。（废话一堆啊）

在mysql中创建路由信息表，对于类如下：

定义CustomRouteLocator类

CustomRouteLocator集成SimpleRouteLocator,实现了RefreshableRouteLocator接口

主要的是locateRoutes和locateRoutesFromDB这两个函数，locateRoutes是从SimpleRouteLocatorOverride过来的，先装载配置文件里面的路由信息，在从数据库里面获取路由信息，最后都是保存在SimpleRoteLocator 的AtomicReference<Map<String, ZuulRoute>> routes属性中，注意routes是类型，它是可以保证线程俺去的。

增加CustomZuulConfig类，主要是为了配置CustomRouteLocator

CustomerRouteLocator 去数据库获取路由配置信息，需要一个JdbcTemplate Bean。this.zuulProperties就是配置文件里面的路由配置，应该是网关服务启动时自动就获取过来的。

RefreshRouteService类，用于实现数据库路由信息的刷新

当然也要提供RefreshController，提供从浏览器访问的刷新功能

上面两个实现的功能是，在数据库里面新增或者修改路由信息，通过上面的功能进行刷新。

问题

网关服务跑起来了，也能实现正常的路由功能。但是，等等，查看日志，发现每隔30秒，服务自动从数据库再次加载路由配置，这是为什么呢？

这个问题在于ZuulRefreshListener 这个类，这个类j实现了ApplicationListener 接口，监听系统的Event，然后进行刷新。

让我们来更改这个类的代码：

private static class ZuulRefreshListener implements ApplicationListener<ApplicationEvent> {
 @Autowired
 private ZuulHandlerMapping zuulHandlerMapping;
 private HeartbeatMonitor heartbeatMonitor;
 
 private ZuulRefreshListener() {
 this.heartbeatMonitor = new HeartbeatMonitor();
 }
 
 @Override
 public void onApplicationEvent(ApplicationEvent event) {
 if (!(event instanceof ContextRefreshedEvent) && !(event instanceof RefreshScopeRefreshedEvent) && !(event instanceof RoutesRefreshedEvent) && !(event instanceof InstanceRegisteredEvent)) {
 if (event instanceof ParentHeartbeatEvent) {
 ParentHeartbeatEvent e = (ParentHeartbeatEvent)event;
 this.resetIfNeeded(e.getValue());
 
 } else if (event instanceof HeartbeatEvent) {
 HeartbeatEvent e = (HeartbeatEvent)event;
 this.resetIfNeeded(e.getValue());
 
 }
 } else {
 /**
 * 原来代码
 * this.reset();
 */
 if ((event instanceof ContextRefreshedEvent) || (event instanceof RefreshScopeRefreshedEvent) || (event instanceof RoutesRefreshedEvent)) {
 
 if (event instanceof ContextRefreshedEvent) {
 ContextRefreshedEvent contextRefreshedEvent = (ContextRefreshedEvent) event;
 ApplicationContext context = contextRefreshedEvent.getApplicationContext();
 
 String eventClassName = context.getClass().getName();
 
 /**
 * 为了服务启动只执行一次从数据库里面获取路由信息，这儿进行判断
 */
 if (eventClassName.equals("org.springframework.context.annotation.AnnotationConfigApplicationContext")) {
 this.reset();
 }
 } else {
 this.reset();
 }
 }
 }
 
 }
 
 private void resetIfNeeded(Object value) {
 /**
 * 发送监控心态信息接收到注册服务中心的数据后，只更新心态的相关信息，不再从新load整个路由
 * 原来是从新load路由信息，可以把新注册的服务都动态load进来。
 * 现在要求新的服务的路由在数据库里面配置。
 *
 * 否则的话每30秒发送心态检测，就会更新一次路由信息，没有必要
 *
 */
 if (!this.heartbeatMonitor.update(value)) {
 return;
 }
 /* 原来代码
 if (this.heartbeatMonitor.update(value)) {
 this.reset();
 }*/
 
 }

为什么会30秒一次频繁的获取路由配置，上面的注释已经说的很清楚了。

测试，一切顺利！

后记

写博客很累，主要是没有经验，又担心有的地方理解错误，误导大家。出现问题，有的时候需要去从源码哪里找到答案。幸好我的博客只记录我的心得，没有任何其他的目的，聊以自慰吧。