厨浴 发表于 昨天 12:49

rocketmq重试机制和死信消息

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

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

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

结果


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

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

方案2


来源:程序园用户自行投稿发布,如果侵权,请联系站长删除
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!
页: [1]
查看完整版本: rocketmq重试机制和死信消息