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

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

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

展开
收起
wenti 2023-03-13 11:55:11 260 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
    赞同 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 热门讨论

    热门文章

    相关电子书

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