在消息队列 RocketMQ版中,消息存储在每个 Topic 的一个或多个队列中。
生产者将消息发送到消息队列 RocketMQ版服务端后,不能立刻被消费者消费,仅能到达指定期望被消费时间才会被投递到 Consumer 进行消费。
生产者将消息发送到消息队列 RocketMQ版服务端后,不能立刻被消费者消费,需推迟指定延时时间才会被投递到 Consumer 进行消费。
说明
消息队列 RocketMQ版延迟消息支持自定义毫秒级延迟,延迟时长最长为 3 天或消息保留时长的 3 倍(两者取较小值)。
保证分布式事务数据的最终一致性。
按照消息的发布顺序进行顺序消费(FIFO),支持全局顺序与分区顺序。
消息队列 RocketMQ版支持对未成功消费的消息自动投递重新消费,达到最大重试次数后,若消费依然失败,则表示消费者在正常情况下无法消费此消息,将此类消息称为死信消息。
消息队列 RocketMQ版在创建消费者与某个 Topic 的订阅关系时会自动创建一个死信队列用以存储死信消息。
同一 Topic 的消息只需被集群内的任意一个消费者处理即可。一个消费者只消费该 Topic 中的部分消息,每条消息仅被消费一次。
同一 Topic 的消息会被所有订阅的消费者都消费一次。即,一个消费者会消费该 Topic 中所有的消息,每条消息会被消费多次。