代理繁忙时客户端不重试的问题
TIMEOUT_CLEAN_QUEUE 是broker端快速失败机制中由于消息发送请求挤压超过200ms（可通过waitTimeMillsInSendQueue参数调整），直接返回失败，避免过长等待，但客户都收到该请求，个人理解，按照快速失败机制的理念，客户端应该要重试其他broker，具体分析请见如下链接：
https://mp.weixin.qq.com/s/_yd-OhWDJ_9N_F_jd3B3VQ
原提问者GitHub用户dingwpmz
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
Broker使用TIMEOUT_CLEAN_QUEUE快速失败---->Broker使用System_Busy生成MQBrokerException---->客户端进程代码，如下所示：
rocketmq/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
Lines 617 to 637 in 39bb938
} catch (MQBrokerException e) { endTimestamp = System.currentTimeMillis(); this.updateFaultItem(mq.getBrokerName(), endTimestamp - beginTimestampPrev, true); log.warn(String.format("sendKernelImpl exception, resend at once, InvokeID: %s, RT: %sms, Broker: %s", invokeID, endTimestamp - beginTimestampPrev, mq), e); log.warn(msg.toString()); exception = e; switch (e.getResponseCode()) { case ResponseCode.TOPIC_NOT_EXIST: case ResponseCode.SERVICE_NOT_AVAILABLE: case ResponseCode.SYSTEM_ERROR: case ResponseCode.NO_PERMISSION:
添加System_Busy，以防原因可能对U很好
原回答者GitHub用户francisoliverlee
2023-05-26 17:29:15赞同 展开评论
阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践，通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式，助力制造业企业高效上云，实现系统稳定、应用敏捷智能。拥抱云原生，让创新无处不在。