rocketmq-send-message

文档摘要

该文所涉及的 RocketMQ 源码版本为 4.9.3。 RocketMQ 消息发送流程这里以同步发送为示例讲解：入口： org.apache.rocketmq.client.producer.DefaultMQProducer#send(org.apache.rocketmq.common.message.Message) 消息发送默认超时时间 3 秒第一步：验证主题的长度不能大于 127，消息的大小不能大于 4M 第二步：查找路由信息如果缓存中存在路由信息，并且队列信息不为空直接返回路由信息，如果缓存不存在，根据当前主题从 NameServer 中获取路由信息，如果路由信息没有找到，根据默认主题查询路由信息，如果没有找到抛出异常从 NameServer