【发布时间】:2015-12-19 03:17:37
【问题描述】:
我尝试构建一个具有多个服务器消息交换的系统。
我有一个叫做 Master 的服务器和另一个叫做 Slave 的服务器。 Master向Slave发送消息,Slave异步向Master发送消息。
我在两台服务器上都有rabbitmq 服务器,并在两台服务器上都使用联合插件来获取消息。 所以两台服务器上的发布者和消费者只与本地rabbitmq服务器通信。并且服务器之间的所有消息交换仅使用 rabbitmq 完成。
它工作正常。当两台服务器都在线时。
我的要求是,当服务器之间没有网络连接时,应该积累消息,直到连接恢复。 而且它不适用于 federation plugin 。如果联邦连接未激活,则消息不会存储在本地 rabbitmq 中。
我应该怎么做才能让消息可以等待连接传递到其他rabbitmq服务器的模型?
我需要提供有关我当前型号的更多信息吗?
有更简单的描述
RabbitMQ1 有交换 MASTER。 RabbitMQ2 使用指向 RabbitMQ1 的链接创建了联盟,并将权限分配给了交易所 MASTER
Publisher 写入 RabbitMQ1 以使用路由密钥“myqueue”交换 MASTER
消费者在交换 MASTER 上侦听 RabbitMQ2 并排队“myqueue”。
如果有连接,那么一切正常 如果没有连接,那么当连接恢复时,发布到 RabbitMQ1 的消息不会传递到 RabbitMQ2。
如何解决?
【问题讨论】:
标签: rabbitmq