《RocketMQ 官网》阅读笔记 RocketMQ 核心概念一 参考资料为什么选择 RocketMQ | RocketMQ 消息队列二 笔记总结为什么选择 RocketMQRocketMQ、ActiveMQ 和 Kafka 之间的对比支持哪些语言的客户端使用的是哪种 SDK 协议与规范是否支持顺序消息、定时消息、批量消息、广播消息等核心概念TopicTopic 是 Apache RocketMQ 中的顶级容器用于传输和存储属于同一业务逻辑的消息。MessageTypeApache RocketMQ 支持普通、顺序、事务和延时消息类型。从 5.0 版本开始Apache RocketMQ 支持强制校验消息类型即每个 Topic 只允许发送单一类型的消息。该校验功能默认是开启的。MessageQueueMessageQueue 是 Apache RocketMQ 中用于存储和传输消息的容器。MessageQueue 是 Apache RocketMQ 消息存储的最小单元。Message消息是 Apache RocketMQ 中数据传输的最小单元。生产者将业务数据的载荷和扩展属性封装成消息并发送给 Apache RocketMQ Broker。随后Broker 根据相关的语义将消息投递给消费者。MessageViewMessageView 是从开发视角对消息的只读接口。消息视图允许您读取消息内部的多个属性和载荷信息但您不能对消息本身进行任何更改。MessageTagMessageTag 是一种细粒度的消息分类属性允许在 Topic 级别之下对消息进行细分。消费者通过订阅特定的标签来实现消息过滤。MessageOffset消息在队列中按优先级顺序存储每条消息在队列中都有一个唯一的 Long 类型坐标定义为消息位点。ConsumerOffset消息在被消费者消费后不会立即从队列中删除Apache RocketMQ 会根据每个消费者组记录最后一条被消费的消息位置。MessageKeyMessageKey 是面向消息的索引属性。通过设置消息索引您可以快速找到对应的消息内容。ProducerApache RocketMQ 中的生产者是创建消息并将其发送到服务器的功能性消息实体。生产者通常集成在业务系统中负责将数据封装为 Apache RocketMQ 消息并发送到服务器。TransactionCheckerApache RocketMQ 使用事务消息机制要求生产者实现事务检查器TransactionChecker以确保事务的最终一致性。ConsumerGroup消费者组是一个负载均衡组包含在 Apache RocketMQ 中使用相同消费行为的消费者。Consumer消费者是 Apache RocketMQ 中接收和处理消息的实体。消费者通常集成在业务系统中。它们从 Apache RocketMQ Broker 获取消息并将消息转换为业务逻辑可感知和处理的信息。Subscription订阅是消费者在ApacheRocketMQ 中获取和处理消息的规则和状态设置。订阅由消费者组动态注册到 Broker。随后消息将根据订阅中定义的过滤规则进行匹配和消费。