前言:
Federation具备的数据转发功能类似,Shovel能够可靠、持续地从一个Broker中的队列(作为源端,即source)拉取数据并转发至另一个Broker中的交换器(作为目的端,即destination)。作为源端的队列和作为目的端的交换器可以同时位于同一个Broker,也可以位于不同的Broker 上。Shovel可以翻译为"铲子",是一种比较形象的比喻,这个"铲子"可以将消息从一方"铲子"另一方。Shovel行为就像优秀的客户端应用程序能够负责连接源和目的地、负责消息的读写及负责连接失败问题的处理。
1、Shovel工作原理图
分别往Q1和Q2各自发送一条消息,Q1的消息也会通过Shovel发送给Q2,所以Q1收到1条消息,Q2收到2条消息
2、搭建shovel
(1)分别在3个RabbitMQ节点上安装shovel插件
rabbitmq-plugins enable rabbitmq_shovel
效果图:
node1:
node2:
node3:
(2)分别在3个RabbitMQ节点上安装shovel管理插件
rabbitmq-plugins enable rabbitmq_shovel_managemen
效果图:
node1:
node2:
node3:
(3)进入Admin页面,可以发现多出了2个与shovel有关的菜单
(4)新增shovel
(5)填写shovel的相关信息
(6)新增shovel
效果图:
(7)点击Shovel Status菜单查看Shovel的运行状态,若状态显示running,则证明Shovel正在正常运行,若这时候往Q1队列发送消息,消息会自动同步到Q2文章来源:https://www.toymoban.com/news/detail-540747.html
文章来源地址https://www.toymoban.com/news/detail-540747.html
到了这里,关于RabbitMQ系列(29)--RabbitMQ搭建Shovel的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!