admin管理员组

文章数量:1641941

验证RocketMQ默认重试

背景：线上有丢消息（无重试）的情况。经过排查，是因为并发时会有一个消息消费失败，但没有进行重试。检查配置无误后决定升级MQ版本。在升级版本前后经过下面的验证。发现新版MQ重试没问题，而老版MQ存在兼容问题而不能重试消息。

先说下结论，后边事对此结论的验证：
RocketMQ的默认重试次数为16次，且默认重试间隔时间为（1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h）

一、环境说明

老版MQ版本：V4_4_0
新版MQ版本：V4_9_3
java

二、java代码

1.生产者

@RestController
@Api(value = "测试服务", description = "测试服务")
@RequestMapping(value = "/test", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_UTF8_VALUE)
public class TestController {
   

  private final static Logger logger = LoggerFactory.getLogger

本文标签： 重试RocketMQ

版权声明：本文标题：验证RocketMQ默认重试 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://m.elefans.com/xitong/1729329582a1196215.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。