RocketMQ进击(七)盘一盘RocketMQ的重试机制

楔子:翻了帖子两三天,硬是没有找到哪一个帖子能证实生产端的消息重试是确实重试了的。大多要么是对概念、源码说明了一下,或者把实现示例贴贴,但基本并无有效测试证实。想了想,仍是本身来捋一捋这 RocketMQ 的消息重试机制。java 因为 MQ 常常处于庞大的分布式系统中,考虑到网络波动、服务宕机、程序异常等因素,极可能会出现消息发送或者消费失败的问题。所以,若是没有消息重试,就有可能形成消息丢失,
相关文章
相关标签/搜索