rocketmq核心源码分析第二十七篇一重试消息以及死信消息

原理图总结 原理图

重试消息以及死信消息的主题均以消费者组名定义每一个消费者组一个死信消息topic每一个消费者组一个重试消息topic重试消息最大消费16次,延迟级别从3开始到18结束当消息重试至最大次数则终止重试发送至死信队列可以建立一个专门消费组订阅死信队列
总结

消费者模块详解了不同模型下消费失败的处理代码基本重复于[消费模块,延时消息模块],本文简述重试以及死信消息流程