RabbitMQ（六）仲裁队列、流式队列、异地容灾（联邦队列Federation Queue）

文章目录

  • 仲裁队列
    • 1、创建交换机
    • 2、创建仲裁队列
    • 3、验证
    • 主节点宕机不影响消息发送和接收
  • 流式队列（不推荐，Kafka主场）
    • 概念
  • 异地容灾
  • 一、Federation插件
      • 概述
  • 二、Federation交换机
    • 1、总体说明
    • 2、准备工作
    • 3、启用联邦插件
    • 4、添加上游连接端点
    • 5、创建控制策略
    • 6、测试
      • 测试计划
      • 创建组件
      • 发布消息执行测试
  • 三、Federation队列
    • 1、总体说明
    • 2、创建控制策略
    • 3、测试
      • 测试计划
      • 创建组件
    • 执行测试

仲裁队列

https://www.rabbitmq.com/docs/quorum-queues

1、创建交换机

和仲裁队列绑定的交换机没有特殊，我们还是创建一个direct交换机即可
交换机名称：exchange.quorum.test
在这里插入图片描述

2、创建仲裁队列

队列名称：queue.quorum.test
经典队列类型为Classic
在这里插入图片描述
点击队列名称查看详细信息
在这里插入图片描述
绑定交换机
在这里插入图片描述

3、验证

// 测试是否成功绑定
@SpringBootTest
public class RabbitMQTest {public static final String EXCHANGE_QUORUM_TEST = "exchange.quorum.test";public static final String ROUTING_KEY_QUORUM_TEST = "routing.key.quorum.test";@Resourceprivate RabbitTemplate rabbitTemplate;@Testpublic void testSendMessageToQuorum() {rabbitTemplate.convertAndSend(EXCHANGE_QUORUM_TEST, ROUTING_KEY_QUORUM_TEST, "message test quorum ~~~ @@@");}
}

在这里插入图片描述
基础配置参考

@Component
@Slf4j
public class MyProcessor {public static final String QUEUE_QUORUM_TEST = "queue.quorum.test";@RabbitListener(queues = {QUEUE_QUORUM_TEST})public void quorumMessageProcess(String data, Message message, Channel channel) throws IOException {log.info("消费端：" + data);channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);}}

主节点宕机不影响消息发送和接收

流式队列（不推荐，Kafka主场）

概念

在这里插入图片描述

  • 从客户端支持角度来说，生态尚不健全
  • 从使用习惯角度来说，和原有队列用法不完全兼容
  • 从竞品角度来说，像Kafka但远远比不上Kafka
  • 从应用场景角度来说：
  • 经典队列：适用于系统内部异步通信场景
  • 流式队列：适用于系统间跨平台、大流量、实时计算场景（Kafka主场）
  • 使用建议：Stream队列在目前企业实际应用非常少，真有特定场景需要使用肯定会倾向于使用Kafka，而不是RabbitMQ Stream
  • 未来展望：Classic Queue已经有和Quorum Queue合二为一的趋势，Stream也有加入进来整合成一种队列的趋势，但Stream内部机制决定这很
    难

异地容灾

Disaster Recovery at a Different Location

  • Federation插件
  • Shovel插件

概述：是通过配置联邦交换机拉取上游节点消息，关于联邦交换机的配置都在下游节点配置upstream，上游节点为常规配置

一、Federation插件

官方链接：
Federation Plugin：https://www.rabbitmq.com/docs/federation
Federated-exchanges：https://www.rabbitmq.com/docs/federated-exchanges

概述

Federation插件的设计目标是使RabbitMQ在不同的Broker节点之间进行消息传递而无须建立集群。

它可以在不同的管理域中的Broker或集群间传递消息，这些管理域可能设置了不同的用户和vhost，也可能运行在不同版本的RabbitMQ和Erlang上。Federation基于AMQP 0-9-1协议在不同的Broker之间进行通信，并且设计成能够容忍不稳定的网络连接情况。
在这里插入图片描述

二、Federation交换机

1、总体说明

  • 各节点操作：启用联邦插件
  • 下游操作：
    • 添加上游连接端点
    • 创建控制策略

2、准备工作

为了执行相关测试，我们使用Docker创建两个RabbitMQ实例。

特别提示：由于Federation机制的最大特点就是跨集群同步数据，所以这两个Docker容器中的RabbitMQ实例不加入集群！！！是两个独立的broker实例。

