rocketMq-namesrv介绍

简介: namesrv的作用    namesrv的定位是作为注册中心,保存broker节点的路由信息,保存一些简单的k/v信息。    namesrv支持集群模式,但是每个namesrv之间相互独立不进行任何通信,它的多点容灾通过producer/consumer在访问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的数据存储

img_b8c85e0ae8f525a7b5a544cad07d9404.png
namesrv broker路由存储

说明:

    参见RouteInfoManager类

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

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

    clusterAddrTable:clusterName及相关的brokerName信息。

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

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


namesrv的k/v存储

img_7cdfbc4ae71e8d3e837269b946c60075.png
namesrv的k/v存储
img_1fd9c0144b9876fe8e221a40ec457c11.png
k/v存储样例

说明:

    参见KVConfigSerializeWrapper类

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


namesrv异常连接检测

img_c0f141d086d249bea05e63dc76408d0f.png
连接异常检测

说明:

    参见BrokerHousekeepingService类

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


namesrv对外服务

img_c0c546bec5fd221b09e969fc3d4f51db.png
注册中心

说明:

    参见DefaultRequestProcessor类

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


namesrv心跳异常检测

img_bc792fa78ccec5b314d05c25342b0f18.png
心跳异常检测


img_555ac85fc211563e1dbdb909f42972c1.png
异常连接清除

说明:

    参见NettyRemotingServer类

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

相关实践学习
RocketMQ一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
目录
相关文章
|
2月前
|
消息中间件 监控 API
RocketMQ 5.0
RocketMQ 5.0 是一款分布式消息中间件,由阿里巴巴开源,提供了高性能、高可靠、高可扩展性的消息传递服务。它采用发布/订阅模式,支持多种消息协议,如 JMS、MQTT 等,可用于构建企业级应用的异步消息处理、系统解耦、流量削峰等场景。
60 4
|
9天前
|
消息中间件 存储 Cloud Native
RocketMQ的初步认识
RocketMQ的初步认识
23 0
|
4月前
|
消息中间件 监控 RocketMQ
RocketMQ
RocketMQ是一个开源的分布式消息中间件,由阿里巴巴集团开发和维护。
60 1
|
4月前
|
消息中间件 存储 负载均衡
RocketMQ
RocketMQ
45 0
|
5月前
|
消息中间件 存储 JSON
RocketMQ使用总结
RocketMQ使用总结
118 0
|
10月前
|
消息中间件 存储 运维
RocketMq
RocketMq
98 0
|
消息中间件 存储 缓存
RocketMQ参数约束和建议
Apache RocketMQ 系统中存在很多自定义参数和资源命名,您在使用 Apache RocketMQ 时建议参考如下说明规范系统设置,避对某些具体参数设置不合理导致应用出现异常。
171 0
|
消息中间件 Kafka Linux
RocketMQ常备知识汇总
RocketMQ常备知识汇总
179 0
|
消息中间件 监控 Java
RocketMq介绍
RocketMq介绍
216 0
|
消息中间件 Java 中间件
rocketmq整合SpringCloudStream
rocketmq整合SpringCloudStream
441 0