其中一个代理崩溃，生产者选择其他代理成功，但抛出MQClientException
我们将retryTimesWhenSendFailed设置为3 我们将发送超时设置为3000 我们设置sendLatencyFaultEnable=false 我们有4个经纪人（经纪人a、经纪人b、经纪人c、经纪人d），使经纪人a崩溃。 生产者发送消息，但抛出org.apache.rocketmq.client.exception.MQClientException： Send [3] times, still failed, cost [3000]ms, Topic: xxxx, BrokersSent: [broker-a, broker-b, broker-c]
broker-a崩溃，重试broker-b成功，不抛出异常
图片1具有选择的代理-b和代理-c，但发送时间为0。
图2是rocketmq_client.log，我们可以看到发送broker-a是超时，但broker-b和broker-c超时是0。
图3是控制台消息页面。这是来自broker-b和broker-c的两条成功消息。
DefaultMQProducerImpl.sendDefaultImpl（），broker-a的成本时间=3000。 if（timeout<costTime）应该是if（timeout<=costTime）？
NettyRemotingAbstract.invokeSyncImpl（） //timeoutMillis为零，无法等待响应。这就是为什么broker-b和broker-c有成功消息，但抛出异常的原因。 RemotingCommand responseCommand=responseFuture.waitResponse（timeoutMillis）；
rocketmq-client and broker are 4.3.2
原提问者GitHub用户zhongkaiuu
写回答
-
当重试逻辑与超时逻辑冲突时，它将首先确保超时逻辑是正确的。如果这个地方需要更改，建议在dev邮件列表[地址]中发布一个讨论(https://rocketmq.apache.org/about/contact). 毕竟，这是一个非常重要的更改，我将首先关闭该问题，但如果您有任何其他问题，请随时重新打开它。
此外，建议升级到最新版本，例如4.7.0，因为这部分逻辑也进行了大量优化
原回答者GitHub用户duhenglucky
2023-05-26 17:39:31赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践，通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式，助力制造业企业高效上云，实现系统稳定、应用敏捷智能。拥抱云原生，让创新无处不在。