docker run -d \
--name rabbitmq-shenzhen \
-p 51000:5672 \
-p 52000:15672 \
-v rabbitmq-plugin:/plugins \
-e RABBITMQ_DEFAULT_USER=guest \
-e RABBITMQ_DEFAULT_PASS=123456 \
rabbitmq:3.13-managementdocker run -d \
--name rabbitmq-shanghai \
-p 61000:5672 \
-p 62000:15672 \
-v rabbitmq-plugin:/plugins \
-e RABBITMQ_DEFAULT_USER=guest \
-e RABBITMQ_DEFAULT_PASS=123456 \
rabbitmq:3.13-management

使用

docker ps

在这里插入图片描述

3、启用联邦插件

在上游、下游节点中都需要开启。

Docker容器中的RabbitMQ已经开启了rabbitmq_federation，还需要开启rabbitmq_federation_management

rabbitmq-plugins enable rabbitmq_federation
rabbitmq-plugins enable rabbitmq_federation_management

rabbitmq_federation_management插件启用后会在Management UI的Admin选项卡下看到：
在这里插入图片描述

4、添加上游连接端点

在下游节点填写上游节点的连接信息：

# # 
amqp://guest:123456@192.168.217.134:51000

在这里插入图片描述
添加后
在这里插入图片描述

5、创建控制策略

在这里插入图片描述
在这里插入图片描述

6、测试

测试计划

特别提示

  • 普通交换机和联邦交换机名称要一致
  • 交换机名称要能够和策略正则表达式匹配上
  • 发送消息时，两边使用的路由键也要一致
  • 队列名称不要求一致
    在这里插入图片描述

创建组件

交换机名称和路由建键相同，队列名称可不同

所在机房交换机名称路由键队列名称
深圳机房（上游）federated.exchange.demorouting.key.demo.testqueue.normal.shenzhen
上海机房（下游）federated.exchange.demorouting.key.demo.testqueue.normal.shanghai

创建组件后可以查看一下联邦状态，连接成功的联邦状态如下：
查看状态
在这里插入图片描述

发布消息执行测试

在上游节点向交换机发布消息：
在这里插入图片描述
上游
在这里插入图片描述
下游在这里插入图片描述

三、Federation队列

1、总体说明

Federation队列和Federation交换机的最核心区别就是：

  • Federation Police作用在交换机上，就是Federation交换机
  • Federation Police作用在队列上，就是Federation队列

2、创建控制策略

queue.federation
^fed.queue.

3、测试

测试计划

上游节点和下游节点中队列名称是相同的，只是下游队列中的节点附加了联邦策略而已

所在机房交换机路由键队列
深圳机房（上游）exchange.normal.shenzhenrouting.key.normal.shenzhenfed.queue.demo
上海机房（下游）————fed.queue.demo

创建组件

上游节点都是常规操作，此处省略。重点需要关注的是下游节点的联邦队列创建时需要指定相关参数：

创建组件后可以查看一下联邦状态，连接成功的联邦状态如下：
在这里插入图片描述

执行测试

在上游节点向交换机发布消息：
在这里插入图片描述
注意：
但此时发现下游节点中联邦队列并没有接收到消息，这是为什么呢？这里就体现出了联邦队列和联邦交换机工作逻辑的区别。

对联邦队列来说，如果没有监听联邦队列的消费端程序，它是不会到上游去拉取消息的！

如果有消费端监听联邦队列，那么首先消费联邦队列自身的消息；如果联邦队列为空，这时候才会到上游队列节点中拉取消息。

所以现在的测试效果需要消费端程序配合才能看到：
在这里插入图片描述
消费端配置
application.yml

spring:rabbitmq:host: 192.168.217.134port: 61000username: guestpassword: 123456virtual-host: /listener:simple:acknowledge-mode: manual # 把消息确认模式改为手动确认

消费端

@Component
@Slf4j
public class MyMessageListener {public static final String QUEUE_NAME = "fed.queue.demo";@RabbitListener(queues = {QUEUE_NAME})public void processMessage(String dataString, Message message, Channel channel) throws IOException {log.info("[Federation]" + dataString);channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);}}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/355244.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【深度学习】TCN，An Empirical Evaluation of Generic Convolutional【二】

【深度学习】TCN，An Empirical Evaluation of Generic Convolutional【二】

