RabbitMQ Federation 插件使用

RabbitMQ Federation 插件可以将消息从一个 Exchange 复制到另一个 Exchange，或从一个 Queue 分发到另一个 Queue。

复制的源端被称为 upstream，复制的目的端被称为 downstream。要使用 Federation 插件，需要在两个集群都开启 Federation 插件，并且在 downstream 集群创建 Federation，配置 upstream。

将多个集群的消息收集到一个集群将一个队列的压力分散到多个集群在不下线的情况下将数据从一个集群同步到另一个集群减少消息消费的时延 Federation 种类

可以创建两种类型的 Federation，分别是 Exchange Federation 和 Queue Federation。

简单说，它可以实现消息在 Exchange 间的复制（同步）。

使用 Exchange Federation 可以将消息发到其他集群。效果是，当消息发送到被联邦的 Exchange 时，消息会被发送到本地的 Exchange 和 下游的集群。这样，你就可以在不同的集群多次消费消息。

Queue Federation 的效果是消息的负载均衡，它只会将消息发往有空闲消费者的下游集群。也就是说，消息不会被复制。

常被用于分散压力和集群消息转移。

两个 RabbitMQ 服务器或集群在两个 RabbitMQ 上开启 Federation 插件（可选）为 Federation 的组件单独创建用户上下游 RabbitMQ 网络可以通过 AMQP 协议连接 Federation Exchange 使用

满足使用前提在下游节点配置 Federation 的 upstream在下游节点配置 Policy，指定要被 Federate 的 Exchange 或 Queue

创建 Exchange

创建 Queue

绑定 Exchange 和 Queue

配置 upstream

创建 Federation policy

检查 Federation 状态

在上游集群向 Exchange 发送消息

在上下游集群的队列都可以收到消息

Federation PluginFAQ: What is the RabbitMQ Federation pluginSetup RabbitMQ Exchange Federation