Rabbitmq的Shovel

news/2025/2/10 22:39:44/
Federation 具备的数据转发功能类似, Shovel 够可靠、持续地从一个 Broker 中的队列 ( 作为源端,即source)拉取数据并转发至另一个 Broker 中的交换器 ( 作为目的端,即 destination) 。作为源端的队列和作为目的端的交换器可以同时位于同一个 Broker ,也可以位于不同的 Broker 上。 Shovel 可以翻译为 " 铲子 " ,是一种比较形象的比喻,这个" 铲子 " 可以将消息从一方 " 铲子 " 另一方。 Shovel 行为就像优秀的客户端应用程序能够负责连接源和目的地、负责消息的读写及负责连接失败问题的处理。

开启插件

需要的机器都开启插件
rabbitmq-plugins enable rabbitmq_shovel
rabbitmq-plugins enable rabbitmq_shovel_management

原理图

在源头发送的消息直接回进入到目的地队列,比如将Q1的队列消息发送到Q2的队列消息

添加 shovel

添加源和目的地 ,amqp://admin:123@node1,admin为用户,123为密码,node1为机器节点hostname

 添加成功

 

 

 


http://www.ppmy.cn/news/1067430.html

相关文章

线程基础:Java多线程的创建休眠与等待

目录 一.Thread 类是什么? 二.Thread 类的几个常见属性 三.线程创建 1. 继承Thread,重写 run 方法 2. 实现Runnable,重写 run 方法 3. 继承Thread,使用匿名内部类 4. 实现Runnable,使用匿名内部类 5. 使用 lambda 表达式…

MySQL项目迁移华为GaussDB PG模式指南

文章目录 0. 前言1. 数据库模式选择(B/PG)2.驱动选择2.1. 使用postgresql驱动2.1. 使用opengaussjdbc驱动 3. 其他考虑因素4. PG模式4.1 MySQL和OpenGauss不兼容的语法处理建议4.2 语法差异 6. 高斯数据库 PG模式JDBC 使用示例验证6. 参考资料 本章节主要…

Mybaties Plus自定义数据源和注解

一、自定义数据源配置 1、加载配置 customer:database1:url: jdbc:mysql://127.0.0.1 XXXusername: rootpassword: rootdriver-class-name: com.mysql.jdbc.Driverconnection-init-sqls: SET NAMES utf8mb4database2:url: jdbc:mysql://127.0.0.1 XXXusername: rootpassword: …

FanoutExchange广播(扇形)交换机

目录 一、简介 二、代码展示 父pom文件 pom文件 配置文件 config 生产者 消费者 测试 结果 一、简介 扇型(广播)交换机,这个交换机没有路由键概念,就算你绑了路由键也是无视的。 这个交换机在接收到消息后,…

探索经典算法问题与解决方案

探索经典算法问题与解决方案 在计算机科学领域,有许多经典算法问题需要我们思考和解决。本文将深入介绍一些著名的经典算法问题,包括旅行商问题、背包问题的变种、N皇后问题、钢条切割问题、最大子数组和问题、最长公共子串问题以及矩阵连乘问题&#x…

Linux目录结构与文件管理(01) (三)

提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档 目录 前言 一、Linux 系统的组成 二、目录结构 根目录 三、文件管理 目录管理 总结 前言 今天主要学习了Linux的目录结构,主要是一些命令的含义和用法&am…

基于Java+SpringBoot+Vue前后端分离工厂车间管理系统设计和实现

博主介绍:✌全网粉丝30W,csdn特邀作者、博客专家、CSDN新星计划导师、Java领域优质创作者,博客之星、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ 🍅文末获取源码联系🍅 👇🏻 精彩专…

vue naive ui 按钮绑定按键

使用vue (naive ui) 绑定Enter 按键 知识点: 按键绑定Button全局挂载使得message,notification, dialog, loadingBar 等NaiveUI 生效UMD方式使用vue 与 naive ui将vue默认的 分隔符大括号 替换 为 [[ ]] <!DOCTYPE html> <html lang"en"> <head>…