本文基于RocketMQ 4.7.1版本

前面两篇文章介绍了DefaultMQPushConsumer和DefaultMQPullConsumer消费消息的原理，由此我们知道了

• DefaultMQPushConsumer消费消息相当于全自动，开发人员只需要创建好监听器即可，其他的问题都由rocketmq自动处理；
• DefaultMQPullConsumer相当于手动，这给开发人员提供了极大的自由度，但也带来了编程上的困难，需要开发人员自己维护消费位移，判断消费失败是否重新消费。

本文主要介绍DefaultMQPushConsumer消费失败后如何自动发起重新消费。

文章目录

• 一、原理图
• 二、消费者消费消息原理
• 三、broker处理重新拉取请求原理
• 四、消费重试主题
• 五、死信主题