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的数据存储
namesrv broker路由存储说明:
参见RouteInfoManager类
topicQueueTable:topic及topic实际数据存储的队列信息。
brokerAddrTable:brokerName及实际机器ip地址的信息。
clusterAddrTable:clusterName及相关的brokerName信息。
brokerLiveTable:broker存活信息其中BrokerLiveInfo保存上次心跳时间。
filterServerTable:暂时不知道保存的信息
namesrv的k/v存储
namesrv的k/v存储 k/v存储样例说明:
参见KVConfigSerializeWrapper类
保存一些k/v信息,但是实际信息有什么作用不是特别清楚。
namesrv异常连接检测
连接异常检测说明:
参见BrokerHousekeepingService类
底层借助于epoll的事件通知机制实现
namesrv对外服务
注册中心说明:
参见DefaultRequestProcessor类
通俗讲就提供读写功能,包括broker的注册,取消注册等操作。
namesrv心跳异常检测
心跳异常检测 异常连接清除说明:
参见NettyRemotingServer类
通过心跳时间戳检测异常连接