文章目录 膨胀卷积什么是膨胀卷积膨胀卷积公式PyTorch代码 从零开始手动实现一个1D膨胀卷积，不使用PyTorch的nn.Conv1d1. 基本概念2. 手动实现1D膨胀卷积 TCN结构如何使用TCN源码说明1. Chomp1d 类2. TemporalBlock 类3. TemporalConvNet 类 使用方法 膨胀卷积 什么…
阅读更多...
DVWA - Brute Force

DVWA - Brute Force

DVWA - Brute Force 等级：low ​ 直接上bp弱口令爆破，设置变量，攻击类型最后一个，payload为用户名、密码简单列表 ​ 直接run，长度排序下，不一样的就是正确的用户名和密码 ​ 另解： 看一下…
阅读更多...
【SpringBoot + Vue 尚庭公寓实战】公寓杂费接口实现（八）

【SpringBoot + Vue 尚庭公寓实战】公寓杂费接口实现（八）

【SpringBoot Vue 尚庭公寓实战】公寓杂费接口实现（八） 文章目录 【SpringBoot Vue 尚庭公寓实战】公寓杂费接口实现（八）1、公寓杂费业务介绍2、公寓杂费逻辑模型介绍3、接口实现3.1、保存或更新杂费值3.2、保存或更新杂费名称3…
阅读更多...
Android【SDK】 SDK是如何开发的，怎么打包aar包

Android【SDK】 SDK是如何开发的，怎么打包aar包

文章目录 一、Android SDK开发示例工程二、Android SDK的开发三、打包aar包四、Android SDK的使用 一、Android SDK开发示例工程 本教程工程Git链接：https://gitcode.com/xiaohuihui1400/AndroidSdkExample/overview 二、Android SDK的开发 新建项目，…
阅读更多...
Photoshop中图像美化工具的应用

Photoshop中图像美化工具的应用

Photoshop中图像美化工具的应用 Photoshop中的裁剪工具Photoshop中的修饰工具模糊工具锐化工具涂抹工具 Photoshop中的颜色调整工具减淡工具加深工具海绵工具 Photoshop中的修复工具仿制图章工具污点修复画笔工具修复画笔工具修补工具内容感知移动工具红眼工具 Photoshop中的裁…
阅读更多...
Redis持久化主从哨兵分片集群

Redis持久化主从哨兵分片集群

文章目录 1. 单点Redis的问题数据丢失问题并发能力问题故障恢复问题存储能力问题 2. Redis持久化 -> 数据丢失问题RDB持久化linux单机安装Redis步骤RDB持久化与恢复示例RDB机制RDB配置示例RDB的fork原理总结 AOF持久化AOF配置示例AOF文件重写RDB与AOF对比 3. Redis主从 ->…
阅读更多...
智能制造uwb高精度定位系统模块，飞睿智能3厘米定位测距芯片，无人机高速传输

智能制造uwb高精度定位系统模块，飞睿智能3厘米定位测距芯片，无人机高速传输

在科技日新月异的今天，定位技术已经渗透到我们生活的方方面面。从手机导航到自动驾驶，再到无人机定位，都离不开精准的定位系统。然而，随着应用场景的不断拓展，传统的定位技术如GPS、WiFi定位等，因其定位精度…
阅读更多...
小摩法兴纷纷转多，看涨港股的时机来了吗？

小摩法兴纷纷转多，看涨港股的时机来了吗？

恒生指数今日高开一度上涨89点报18520点，创近两周高。之后持续震荡下行；恒指临近中 午跌幅扩大，恒生科技指数一度跌近1.5%。截止收盘，恒生指数跌0.52%，盘面上，石油、煤炭、环保、建筑节能等板块涨幅居前&a…
阅读更多...
VScode中js关闭烦人的ts检查

VScode中js关闭烦人的ts检查

类似如下的代码在vscode 会报错，我们可以在前面添加忽略检查或者错误，如下： 但是！！！这太不优雅了！！！，js代码命名没有问题，错在ts上面，…
阅读更多...
112、路径总和

112、路径总和

给你二叉树的根节点 root 和一个表示目标和的整数 targetSum 。判断该树中是否存在 根节点到叶子节点 的路径，这条路径上所有节点值相加等于目标和 targetSum 。如果存在，返回 true ；否则，返回 false 。 叶子节点 是指没有子节点…
阅读更多...
简单且高效的水域物探轨迹坐标转换程序

