本文主要对云消息队列 RocketMQ 版涉及的专有名词及术语进行定义和解析,方便您更好地理解相关概念并使用云消息队列 RocketMQ 版

Topic
消息主题,一级消息类型,通过Topic对消息进行分类。更多信息,请参见Topic与Tag最佳实践
消息(Message)
消息队列中信息传递的载体。
Message ID
消息的全局唯一标识,由云消息队列 RocketMQ 版系统自动生成,唯一标识某条消息。
Message Key
消息的业务标识,由消息生产者(Producer)设置,唯一标识某个业务逻辑。
Tag
消息标签,二级消息类型,用来进一步区分某个Topic下的消息分类。更多信息,请参见Topic与Tag最佳实践
Producer
消息生产者,也称为消息发布者,负责生产并发送消息。
Producer实例
Producer的一个对象实例,不同的Producer实例可以运行在不同进程内或者不同机器上。Producer实例线程安全,可在同一进程内多线程之间共享。
Consumer
消息消费者,也称为消息订阅者,负责接收并消费消息。可分为两类:
  • Push Consumer:消息由云消息队列 RocketMQ 版推送至Consumer。
  • Pull Consumer:该类Consumer主动从云消息队列 RocketMQ 版拉取消息。目前仅TCP Java SDK支持该类Consumer。
    重要 如需使用Pull Consumer,请确保您的云消息队列 RocketMQ 版实例为企业铂金版。

更多信息,请参见接口和参数说明订阅消息

消费位点
每个Topic会有多个分区,每个分区会统计当前消息的总条数,这个称为最大位点MaxOffset;分区的起始位置对应的位置叫做起始位点MinOffset。

云消息队列 RocketMQ 版的Pull Consumer会按顺序依次消费分区内的每条消息,记录已经消费了的消息条数,称为消费位点ConsumerOffset。剩余的未消费的条数(也称为消息堆积量)= 最大位点MaxOffset-消费位点ConsumerOffset。

Consumer实例
Consumer的一个对象实例,不同的Consumer实例可以运行在不同进程内或者不同机器上。一个Consumer实例内配置线程池消费消息。
Group

一类Producer或Consumer,这类Producer或Consumer通常生产或消费同一类消息,且消息发布或订阅的逻辑一致。

Group ID
Group的标识。
队列(Message Queue)
即Topic Partition,物理上的概念。每个Topic包含一个或多个队列。创建Topic时队列由系统自动分配,不支持自定义修改。
集群消费
一个Group ID所标识的所有Consumer平均分摊消费消息。例如某个Topic有9条消息,一个Group ID有3个Consumer实例,那么在集群消费模式下每个实例平均分摊,只消费其中的3条消息。更多信息,请参见集群消费和广播消费
广播消费
一个Group ID所标识的所有Consumer都会各自消费某条消息一次。例如某个Topic有9条消息,一个Group ID有3个Consumer实例,那么在广播消费模式下每个实例都会各自消费9条消息。更多信息,请参见集群消费和广播消费
定时消息
Producer将消息发送到云消息队列 RocketMQ 版服务端,但并不期望这条消息立马投递,而是推迟到在当前时间点之后的某一个时间投递到Consumer进行消费,该消息即定时消息。更多信息,请参见定时和延时消息
延时消息
Producer将消息发送到云消息队列 RocketMQ 版服务端,但并不期望这条消息立马投递,而是延迟一定时间后才投递到Consumer进行消费,该消息即延时消息。更多信息,请参见定时和延时消息
事务消息
云消息队列 RocketMQ 版提供类似XA或Open XA的分布事务功能,通过云消息队列 RocketMQ 版的事务消息能达到分布式事务的最终一致。更多信息,请参见事务消息
顺序消息
云消息队列 RocketMQ 版提供的一种按照顺序进行发布和消费的消息类型,分为全局顺序消息和分区顺序消息。更多信息,请参见顺序消息
全局顺序消息
对于指定的一个Topic,所有消息按照严格的先入先出(FIFO)的顺序进行发布和消费。更多信息,请参见顺序消息
分区顺序消息
对于指定的一个Topic,所有消息根据Sharding Key进行区块分区。同一个分区内的消息按照严格的FIFO顺序进行发布和消费。Sharding Key是顺序消息中用来区分不同分区的关键字段,和普通消息的Message Key是完全不同的概念。更多信息,请参见顺序消息
消息堆积
Producer已经将消息发送到云消息队列 RocketMQ 版的服务端,但由于Consumer消费能力有限,未能在短时间内将所有消息正确消费掉,此时在云消息队列 RocketMQ 版的服务端保存着未被消费的消息,该状态即消息堆积。
消息堆积量=处理中消息量+已就绪消息量,具体的指标含义,可参考以下说明:队列消息状态

