找回密码
 立即注册
首页 业界区 安全 rocketmq重试机制和死信消息

rocketmq重试机制和死信消息

绂染 7 小时前
1.重试机制
当生产者发送消息失败的时候,可以重新发送消息,可以设置重试的次数以及重试的间隔
当消费者消费失败的时候可以重新消费消息,默认的重试次数是16次(重试间隔和延迟等级一致(10s-2h)),如果是顺序消息的话会重试int的最大值次数
演示代码
生产者
1.png

消费者(不设置最大重试次数)
注意:消息消费的重试次数从0开始计算(包含消息首次消费)
2.png

消费者(设置最大重试次数)
3.png

结果
4.png

5.png

2.死信消息
当消息超过最大重试次数都没有成功消费时,消息会进入死信Topic中,死信主题名称为“%DLQ%+原Topic消费者组名称”,死信Topic中只有一个队列
如下图所示
6.png

死信消息解决方案
方案1(基本不用)
7.png

方案2
8.png


来源:豆瓜网用户自行投稿发布,如果侵权,请联系站长删除

相关推荐

您需要登录后才可以回帖 登录 | 立即注册