概念
本节介绍 Apache RocketMQ 的核心概念。
主题
主题是 Apache RocketMQ 中用于传输和存储属于相同业务逻辑消息的顶层容器。了解更多 主题。
消息类型
根据消息传输特性定义的类别,用于类型管理和安全验证。Apache RocketMQ 支持普通(NORMAL)、顺序(FIFO)、事务(TRANSACTION)和延时(DELAY)消息类型。
从 5.0 版本开始,Apache RocketMQ 支持强制验证消息类型,即每个主题只允许发送单一类型的消息。这有助于更好地促进生产系统的操作和管理,并避免混淆。然而,为了确保与 4.x 版本的向后兼容性,该验证功能默认是启用的。
消息队列
消息队列是 Apache RocketMQ 中用于存储和传输消息的容器。消息队列是 Apache RocketMQ 消息的最小存储单元。了解更多 消息队列。
消息
消息是 Apache RocketMQ 中最小的数据传输单元。生产者将业务数据的负载和扩展属性封装到消息中,并将消息发送到 Apache RocketMQ 的 Broker。然后,Broker 根据相关语义将消息传递给消费者。了解更多消息。
消息视图
消息视图是从开发角度看消息的只读接口。消息视图允许您读取消息中的多个属性和负载信息,但不能对消息本身进行任何更改。
消息标签
消息标签是一种细粒度的消息分类属性,允许在主题级别以下对消息进行细分。消费者通过订阅特定的标签来实现消息过滤。了解更多 消息过滤。
消息偏移量
消息在队列中按优先级顺序存储,每条消息在队列中都有一个唯一的 Long 类型坐标,定义为消息位置。了解更多 消费者进度管理。
消费者偏移量
消息不会在被消费者消费后立即从队列中移除,Apache RocketMQ 会根据每个消费者组记录最后消费的消息。了解更多 消费者进度管理。
消息键
消息键是面向消息的索引属性。通过设置消息索引,您可以快速找到相应的消息内容。
生产者
Apache RocketMQ 中的生产者是创建消息并将其发送到服务器的功能性消息实体。生产者通常集成在业务系统中,用于将数据封装为 Apache RocketMQ 中的消息并发送到服务器。了解更多 生产者。
事务检查器
Apache RocketMQ 使用事务消息机制,这要求生产者实现事务检查器以确保事务的最终一致性。了解更多事务消息。
消费者组
消费者组是一个负载均衡组,其中包含在 Apache RocketMQ 中使用相同消费行为的消费者。了解更多 消费者组。
消费者
消费者是 Apache RocketMQ 中接收和处理消息的实体。消费者通常集成在业务系统中。他们从 Apache RocketMQ 的 Broker 获取消息,并将消息转换为业务逻辑可以感知和处理的信息。了解更多 消费者。
订阅
订阅是消费者在 Apache RocketMQ 中获取和处理消息的规则和状态设置。订阅由消费者组动态注册到 Broker。然后,消息根据订阅定义的过滤规则进行匹配和消费。了解更多 订阅。