《RocketMQ 官网》阅读笔记 RocketMQ 消息队列 MessageQueue 消息 Messagege消息队列 (Message Queue)定义队列是 Apache RocketMQ 中用于存储和传输消息的容器。队列是 Apache RocketMQ 消息存储的最小单位。Apache RocketMQ 中的一个主题由多个队列组成。队列具有以下优势有序存储队列天生具有顺序性消息按入队顺序存储。最早的消息位于队列起始位置最新的消息位于队尾。通过偏移量Offset来标记队列中消息的位置和顺序。流式操作语义Apache RocketMQ 的基于队列的存储允许消费者从特定偏移量读取一条或多条消息。这有助于实现聚合读取和回溯读取等功能。这些功能在 RabbitMQ 或 ActiveMQ 中是不具备的。模型关系默认情况下Apache RocketMQ 提供可靠的消息存储。所有成功发送的消息都会持久化存储在队列中。消息由生产者发送由消费者客户端接收。每条消息均可保证至少被成功投递一次。Apache RocketMQ 的队列模型类似于 Kafka 的分区模型。在 Apache RocketMQ 中队列是主题的一部分。尽管消息由主题管理但操作是在队列级别进行的。例如当生产者向特定主题发送消息时消息会被发送到该主题下的一个队列中。您可以通过调整 Apache RocketMQ 中的队列数量来进行扩容或缩容。内部属性读写权限定义决定当前队列是否可以进行读写操作。取值由 Broker 定义。枚举值说明如下6读写。当前队列既可以写入消息也可以读取消息。4只读。当前队列可以读取消息但不能写入消息。2只写。当前队列可以写入消息但不能读取消息。0读写不可用。当前队列不允许任何读写操作。约束读写权限与运维操作相关。建议不要频繁修改权限。行为约束每个主题包含一个或多个用于存储消息的队列。每个主题的队列数量与消息类型及实例所在的地域有关。队列数量不可随意更改。版本兼容性队列名称因 Apache RocketMQ Broker 的版本而异。差异如下Broker 3.x 和 4.x 版本队列名称由主题名称、Broker ID 和队列 ID 组成并绑定到物理节点。Broker 5.x 版本队列名称是一个由集群分配的全局唯一字符串与物理节点解耦。建议不要手动构建队列名称或将其绑定到其他操作中否则在 Broker 更新时这些队列名称可能无法解析。使用说明队列数量设置您可以在创建或修改主题时指定 Apache RocketMQ 中的队列数量。建议配置较少的队列避免添加不必要的队列。主题中包含过多队列会导致以下问题集群元 数据量增加Apache RocketMQ 基于队列采集指标和监控数据。过多的队列可能导致元数据量剧增。客户端负载过高Apache RocketMQ 的消息读写基于队列执行。大量的队列可能会产生空轮询请求从而增加系统负载。扩容队列的场景物理节点负载均衡Apache RocketMQ 中每个主题的队列可以分布在不同的服务节点上。为确保集群扩容后的流量负载均衡建议增加队列或将之前的队列迁移到新的服务节点上。与 FIFO顺序消息相关的性能瓶颈在 Apache RocketMQ Broker 4.x 版本中FIFO 消息仅在队列级别生效。因此FIFO 消息的并发性取决于队列数量。当系统出现性能瓶颈时建议增加队列数量。消息 (Message)定义消息是 Apache RocketMQ 中数据传输的最小单元。生产者将业务数据封装成消息并将消息发送到 Apache RocketMQ Broker。随后Broker 会根据相关语义将消息分发给 费者。Apache RocketMQ 中消息模型的特征为不可变性消息一旦产生即成为一个事件。在消息生成后其内容不会发生改变。即使消息经过传输通道其内容也保持不变。消费者获取的消息均为只读消息。持久性默认情况下Apache RocketMQ 会对消息进行持久化处理。接收到的消息存储在 Apache RocketMQ Broker 的存储文件中以确保在系统故障时可以对消息进行追踪和恢复。模型关系消息类型普通消息普通消息。普通消息不需要特殊语义且与其他普通消息不相关联。FIFO 消息顺序消息。Apache RocketMQ 使用消息组来确定一组特定消息的顺序。消息将按照发送顺序进行投递。延迟消息延迟消息。您可以指定延迟时间使消息在延迟时间过后才对消费者可见而不是在生产时立即投递。事务消息事务消息。Apache RocketMQ 支持分布式事务消息确保 数据库更新和消息调用之间的事务一致性。消息队列消息所属的队列。由 Broker 指定并填充。消息位点 (Message Offset)当前消息在队列中的存储位置。由 Broker 指定并填充。有效值0 到 Long.Max。消息 ID消息的唯一标识符。每条消息的 ID 在集群中全局唯一。由生产者客户端自动生成。消息 ID 是一个由 32 个字符组成的字符串包含数字和大写字母。消息 Key可选消息的索引键列表。您可以配置不同的 Key 来区分消息并快速查找消息。由生产者客户端定义。消息 Tag可选用于过滤消息的标签。 消费者可以通过标签过滤消息仅接收包含指定标签的消息。由生产者客户端定义。每条消息只能指定一个标签。定时时间可选在定时场景中消息触发延迟投递时所使用的毫秒级时间戳。由消息生产者定义。最长持续时间为 40 天。消息发送时间消息发送时生产者客户端的本地毫秒级时间戳。客户端时间可能与 Broker 时间不同。在这种情况下消息发送时间以客户端时间为准。消息存储时间消息存储时Apache RocketMQ Broker 的本地毫秒级时间戳。对于延迟消息和事务消息消息保留时间是指消息生效时展示给消费者的 Broker 时间。客户端时间可能与 Broker 时间不同。在这种情况下消息保留时间以 Broker 时间为准。重试次数消息消费失败后Apache RocketMQ Broker 重新投递消息的次数。每次重试后最大重试次数加一。由 Broker 标记。第一次消费消息时重试次数为零。第一次消费失败时重试次数为一。消息的自定义属性自定义属性生产者可以指定的扩展信息。由生产者基于字符串键值对进行指定。消息负载 (Message Payload)业务消息的实际数据。由生产者序列化并以二进制字节流进行传输。行为约束消息大小不能超过上限。如果消息大小超过相应的上限消息将发送失败。默认限制最大消息大小4 MB。使用说明不建议单条消息进行超大负载传输。Apache RocketMQ 是一种用于传输业务事件数据的消息中间件。如果消息过大网络传输层可能会过载。这会影响错误重试和限流机制。建议限制单条消息事件的数据大小。如果生产环境确实需要传输大数据建议根据固定大小对消息进行拆分或采用文件存储方式。消息的不可变性在 Apache RocketMQ Broker 5.x 版本中消息无法被修改 消费者获取的消息均为只读消息。3.x 和 4.x 版本未实施有关不可变性的强制约束。建议若需传输消息请重新初始化消息。正确示例MessagemConsumer.receive();Messagem2MessageBuilder.buildFrom(m);Producer.send(m2);错误示例MessagemConsumer.receive();m.update()Producer.send(m);