咨询一下,两个mq之间互发、接收消息,需要怎么做? 我有2个微服务,要通过mq进行消息发送,每个微服务都有自己的MQ,,我在微服务用中同时创建mqA 和mqB的生产者和消费者吗?
咨询一下,两个mq之间互发、接收消息,需要怎么做?[阿里云消息队列MQ]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!
咨询一下,两个mq之间互发、接收消息,需要怎么做? 我有2个微服务,要通过mq进行消息发送,每个微服务都有自己的MQ,,我在微服务用中同时创建mqA 和mqB的生产者和消费者吗?
MQ可以可以拉取系统A然后传输给系统B,实现2台 MQ 服务器互相通信1、实现 MQServer2 发信息到MQServer1:MQServer1 创建队列、通道和监听器,实现 MQServer1 发信息到MQServer2:MQServer2 创建队列、通道和监听器,具体可以看这个代码地址:https://blog.csdn.net/weixin_34032827/article/details/89860444
如果你的两个微服务分别对应着不同的MQ实例,那么你需要在每个微服务中分别创建与对应MQ实例的生产者和消费者。
同时,需要确定消息的发送和接收方,比如说微服务A需要向微服务B发送消息,那么在微服务A中创建MQA的生产者,同时在微服务B中创建MQB的消费者。在消息发送时,将消息发送到MQA中,消息到达MQB时,MQB的消费者将接收到该消息进行处理。
双向复制,要么业务侧双写双读,要么基于mq的复制工具做双向消息同步。此答案整理自钉群“群2-Apache RocketMQ 中国”