Namesrv路由原理
Namesrv获取的Topic路由信息来自Broker定时心跳,心跳时Broker将Topic信息和其他信息发送到Namesrv。
Namesrv通过RequestCode.REGISTER_BROKER接口将心跳中的Broker信息和Topic信息存储在Namesrv中
路由注册
registerBrokerWithFilterServer()方法中的this.namesrvController.getRouteInfoManager.registerBroker()方法,该方法的主要功能是将request解码为路由对象,保存在Namesrv中。在路由信息注册完成后,Broker会每隔30s发送一个注册请求给集群中全部的Namesrv,俗称心跳信,会把最新的Topic路由信息注册到Namesrv中
路由剔除
如果Broker长久没有心跳或者宕机,那么Namesrv会将这些不提供服务的Broker剔除,同时生产者和消费者与Namesrv心跳后也会感知被踢掉的Broker,如此Broker扩容或者宕机对生产、消费无感知的情况就处理完了。
Namesrv有两种剔除Broker的方式
- 第一种:Broker主动关闭时,会调用Namesrv的取消注册Broker的接口RequestCode=RequestCode.UNREGISTER_BROKER,将自身从集群中删除
- 第二种:Namesrv通过定时扫描已经下线的Broker,将其主动剔除,实现过程在NamesrvController.initialize()方法中,
这里定时执行scanNotActiveVroker(),该方法会扫描全部已经注册的Broker,依次将每一个Broker心跳的最后更新时间和当前时间做对比,如果Broker心跳的最后更新时间超过BROKER_CHANNEL_EXPIRED_TIME(1000 * 60 * 2= 120s)则将Broker剔除,从此没有心跳的Broker从路由中被剔除,而客户端无任何感知