《RocketMQ 官网》阅读笔记 RocketMQ 核心概念

一 参考资料

为什么选择 RocketMQ | RocketMQ 消息队列

二 笔记总结

为什么选择 RocketMQ

RocketMQ、ActiveMQ 和 Kafka 之间的对比：

• 支持哪些语言的客户端
• 使用的是哪种 SDK 协议与规范
• 是否支持顺序消息、定时消息、批量消息、广播消息等

核心概念

Topic

Topic 是 Apache RocketMQ 中的顶级容器，用于传输和存储属于同一业务逻辑的消息。

MessageType

Apache RocketMQ 支持普通、顺序、事务和延时消息类型。

从 5.0 版本开始，Apache RocketMQ 支持强制校验消息类型，即每个 Topic 只允许发送单一类型的消息。该校验功能默认是开启的。

MessageQueue

MessageQueue 是 Apache RocketMQ 中用于存储和传输消息的容器。MessageQueue 是 Apache RocketMQ 消息存储的最小单元。

Message

消息是 Apache RocketMQ 中数据传输的最小单元。生产者将业务数据的载荷和扩展属性封装成消息，并发送给 Apache RocketMQ Broker。随后，Broker 根据相关的语义将消息投递给消费者。

MessageView

MessageView 是从开发视角对消息的只读接口。消息视图允许您读取消息内部的多个属性和载荷信息，但您不能对消息本身进行任何更改。

MessageTag

MessageTag 是一种细粒度的消息分类属性，允许在 Topic 级别之下对消息进行细分。消费者通过订阅特定的标签来实现消息过滤。

MessageOffset

消息在队列中按优先级顺序存储，每条消息在队列中都有一个唯一的 Long 类型坐标，定义为消息位点。

ConsumerOffset

消息在被消费者消费后不会立即从队列中删除，Apache RocketMQ 会根据每个消费者组记录最后一条被消费的消息位置。

MessageKey

MessageKey 是面向消息的索引属性。通过设置消息索引，您可以快速找到对应的消息内容。

Producer

Apache RocketMQ 中的生产者是创建消息并将其发送到服务器的功能性消息实体。生产者通常集成在业务系统中，负责将数据封装为 Apache RocketMQ 消息并发送到服务器。

TransactionChecker

Apache RocketMQ 使用事务消息机制，要求生产者实现事务检查器（TransactionChecker）以确保事务的最终一致性。

ConsumerGroup

消费者组是一个负载均衡组，包含在 Apache RocketMQ 中使用相同消费行为的消费者。

Consumer

消费者是 Apache RocketMQ 中接收和处理消息的实体。消费者通常集成在业务系统中。它们从 Apache RocketMQ Broker 获取消息，并将消息转换为业务逻辑可感知和处理的信息。

Subscription

订阅是消费者在ApacheRocketMQ 中获取和处理消息的规则和状态设置。订阅由消费者组动态注册到 Broker。随后，消息将根据订阅中定义的过滤规则进行匹配和消费。