You need to enable JavaScript to run this app.
导航
相关概念
最近更新时间:2023.03.21 15:27:10首次发布时间:2021.08.30 16:57:44

队列(Queue)

在消息队列 RocketMQ版中,消息存储在每个 Topic 的一个或多个队列中。

位点(Offset)

  • 最大位点(MaxOffset):一个分区中统计的当前消息的总条数。
  • 起始位点(MinOffset):分区的起始位置。
  • 消费位点(ConsumerOffset):记录按顺序依次消费分区内的消息时,已被消费的消息条数。

定时消息

生产者将消息发送到消息队列 RocketMQ版服务端后,不能立刻被消费者消费,仅能到达指定期望被消费时间才会被投递到 Consumer 进行消费。

延时消息

生产者将消息发送到消息队列 RocketMQ版服务端后,不能立刻被消费者消费,需推迟指定延时时间才会被投递到 Consumer 进行消费。

说明

消息队列 RocketMQ版延迟消息支持自定义毫秒级延迟,延迟时长最长为 3 天或消息保留时长的 3 倍(两者取较小值)。

事务消息

保证分布式事务数据的最终一致性。

顺序消息

按照消息的发布顺序进行顺序消费(FIFO),支持全局顺序与分区顺序。

  • 全局顺序消息:严格保证所有消息都是按照生产者投递的顺序(即先入先出,FIFO)的顺序进行发布和消费。
  • 局部顺序消息:严格保证在同一分区下的消息按照生产者投递到该分区的顺序(即先入先出,FIFO)进行发布和消费。

死信消息

消息队列 RocketMQ版支持对未成功消费的消息自动投递重新消费,达到最大重试次数后,若消费依然失败,则表示消费者在正常情况下无法消费此消息,将此类消息称为死信消息。

死信队列

消息队列 RocketMQ版在创建消费者与某个 Topic 的订阅关系时会自动创建一个死信队列用以存储死信消息。

集群消费

同一 Topic 的消息只需被集群内的任意一个消费者处理即可。一个消费者只消费该 Topic 中的部分消息,每条消息仅被消费一次。

广播消费

同一 Topic 的消息会被所有订阅的消费者都消费一次。即,一个消费者会消费该 Topic 中所有的消息,每条消息会被消费多次。