网站备案需要多少天,网站建设工作稳定吗,网站系统建设需要什么资质,遵义网约车在分布式消息系统中#xff0c;处理消费失败的消息是非常关键的一环。 RocketMQ 提供了一套完整的消息消费失败处理机制#xff0c;下面我将简要介绍一下其处理逻辑。 截图代码版本#xff1a;4.9.8 步骤1
当消息消费失败时#xff0c;RocketMQ会发送一个code为36的请求到…在分布式消息系统中处理消费失败的消息是非常关键的一环。 RocketMQ 提供了一套完整的消息消费失败处理机制下面我将简要介绍一下其处理逻辑。 截图代码版本4.9.8 步骤1
当消息消费失败时RocketMQ会发送一个code为36的请求到消息所在的 broker。broker接收到这个请求后会将这个失败的消息放入到一个特殊的retry topic中准备后续的重试消费。然而在网络异常的情况下有可能这里拿到的broker地址是空的这将导致请求被发送到ns。由于ns并不处理这种类型的请求因此在网络异常的情况下会出现请求超时等待的情况**这个我们在多az做断网演练时遇到过**。 步骤2
如果步骤1失败即消息没有成功地被放入retry topic客户端会尝试选择其他的broker进行发送。这样即使某个broker出现问题我们仍然可以确保消息得以在retry topic中得到存储以便后续进行重试消费。 步骤3
如果步骤2也失败即消息在所有的broker中都没有成功地放入retry topic那么客户端会将消息塞回到消费的队列中在5秒后再次尝试消费。
总结
总的来说RocketMQ在处理消费失败的消息时提供了一套从多个角度进行保障的策略。无论是通过发送到不同broker的retry topic还是通过延迟再次消费都能在一定程度上确保消息的最终一致性降低消息丢失的风险。
