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