三分钟白话 RocketMQ 系列—— 核心概念

RocketMQ 是一个开源的分布式消息中间件。它是一种 低延迟、高可用、高可靠、高并发 的消息队列系统，用于在分布式系统中进行异步通信。

白话 3 分钟，快速了解 RocketMQ 基础，包括适用场景，以及基本概念。

看完如果不了解，欢迎来打我。

关键字摘要

• 低延迟、高可用、高可靠、高并发 的消息中间件

• 适合在线业务

• 分为 producer、consumer、nameserver、broker 等角色

• 另外还有主题（Topic）、队列（MessageQueue）、消息（Message）、消费者组（ConsumerGroup）、订阅关系（Subscription）等核心概念

Q1：RocketMQ 是什么？

RocketMQ 是一个开源的分布式消息中间件。它是一种 低延迟、高可用、高可靠、高并发 的消息队列系统，用于在分布式系统中进行异步通信。

Q2: 作为消息中间件，RocketMQ 和 kafka 有什么区别？

作为消息中间件，RocketMQ 和 kafka 的「消息模型」上比较相似，都有生产、存储（消息堆积）、消费三大部分。主要区别还是使用场景。

RocketMQ 比 kafka 多了一些业务特性，比如 定时消息、延迟消息、事务消息（RocketMQ 和 kafka 的不是同一个概念）、广播消息、消息轨迹 等，所以我们一般把 RocketMQ 用在在线业务场景中。而 kafka 由于大数据生态完善，在系统间的数据流管道、实时数据处理等场景中依旧占据优势。

当然，RocketMQ 5.x 版本进一步强化了自身在 事件、流处理 场景上的结合。不过目前观察，主要还是阿里云自身在做相关生态建设和应用，业界落地上还不算主流。

Q3: RocketMQ 的基本架构是怎样的？

图片

RocketMQ 4.x 版本中，主要分为 4 个角色：

• producer：发布消息的角色。Producer 通过负载均衡模块选择相应的 Broker 集群队列进行消息投递。

• consumer：消息消费的角色。提供实时订阅消息的能力。

• broker：Broker 主要负责消息的存储、投递和查询以及服务高可用保证。

• nameserver：NameServer 是一个简单的 Topic 路由注册中心。支持 Topic、Broker 的动态注册与发现。

RocketMQ 5.x 为了更好适应云原生环境下的「存算分离」，在部署架构上做了一个变化。

新增无状态的代理模块 Proxy，作为「计算层」，将 Broker 原来的协议适配、权限管理、消息管理等计算功能抽离到了代理模块中。而 Broker 则专注于「存储层」，主要负责消息存储功能。

这样在云环境下可以更好地进行资源调度。

图片

Q4：RocketMQ 有哪些核心概念？

图片

RocketMQ 核心概念

前面提到过，消息中间件的逻辑架构上比较相似，都有消息 生产、存储（消息堆积）、消费 三大部分。

就 RocketMQ 而言，核心概念也是围绕这三个部分展开，7 个核心概念：

• 消息生产：

• 生产者（Producer）：RocketMQ 中用于产生消息的实体。

• 消息存储

• 主题（Topic）：RocketMQ 消息传输和存储的分组容器，主题内部由多个队列（MessageQueue）组成。

• 队列（MessageQueue）：RocketMQ 消息传输和存储的实际单元容器，类比于 kafka 中的分区。

• 消息（Message）：RocketMQ 的最小传输单元。在初始化发送和完成存储后即不可变。

• 消息消费

• 消费者分组（ConsumerGroup）：RocketMQ 发布订阅模型中定义的独立的消费身份分组，用于统一管理底层运行的多个消费者（Consumer）。

• 消费者（Consumer）：RocketMQ 消费消息的运行实体。消费者必须被指定到某一个消费组中。

• 订阅关系（Subscription）：RocketMQ 发布订阅模型中消息过滤、重试、消费进度的 持久化「规则配置」。消费组通过定义订阅关系控制指定消费组下的消费者如何实现消息过滤、消费重试及消费进度恢复等。

总结

• 低延迟、高可用、高可靠、高并发的消息中间件。

• 适合在线业务。

• 分为 producer、consumer、nameserver、broker 等角色。

• 另外还有主题（Topic）、队列（MessageQueue）、消息（Message）、消费者组（ConsumerGroup）、订阅关系（Subscription）等核心概念。