跳至主要内容
版本: 5.0

概念

本节介绍 Apache RocketMQ 的核心概念。

主题

主题是 Apache RocketMQ 中用于传输和存储属于同一业务逻辑的消息的顶级容器。了解更多 主题

消息类型

由消息传输特性定义的类别,用于类型管理和安全验证。Apache RocketMQ 支持 NORMAL、FIFO、TRANSACTION 和 DELAY 消息类型。

信息

从 5.0 版本开始,Apache RocketMQ 支持强制执行消息类型的验证,即每个主题只允许发送单一类型的消息。这可以更好地促进生产系统的操作和管理,避免混淆。但是,为了确保与 4.x 版本的向后兼容性,验证功能默认情况下是启用的。

消息队列

消息队列是 Apache RocketMQ 中用于存储和传输消息的容器。消息队列是 Apache RocketMQ 消息存储的最小单位。了解更多 消息队列

消息

消息是 Apache RocketMQ 中数据传输的最小单位。生产者将业务数据的负载和扩展属性封装成消息,并将其发送到 Apache RocketMQ 代理。然后,代理根据相关的语义将消息传递给消费者。了解更多消息

消息视图

消息视图是从开发角度来看消息的只读接口。消息视图允许您读取消息内部的多个属性和有效负载信息,但您无法对消息本身进行任何更改。

消息标签

消息标签是细粒度的消息分类属性,允许消息在主题级别以下进行细分。消费者通过订阅特定标签来实现消息过滤。了解更多 消息过滤器

消息偏移量

消息按优先级顺序存储在队列中,每条消息在队列中都有一个唯一的类型为 Long 的坐标,定义为消息位置。了解更多 消费者进度管理

消费者偏移量

消息不会在被消费者消费后立即从队列中删除,Apache RocketMQ 会根据每个消费者组记录最后消费的消息。了解更多 消费者进度管理

消息键

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

生产者

Apache RocketMQ 中的生产者是一个功能性消息实体,它创建消息并将其发送到服务器。生产者通常集成在业务系统中,用于将数据封装为 Apache RocketMQ 中的消息,并将消息发送到服务器。了解更多 生产者

事务检查器

Apache RocketMQ 使用事务消息机制,要求生产者实现事务检查器,以确保事务的最终一致性。了解更多事务消息

消费者组

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

消费者

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

订阅

订阅是消费者在 Apache RocketMQ 中获取和处理消息的规则和状态设置。订阅由消费者组动态注册到代理。然后,根据订阅定义的过滤器规则匹配和消费消息。了解更多 订阅