开发者社区 > 云原生 > 正文

RocketMQ中怎么实现发送消息?

RocketMQ中怎么实现发送消息?

展开
收起
vncamyi27xznk 2021-11-27 17:10:12 505 0
1 条回答
写回答
取消 提交回答
  • DefaultMQProducerImpl#sendKernelImpl image.png

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

    在 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

    2021-11-27 20:41:24
    赞同 展开评论 打赏

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

相关产品

  • 云消息队列 MQ
  • 相关电子书

    更多
    RocketMQ Client-GO 介绍 立即下载
    RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载