RocketMQ中怎么实现发送消息？

DefaultMQProducerImpl#sendKernelImpl

在消息发送时的请求报文中，设置默认 topic 名称，消息发送 topic 名称，使用的队列数量为 DefaultMQProducer#defaultTopicQueueNums，即默认为 4。 Step4：Broker 端收到消息后的处理流程 服务端收到消息发送的处理器为：SendMessageProcessor，在处理消息发送时，会调用 super.msgCheck 方法：AbstractSendMessageProcessor#msgCheck

在 Broker 端，首先会使用 TopicConfigManager 根据 topic 查询路由信息，如果 Broker 端不存在该主题的路由配置(路由信息),此时如果 Broker 中存在默认主题的路由配置信息，则根据消息发送请求中的队列数量，在 Broker 创建新 Topic 的路由信息。这样Broker 服务端就会存在主题的路由信息。 在 Broker 端的 topic 配置管理器中存在的路由信息，一会向Nameserver 发送心跳包，汇报到 Nameserver，另一方面会有一个定时任务，定时存储在 broker 端，具体路径为${ROCKET_HOME}/store/config/topics.json 中，这样在 Broker 关闭后再重启，并不会丢失路由信息。

答复内容摘自《Apache RocketMQ 从入门到实战》，这本电子书收录开发者藏经阁 下载连接：https://developer.aliyun.com/topic/download?id=1139