简单且高效的水域物探轨迹坐标转换程序

简单且高效的水域物探轨迹坐标转换程序 前言 水上测线的高精度定位是水域物探的难题，水域磁法、水域地震实施时常采用船舶拖拽传感器进行走航式观测，GPS仪器放在船舶上测量，造成船舶位置与传感器位置存在偏差，后期资料整理需要校…
阅读更多...
QT-QPainter实现一个可切换的开关控件

QT-QPainter实现一个可切换的开关控件

1、效果 2、核心代码 #ifndef SWITCH_H #define SWITCH_H #include <QWidget> #include <QTimer>
阅读更多...
Javase.String 类

Javase.String 类

String 类 【本节目标】1. String类的重要性2. 常用方法2.1 字符串构造2.2 String对象的比较2.3 字符串查找2.4 转化2.5 字符串替换2.7 字符串截取2.8 其他操作方法2.9 字符串的不可变性2.10 字符串修改 3. StringBuilder和StringBuffer3.2 面试题&#xff1a; 4. String类oj4.…
阅读更多...
【MySQL】 -- 用户管理

【MySQL】 -- 用户管理

1. 权限 如果我们只能使用root用户&#xff0c;这样存在安全隐患。这时&#xff0c;就需要使用MySQL的用户管理。创建出非root用户&#xff0c;限制其权限。 权限这个概念拿出来就是用来限制非root用户的。这样从技术手段上保证了数据的安全性和完整性&#xff0c;防止有人删库…
阅读更多...
【SAP Abap】一条SQL语句实现支持报表项配置的财务报表

【SAP Abap】一条SQL语句实现支持报表项配置的财务报表

【SAP Abap】一条SQL语句实现支持报表项配置的财务报表 1、业务背景2、配置项特殊处理3、实现方式&#xff08;Hana Studio SQL语句&#xff09;4、实现方式&#xff08;Abap OpenSQL语句&#xff09;5、总结 1、业务背景 在财务三大报表之外&#xff0c;业务需要使用类似的科…
阅读更多...
数据库复习——模式分解

数据库复习——模式分解

模式分解这边主要包括无损分解和保持函数依赖的分解两种形式&#xff0c;简单整理一下。 无损分解 把一个 R R R 分成 ρ { R 1 , R 2 , ⋯ , R k } \rho \{R_1,R_2,\cdots,R_k\} ρ{R1​,R2​,⋯,Rk​}&#xff0c;然后通过自然连接 R 1 ⋈ R 2 ⋈ ⋯ ⋈ R k R_1\bowtie R…
阅读更多...
git的远程管理与标签管理

git的远程管理与标签管理

✨前言✨ &#x1f4d8; 博客主页&#xff1a;to Keep博客主页 &#x1f646;欢迎关注&#xff0c;&#x1f44d;点赞&#xff0c;&#x1f4dd;留言评论 ⏳首发时间&#xff1a;2024年6月20日 &#x1f4e8; 博主码云地址&#xff1a;博主码云地址 &#x1f4d5;参考书籍&…
阅读更多...
swift使用swift-protobuf协议通讯，使用指北

swift使用swift-protobuf协议通讯，使用指北

什么是Protobuf Protobuf&#xff08;Protocol Buffers&#xff09;协议&#x1f609; Protobuf 是一种由 Google 开发的二进制序列化格式和相关的技术&#xff0c;它用于高效地序列化和反序列化结构化数据&#xff0c;通常用于网络通信、数据存储等场景。 为什么要使用Proto…
阅读更多...
【python】Sklearn—Cluster

【python】Sklearn—Cluster

参考学习来自 10种聚类算法的完整python操作示例 文章目录 聚类数据集亲和力传播——AffinityPropagation聚合聚类——AgglomerationClusteringBIRCH——Birch&#xff08;✔&#xff09;DBSCAN——DBSCANK均值——KMeansMini-Batch K-均值——MiniBatchKMeans均值漂移聚类——…
阅读更多...
MySQL之复制(七)

MySQL之复制(七)

复制 定制的复制方案 分离功能 许多应用都混合了在线事务处理(OLTP)和在线数据分析(OLAP)的查询。OLTP查询比较短并且是事务型的。OLAP查询则通常很大&#xff0c;也很慢&#xff0c;并且不要求绝对最新的数据。这两种查询给服务器带来的负担完全不同&#xff0c;因此它们需…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023