RocketMQ基本概念

RocketMQ 基本概念 Apache RocketMQ 是一个分布式消息队列系统，具有高性能、高可用和可扩展的特点。本文将对 RocketMQ 的基本概念进行介绍，以便读者更好地理解和使用 RocketMQ。 主题（Topic） 主题是 Apache RocketMQ 中消息传输和存储的顶层容器，用于标识同一类业务逻辑的消息。主题通过 TopicName 来做唯一标识和区分。每个主题可以包含多个队列，实现队列数量的水平拆分和队列内部的流式存储。 消息类型（MessageType） 消息类型是 Apache RocketMQ 中按照消息传输特性的不同而定义的分类，用于类型管理和安全校验。Apache RocketMQ 支持的消息类型有普通消息、顺序消息、事务消息和定时/延时消息。从 5.0 版本开始，支持强制校验消息类型，即每个主题Topic 只允许发送一种消息类型的消息，这样可以更好的运维和管理生产系统，避免混乱。 消息队列（MessageQueue） 消息队列是 Apache RocketMQ 中消息存储和传输的实际容器，也是消息的最小存储单元。所有主题都是由多个队列组成，以此实现队列数量的水平拆分和队列内部的流式存储。队列通过 QueueId 来做唯一标识和区分。 消息（Message） 消息是 Apache RocketMQ 中的最小数据传输单元。生产者将业务数据的负载和拓展属性包装成消息发送到服务端，服务端按照相关语义将消息投递到消费端进行消费。 消息视图（MessageView） 消息视图是 Apache RocketMQ 面向开发视角提供的一种消息只读接口。通过消息视图可以读取消息内部的多个属性和负载信息，但是不能对消息本身做任何修改。 消息标签（MessageTag） 消息标签是 Apache RocketMQ 提供的细粒度消息分类属性，可以在主题层级之下做消息类型的细分。消费者通过订阅特定的标签来实现细粒度过滤。 消息位点（MessageQueueOffset） 消息位点是 Apache RocketMQ 中消息在队列中的唯一坐标，用于标识消息在队列中的位置。 消费位点（ConsumerOffset） 消费位点是 Apache RocketMQ 中记录消费者消费过的最新一条消息的位点，用于记录消费者的消费进度。 消息索引（MessageKey） 消息索引是 Apache RocketMQ 提供的面向消息的索引属性。通过设置的消息索引可以快速查找到对应的消息内容。 生产者（Producer） 生产者是 Apache RocketMQ 系统中用来构建并传输消息到服务端的运行实体。生产者通常被集成在业务系统中，将业务消息按照要求封装成消息并发送至服务端。 事务检查器（TransactionChecker） 事务检查器是 Apache RocketMQ 中生产者用来执行本地事务检查和异常事务恢复的监听器。事务检查器应该通过业务侧数据的状态来检查和判断事务消息的状态。 事务状态（TransactionResolution） 事务状态是 Apache RocketMQ 中事务消息发送过程中，事务提交的状态标识，服务端通过事务状态控制事务消息是否应该提交和投递。 消费者分组（ConsumerGroup） 消费者分组是 Apache RocketMQ 系统中承载多个消费行为一致的消费者的负载均衡分组。在 Apache RocketMQ 中，通过消费者分组内初始化多个消费者实现消费性能的水平扩展以及高可用容灾。 消费者（Consumer） 消费者是 Apache RocketMQ 中用来接收并处理消息的运行实体。消费者通常被集成在业务系统中，从服务端获取消息，并将消息转化成业务可理解的信息，供业务逻辑处理。 消费结果（ConsumeResult） 消费结果是 Apache RocketMQ 中 PushConsumer 消费监听器处理消息完成后返回的处理结果，用来标识本次消息是否正确处理。 订阅关系（Subscription） 订阅关系是 Apache RocketMQ 系统中消费者获取消息、处理消息的规则和状态配置。订阅关系由消费者分组动态注册到服务端系统，并在后续的消息传输中按照订阅关系定义的过滤规则进行消息匹配和消费进度维护。 本文对 RocketMQ 的基本概念进行了详细的介绍，包括主题、消息类型、消息队列、消息、消息视图、消息标签、消息位点、消费位点、消息索引、生产者、事务检查器、事务状态、消费者分组、消费者、消费结果和订阅关系等概念的解释和说明。