rocketMq-namesrv介绍

作者: 晴天哥_王志 | 来源:发表于2018-03-18 23:38 被阅读73次

    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类

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

    相关文章

      网友评论

        本文标题:rocketMq-namesrv介绍

        本文链接:https://www.haomeiwen.com/subject/lqpyqftx.html