天天看点

rocketMq-namesrv介绍

namesrv的作用

    namesrv的定位是作为注册中心,保存broker节点的路由信息,保存一些简单的k/v信息。

    namesrv支持集群模式,但是每个namesrv之间相互独立不进行任何通信,它的多点容灾通过producer/consumer在访问namesrv的时候轮询获取信息(当前节点访问失败就转向下一个)。

    namesrv作为注册中心,负责接收broker定期的注册信息并维持在内存当中,没错namesrv是没有持久化功能的,所有数据都保存在内存当中,broker的注册过程也是循环遍历所有namesrv进行注册。

    namesrv通过提供对外接口给producer和consumer访问broker的路由信息,底层通过netty来实现。

    namesrv对broker的存活检测机制:心跳机制即namesrv作为broker的server端定期接收broker的心跳信息,超时无心跳就移除broker;连接异常检测机制即底层通过epoll的消息机制来检测连接的断开。

namesrv的数据存储

rocketMq-namesrv介绍

namesrv broker路由存储

说明:

    参见RouteInfoManager类

    topicQueueTable:topic及topic实际数据存储的队列信息。

    brokerAddrTable:brokerName及实际机器ip地址的信息。

    clusterAddrTable:clusterName及相关的brokerName信息。

    brokerLiveTable:broker存活信息其中BrokerLiveInfo保存上次心跳时间。

    filterServerTable:暂时不知道保存的信息

namesrv的k/v存储

rocketMq-namesrv介绍
rocketMq-namesrv介绍

k/v存储样例

    参见KVConfigSerializeWrapper类

    保存一些k/v信息,但是实际信息有什么作用不是特别清楚。

namesrv异常连接检测

rocketMq-namesrv介绍

连接异常检测

    参见BrokerHousekeepingService类

    底层借助于epoll的事件通知机制实现

namesrv对外服务

rocketMq-namesrv介绍

注册中心

    参见DefaultRequestProcessor类

    通俗讲就提供读写功能,包括broker的注册,取消注册等操作。

namesrv心跳异常检测

rocketMq-namesrv介绍

心跳异常检测

rocketMq-namesrv介绍

异常连接清除

    参见NettyRemotingServer类

    通过心跳时间戳检测异常连接