开发者社区 > 云原生 > 消息队列 > 正文

请教一下数据链路的问题: 端上来的消息,通过mqttbroker直接进入rocketmq?

请教一下数据链路的问题: 端上来的消息,通过mqttbroker直接进入rocketmq? 然后云应用消费rocketmq?

展开
收起
wenti 2023-03-13 11:55:11 240 0
3 条回答
写回答
取消 提交回答
  • 有两种方案: 一种是采用商业化的方案,使用阿里云的RocketMQ、微消息队列MQTT、EventBridge,能够将MQTT的消息链接到各种消息队列和数据产品。 一种是采用RocketMQ开源自建的方案,直接参考https://rocketmq.apache.org/zh/docs/mqtt/01RocketMQMQTTOverview

    2023-03-14 14:00:09
    赞同 展开评论 打赏
  • 发表文章、提出问题、分享经验、结交志同道合的朋友

    数据链路是指将消息从源头传输到目的地的过程中,经过的所有网络设备和传输介质。在您的问题中,消息从端上通过MQTT协议传输到MQTT Broker上,然后进入RocketMQ,最终被云应用消费。因此,数据链路的路径应该是:

    端设备 -> MQTT协议 -> MQTT Broker -> RocketMQ -> 云应用

    在这个过程中,每个环节都可能会影响消息传输的可靠性、时延和带宽等。因此,在设计和优化数据链路时,需要考虑多个因素,例如网络拓扑结构、传输协议、传输介质、QoS等,以满足应用场景的需求。

    2023-03-13 13:46:32
    赞同 展开评论 打赏
  • 在一般情况下,数据链路通常是指网络层面的数据传输。而您提到的问题,涉及到的是数据在不同组件之间的传输,一般可以称之为组件间通信。因此,我来回答您的问题: 在MQTT和RocketMQ之间,通常需要通过一个中间件来进行转换和传输。因为MQTT和RocketMQ是两种不同的消息传输协议,需要进行协议转换。常见的做法是使用MQTT Broker作为中间件,将MQTT消息转换为RocketMQ消息,并通过RocketMQ进行传输。因此,端上来的消息会先经过MQTT Broker进行协议转换和路由,然后再进入RocketMQ进行消息传输。

    对于云应用消费RocketMQ的问题,一般需要在云平台上部署RocketMQ消费者,该消费者可以从RocketMQ订阅消息并进行处理。如果您的云应用是在PaaS平台上部署的,可能已经提供了RocketMQ消费者的相关服务。如果您是在IaaS平台上部署的云应用,则需要自行部署RocketMQ消费者。

    2023-03-13 13:26:11
    赞同 展开评论 打赏

多个子产品线联合打造金融级高可用消息服务以及对物联网的原生支持,覆盖多行业。

热门讨论

热门文章

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载