栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

RabbitMQ Federation 插件简单使用小记

RabbitMQ Federation 插件简单使用小记

官方文档 : Federation Plugin

非常简单的记录一下使用,详细内容请看官方文档!

作用:

Federation插件的高级目标是在不需要集群的情况下在brokers之间传输消息。

一、安装

RabbitMQ自带插件,直接启用即可。(如果是集群需要所有节点都启用该插件)

# 进入 安装目录/sbin 下
# 启用插件
rabbitmq-plugins enable rabbitmq_federation

# 启用管理界面
rabbitmq-plugins enable rabbitmq_federation_management

之后你就可以在管理界面中看到图中框出的两个选项

二、配置 2.1 前情提要
  1. 一个上游MQ,即数据来源MQ,你要从这里拿数据过来。
  2. 一个下游MQ,即接收数据的MQ,数据从上游MQ通过Federation来到这里。
  3. 步骤:
    • 配置交换机和队列 上下游
    • 配置 Upstream 和 Policy 仅下游
2.2 创建交换机和队列并绑定 2.3 创建Upstream

简单填写了必填项
需要注意的点是如果虚拟目录为 / ip后面不要加 / 否则连不上。

2.4 创建Policy

同样简单填写

注意事项:如果 apply to 选择了 Queues,则必须要有消费者,不然不会有数据过来。 所以如果需要不错过消息的话就不要选只有Queues的了!

2.5 成功连接

下游Federation status:

上游可以看到连接里面有Federation link

上游MQ的交换机中会看到type为x-federation-upstream灰色的交换机和队列,如果选的是Queues则不会有。

最后

在上游push消息,下游MQ能收到即代表成功了!!

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/653803.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号