在异步模式下发送消息时,重试不起作用(例如,当代理关闭时)

在异步模式下发送消息时,重试次数设置为1。代码如下:

提问100.png

如果所选的代理在那一刻关闭,消息发送将失败,不会重试。

RMQ 4.6.0

原提问者GitHub用户xiangwangcheng

展开
收起
芬奇福贵 2023-05-26 15:45:16 107 分享 版权
1 条回答
写回答
取消 提交回答
  • 在 RocketMQ 中同步的消息发送重试是通过DefaultMQProducerImpl#sendDefaultImpl()中的 for 循环,循环调用sendKeynelImpl()方法实现的。重试次数由DefaultMQProducer#getRetryTimesWhenSendFailed()获得。 而异步的消息发送重试是在出现异常的情况下,由MQClientAPIImpl#onExceptionImpl()递归调用MQClientAPIImpl#sendMessageAsync()方法实现的。重试次数由DefaultMQProducerImpl#.getRetryTimesWhenSendAsyncFailed()获得,缺省值为 2。 所以在不设置异步重试次数的情况下,也会至少重试 2 次,不会因为没有重试而导致消息发送失败。只是异步和同步发送重试实现的位置不一样,导致产生了这样判断。

    原回答者GitHub用户MountainOne

    2023-05-26 17:45:19
    赞同 展开评论
问答地址:

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

还有其他疑问?
咨询AI助理