栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

RocketMQ-重试队列

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

RocketMQ-重试队列

重试队列介绍

对于需要重试消费的消息,并不是Consumer在等待一个指定时长后再去拉取原来的消息进行消费,而是将这些需要重试的消息放入到一个特殊的Topic队列中,而后进行再次消费的,这个特殊的队列就是重试队列。当出现需要进行重试消费的消息时,Broker会为每个消费组都设置Topic名称,为%RETRY%consumerGroup@consumerGroup的重试队列。

这个重试队列是针对消息才组的,而不是针对每个Topic设置的(一个Topic的消息可以让多个消费者进行消费,所以会为这些消费者组各创建一个重试队列)
只有当现在需要进行重试消费的消息时,才会为该消费者组创建重试队列


Broker对于重试消息的处理是通过延迟消息来实现的,先将消息保存到SCHEDULE_TOPIC_XXXX延迟队列中,延迟时间到后,会将消息投递到%consumerGroup@consumerGroup重试队列中。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/684731.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号