RocketMQ入门篇-Rocket超详细讲解

￡神魔★判官ぃ 2023-02-21 11:46 27阅读 0赞

> 微信公众号：**Java患者**
> 
> **专注Java领域技术分享**  
>

### 什么是RocketMQ？ ###

![format_png][]

*  一个队列模型的消息中间件，具有高性能、高可靠、高实时、分布式的特点。
 *  Producer向一些队列轮流发送消息，队列集合称为一个Topic，Consumer从队列中进行消费，如果Consumer做广播消费，则一个Consumer实例消费这个Topic对应的所有队列，Consumer如果做集群消费，则多个实例平均消费这个Topic对应的队列集合。
 *  保证严格的消息顺序，QUEUE队列的数据结构，先进先出
 *  提供丰富的消息拉取模式
 *  高效的订阅者水平拓展能力
 *  消息订阅机制实时
 *  亿计消息堆积能力

### 物理部署结构 ###

![物理结构][format_png 1] 物理结构

**NameSrv**：一个几乎无状态节点的注册中心，比zookeeper更轻量级，更好用，可集群部署，节点之间无任务信息同步，负责维护Producer和Consumer的配置信息、状态信息，并且协调各个角色的协同执行。

**Broker**: 消息中转对象，负责存储消息、转发消息，一般也称为Server。在JMS规范中称Provider。Broker分为Master与Slave,一个Master可以对应多个Slave，一个Slave之恩呢对应一个Master。每个Broker与Namesrv集群中所有节点建立长连接，定时注册Topic信息到所有NameSrv。

**Producer**: 与Namesrv集群中的一个节点建立长连接，定期从Namesrv取Topic路由信息，并向提供Topic服务的Master建立长连接，且定时向Master发送心跳。

**Consumer**: 与Namesrv集群中的其中一个节点建立长连接，定期从Namesrv取Topic路由信息，并向提供Topic服务，并向提供Topic服务的Master、Slave建立长连接，且定时向Master、Slave发送心跳。Consumer可以从Master订阅消息，也可以从Slave订阅消息，订阅规则由Broker配置决定。

往期精彩

[RocketMQ入门篇-三分钟入门RocketMQ][RocketMQ_-_RocketMQ]

[RocketMQ入门篇-安装][RocketMQ_-]

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxNzRWeFdOTmlhbmZhTEhvMTI4Y2RWQkR5MGJPUDFwSFhNNzJ6bjRvMUxCUkd2cWljRXFYUWJwMldockkzRlc5eDlMcm9pY0dpYXhOVW53Q1EvNjQw?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxNzRWeFdOTmlhbmZhTEhvMTI4Y2RWQkRod3NoQWljN2pxQ2g0ZVVEV0ZSRkhwemR3OGZvS0hMN3VjZ09tRFhXS045aWN2NjI3VjJodFUxZy82NDA?x-oss-process=image/format,png
[RocketMQ_-_RocketMQ]: http://mp.weixin.qq.com/s?__biz=MzI1NzU3ODAwMg%3D%3D&chksm=ea1406aedd638fb8fcd52b28aad7f50cf9b1c94e36d158bf26c9ccb008e2118389a1658fd570&idx=1&mid=2247484371&scene=21&sn=101d05df070fb3b12295607e8a8184c1#wechat_redirect
[RocketMQ_-]: http://mp.weixin.qq.com/s?__biz=MzI1NzU3ODAwMg%3D%3D&chksm=ea1406aedd638fb8680dab14bef9ed6bd7902e7d06bdf156ccfb8f33df4ae7ac2a6c89b299ce&idx=2&mid=2247484371&scene=21&sn=e8223b2541aff44932ec553e78dcd451#wechat_redirect