上图表示指定主题的某一队列中各消息的状态,云消息队列 RocketMQ 版将处于不同处理阶段的消息数量和耗时进行统计,这些指标可直接反映队列中消息的处理速率和堆积情况,通过观察这些指标可初步判断业务的消费是否异常。具体的指标含义和计算公式如下:

分类指标定义计算公式
消息数量指标处理中的消息(inflight messages)在消费者客户端正在处理,但客户端还未返回消费结果的消息。最晚一条拉取消息的位点-最晚一条提交消息的位点
已就绪的消息(ready messages)消息在云消息队列 RocketMQ 版服务端已就绪,对消费者可见可被消费的消息。最大消息位点-最晚一条拉取消息的位点
消息堆积量(consumer lag)所有未处理完成的消息量。处理中消息量+已就绪消息量
消息耗时指标已就绪消息的就绪时间(ready time)
  • 普通消息、顺序消息:消息存储到服务端的时间。
  • 定时/延时消息:消息定时或延时结束的时间。
  • 事务消息:事务提交的时间。
不涉及
已就绪消息的排队时间(ready message queue time)最早一条就绪消息的就绪时间和当前时刻的时间差。

该时间反映消费者拉取消息的及时性。

当前时间-最早一条就绪消息的就绪时间
消费处理滞后时间(comsumer lag time)最早一条未消费完成的消息的就绪时间和当前时刻的时间差。

该时间反映消费者完成消息处理的及时性。

当前时间-最早一条未提交消息的就绪时间
消息过滤
Consumer可以根据消息标签(Tag)对消息进行过滤,确保Consumer最终只接收被过滤后的消息类型。消息过滤在云消息队列 RocketMQ 版的服务端完成。更多信息,请参见消息过滤
消息轨迹
在一条消息从Producer发出到Consumer消费处理过程中,由各个相关节点的时间、地点等数据汇聚而成的完整链路信息。通过消息轨迹,您能清晰定位消息从Producer发出,经由云消息队列 RocketMQ 版服务端,投递给Consumer的完整链路,方便定位排查问题。更多信息,请参见查询消息轨迹
重置消费位点
以时间轴为坐标,在消息持久化存储的时间范围内(默认3天),重新设置Consumer对已订阅的Topic的消费进度,设置完成后Consumer将接收设定时间点之后由Producer发送到云消息队列 RocketMQ 版服务端的消息。更多信息,请参见重置消费位点
死信队列

死信队列用于处理无法被正常消费的消息。当一条消息初次消费失败,云消息队列 RocketMQ 版会自动进行消息重试;达到最大重试次数后,若消费依然失败,则表明Consumer在正常情况下无法正确地消费该消息。此时,云消息队列 RocketMQ 版不会立刻将消息丢弃,而是将这条消息发送到该Consumer对应的特殊队列中。

云消息队列 RocketMQ 版将这种正常情况下无法被消费的消息称为死信消息(Dead-Letter Message),将存储死信消息的特殊队列称为死信队列(Dead-Letter Queue)。

相关操作,请参见死信队列