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

咨询一下,两个mq之间互发、接收消息,需要怎么做?

咨询一下,两个mq之间互发、接收消息,需要怎么做? 我有2个微服务,要通过mq进行消息发送,每个微服务都有自己的MQ,,我在微服务用中同时创建mqA 和mqB的生产者和消费者吗?

展开
收起
滴滴滴~ 2023-03-06 16:43:08 691 0
4 条回答
写回答
取消 提交回答
  • 坚持这件事孤独又漫长。
    • 在这种场景下,你需要在每个微服务中都创建自己的 MQ 生产者和消费者。并且,需要确保两个 MQ 之间的消息传递方式是正确的。

    具体而言,可以在 MQA 和 MQB 之间设置一个消息队列或者一个 topic,用来交换消息。在微服务中,需要创建自己的生产者和消费者,同时指定发送或接收的消息队列或者 topic。当一个微服务想要向另外一个微服务发送消息时,将消息发送到消息队列或者 topic 上,由另外一个微服务中的消费者来消费这些消息。

    • 例如,假设微服务 A 中创建了一个名为“queueA”的消息队列,微服务 B 中创建了一个名为“queueB”的消息队列。如果微服务 A 想要向微服务 B 发送消息,它就可以发送消息到“queueB”队列上;反之亦然。通过这种方式,可以保证两个微服务之间的通信是可靠和高效的。

    需要注意的是,消息传递过程中可能会出现一些问题,例如消息丢失、消息重复等。因此,在实现这种通信方式时,需要对消息传递机制进行优化和调优,以提高消息传递的可靠性和性能。

    2023-03-07 10:05:06
    赞同 展开评论 打赏
  • 天下风云出我辈,一入江湖岁月催,皇图霸业谈笑中,不胜人生一场醉。

    MQ可以可以拉取系统A然后传输给系统B,实现2台 MQ 服务器互相通信1、实现 MQServer2 发信息到MQServer1:MQServer1 创建队列、通道和监听器,实现 MQServer1 发信息到MQServer2:MQServer2 创建队列、通道和监听器,具体可以看这个代码地址:https://blog.csdn.net/weixin_34032827/article/details/89860444

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

    如果你的两个微服务分别对应着不同的MQ实例,那么你需要在每个微服务中分别创建与对应MQ实例的生产者和消费者。

    同时,需要确定消息的发送和接收方,比如说微服务A需要向微服务B发送消息,那么在微服务A中创建MQA的生产者,同时在微服务B中创建MQB的消费者。在消息发送时,将消息发送到MQA中,消息到达MQB时,MQB的消费者将接收到该消息进行处理。

    2023-03-07 08:38:40
    赞同 展开评论 打赏
  • 双向复制,要么业务侧双写双读,要么基于mq的复制工具做双向消息同步。此答案整理自钉群“群2-Apache RocketMQ 中国”

    2023-03-06 16:49:06
    赞同 展开评论 打赏
问答分类:
问答标签:
相关产品:

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

相关产品

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

    热门文章

    相关电子书

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