RabbitMQ Federation 插件使用

概述

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

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

使用场景

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

Federation 种类

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

Exchange Federation

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

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

Queue Federation

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

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

使用前提

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

Federation Exchange 使用

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

upstream 上游集群配置

创建 Exchange

创建 Queue

绑定 Exchange 和 Queue

downstream 下游集群配置

配置 upstream

创建 Federation policy

检查 Federation 状态

测试

在上游集群向 Exchange 发送消息

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

参考资料

Federation Plugin
FAQ: What is the RabbitMQ Federation plugin
Setup RabbitMQ Exchange Federation

RabbitMQ Federation 插件使用相关推荐

RabbitMq 集群federation 插件使用心得
@doc 前言为了能让RabbitMQ 更好的在wan下面工作,Rabbit推出了federation插件.主要用于在wan情况下,多个rabbit实例(集群)进行数据传输和交换. 步骤 1,首先搭 ...
RabbitMq Federation简介
RabbitMq Federation简介背景: broker1 broker2 exchanger2 mq2 federation提供了一个能力,让broke1在本地先创建一个exchange2, ...
RabbitMQ 延迟插件的作用
RabbitMQ 延迟插件的作用延迟插件的作用: 延迟队列可以做什么事情? 比如消息的延迟推送,定时任务(消息)的执行.包括一些消息重试策略的配合使用,以及用于业务削峰限流,降级的异步延迟消息机制, ...
RabbitMQ Tracing插件使用
在https://github.com/MarcialRosales/rabbitmq-tracing-guide基础上添加一些个人的实践和理解 RabbitMQ Tracing Guide rabb ...
rabbitmq添加插件和配置文件的添加
https://blog.csdn.net/njnujuly/article/details/80405915 上面的是重启rabbitmq 其中重启我感觉有问题,可以用这 rabbitmqctl s ...
基于rabbitmq延迟插件实现分布式延迟任务
一.延迟任务的使用场景 1.下单成功,30分钟未支付.支付超时,自动取消订单 2.订单签收,签收后7天未进行评价.订单超时未评价,系统默认好评 3.下单成功,商家5分钟未接单,订单取消 4.配送超时, ...
docker安装rabbitMQ stomp插件
1.拉取镜像 docker pull rabbitmq:3-management 2.运行容器 docker run -d --name rabbit -e RABBITMQ_DEFAULT_USER ...
linux查看rabbitmq的插件,【linux环境下】RabbitMq的安装和监控插件安装
简介这篇文章主要介绍了[linux环境下]RabbitMq的安装和监控插件安装以及相关的经验技巧,文章约2904字,浏览量445,点赞数5,值得参考! [注意安装过程中,提示某些命令not found ...
rabbitmq shovel插件
官网说明https://www.rabbitmq.com/shovel.html#management-status 启用shovel插件命令: rabbitmq-plugins enable rab ...
RabbitMq启用插件管理
打开命令行输入以下命令: rabbitmq-plugins enable rabbitmq_management 之后在浏览器地址栏输入 http://localhost:15672/ 默认的账户密码 ...