RabbitMQ 集群 - 普通集群、镜像集群、仲裁队列

news2025/1/12 8:37:08

目录

一、RabbitMQ 集群

1.1、前言

1.2、普通集群

1.3、镜像集群

1.4、仲裁队列


一、RabbitMQ 集群


1.1、前言

前面我们已经解决了消息可靠性问题,以及延迟消息问题 和 消息堆积问题.

这最后一章,我们就来解决以下 mq 的可用性 和 并发能力.

1.2、普通集群

普通集群,也叫做标准集群(classic cluster),它具备以下特征:

1. 集群中的各个节点是可以共享数据的,比如交换机信息、队列元信息,但不包含队列中的消息.

什么是元信息? 元信息,就是指队列的描述信息,队列名、队列在哪一个节点中,但是不包括消息本身.

不包括消息本身是什么意思? 假设我现在两个节点 mq1 和 mq2,然后有一个消费者订阅了 mq2 中的一个队列,但是呢,这个消费者在访问的时候,不想小心访问到了 mq1,不过由于在 mq1 上持有 mq2 的元信息,所以他知道 mq2 在哪,因此就可以通过这个元数据找到 mq2 这个节点,然后拿到我们想要的数据(这就类似于 mq1 上有 指向 mq2 的指针,通过指针就可以找到 mq2).

2. 基于第一个特点的元信息,我们就可以在访问集群中的某个节点时,发现队列不在该节点,就可以通过要访问数据的所在节点的元信息,进一步的拿到这个节点的所有数据.

这一点上面以及解释的很清楚了.

3. 如果队列所在节点宕机,那么消息就会丢失.

这里有点类似于 redis 集群中的分片处理,每一个集群上存储全集队列的一部分队列,因此这个节点挂了,消息必然会丢失.

1.3、镜像集群

镜像集群,本质上就是主从模式.

主要有以下几个特性:

1.交换机、队列、队列中的消息会在各个mq的镜像节点之间同步备份

这里就和之前的普通交换机不一样了,不仅仅是交换机可以共享,队列中的消息大家也可以共享了.

2. 创建队列的节点被称为该队列的主节点,备份到的其它节点叫做该队列的镜像节点。

比如我现在有三个节点,现在我再 mq1 上创建了一个队列 q1,因此 mq1 就是主节点,那么还可以给他挑一个镜像节点,比如我再 mq2 上做一个镜像,那么 mq2 就会去找 mq1 同步 q1 的所有数据.

3. 一个队列的主节点可能是另一个队列的镜像节点

也就是说,主节点和镜像节点是可以相互备份的.

比如 q1 在 mq1 上,给 mq2 备份了一份,q2 实在 mq2 上,给 mq3 备份了一份,q3 在 mq3 上的,给 mq1 备份了一份,那么这个时候,mq1 就是 q1 的主节点,同时也是 q3 的镜像节点.

4. 所有操作都是主节点完成,然后同步给镜像节点

5.主宕机后,镜像节点会替代成新的主

1.4、仲裁队列

仲裁队列:仲裁队列是3.8版本以后才有的新功能,用来替代镜像队列,具备下列特征:

  1. 与镜像队列一样,都是主从模式,支持主从数据同步
  2. 使用非常简单,没有复杂的配置
  3. 主从同步基于Raft协议,强一致

在 SpringAMQP 中创建仲裁队列:

@Bean
public Queue quorumQueue() {
    return QueueBuilder
            .durable("quorum.queue") // 持久化 
            .quorum() // 仲裁队列
            .build();
}

SpringAMQP连接集群,只需要在yaml中配置即可:

spring:
  rabbitmq:
    addresses: 192.168.150.105:8071, 192.168.150.105:8072, 192.168.150.105:8073
    username: root
    password: 1111
    virtual-host: /

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

企业贸易站官网是HTML模板源码,提供完整源代码

企业贸易站官网是HTML模板源码,提供完整源代码二改的是 为了一起学习所以就分享出来了 有能力的可以自己做成主题配合帝国或者WordPress系统 (访问密码:2971)无需解压密码 源代码:https://url53.ctfile.com/f/20638…

Vue的自定义事件(Custom Events):实现组件间通信的强大工具

Vue的自定义事件(Custom Events):实现组件间通信的强大工具 Vue.js是一款流行的JavaScript框架,用于构建交互式的Web应用程序。在Vue中,组件是构建应用程序的基本单元,它们之间的通信对于构建复杂的应用非…

模拟实现offsrtof

写一个宏,计算结构体中某变量对于首地址的偏移 设计思路: 1.偏移量,用每个所求元素的地址减去结构体初始值的地址可得 2.如计算图示,第一个元素的偏移量结构体初始值必为0,第二个为4,其次为6,…

微信小程序更改AI类目-深度合成-AI绘画/AI问答教程

实测截图 准备材料: 1.营业执照 2.企业公章 一、首先我们需要到百度智能云进行企业认证 https://cloud.baidu.com/ 注册登录后进行企业认证 认证成功后申请千帆大模型平台和AI作画 开通付费服务 开通完以后点击右上角财务 选择合同管理 申请合同 将所有的选…

如何利用Arcgis进行地统计学分析(一):地统计学分析概念及其分析流程

一、地统计分析概念 地统计(Geostatistics)又称地质统计,也可以称为空间统计分析,其是统计学的一个分支。地统计学是以区域化变量理论为基础,以变异函数(variogram)为基本工具来研究分布于空间&…

Python 潮流周刊#21:如何提升及测量 Python 代码的性能?

你好,我是猫哥。这里每周分享优质的 Python、AI 及通用技术内容,大部分为英文。标题取自其中三则分享,不代表全部内容都是该主题,特此声明。 本周刊由 Python猫 出品,精心筛选国内外的 250 信息源,为你挑选…

ruoyi-nbcio增加websocket与测试页面

更多ruoyi-nbcio功能请看演示系统 gitee源代码地址 前后端代码&#xff1a; https://gitee.com/nbacheng/ruoyi-nbcio 为了后面流程发起等消息推送&#xff0c;所以需要集成websocket。 1、后端增加websoket支持 首先在framework模块里的pom.xml增加websocket <dependency…

肖sir__项目实战讲解__004

项目实战讲解 一、项目的类型 金融类&#xff1a; 保险(健康险理财险)、证券、基金(股票型基金、混合型基金、指数型基金、债券型基金、 天天基金网&#xff08;ETF基金、货币型基金、量化基金)、银行、贷款、信用卡、外汇、二元期权、期货原油、blockchain、 数字货币、黄金白…

Nginx环境搭建、负载均衡测试

Nginx环境搭建、负载均衡测试 系统环境&#xff1a; win10&#xff0c;IDEA2020&#xff0c;JDK8 一、nginx环境搭建 1.ngxin下载 Nginx官网下载&#xff1a; http://nginx.org/en/download.html Nginx有三种版本&#xff0c;分别是Mainline version&#xff08;开发版&…

Vue load 页面报错:Error: Request failed with status code 404 ###createError.js

vue 项目 npm run dev 之后一切正常 在打开页面 http://localhost:8080/ 的时候后台报错 Error: Request failed with status code 404 at createError (\node_modules\axios\lib\core\createError.js) 网上各种查找原因&#xff0c;说是后台接口对接跨域问题&#xff0c;但…

C++——list

作者&#xff1a;几冬雪来 时间&#xff1a;2023年9月24日 内容&#xff1a;C板块list知识讲解 目录 前言&#xff1a; 什么是list&#xff1a; 遍历list&#xff1a; insert&#xff1a; find&#xff1a; insert与erase&#xff1a; merge&#xff1a; unique&am…

TLS/SSL(十) session缓存、ticket 票据、TLS 1.3的0-RTT

一 TLS优化手段 TLS 为了提升握手速度而提出优化手段,主要是减少TLS握手中RTT消耗的时间关于session cache和session ticket,nginx关于ssl握手的地方都有影子 [指令] https面经 ① session 缓存 resume: 重用,复用 案例&#xff1a; 第二次访问www.baidu.com 说明&#x…

Linux-多路转接-epoll

epoll 接口认识epoll_createepoll_ctlepoll_wait epoll工作原理在内核中创建的数据结构epoll模型的一个完整工作流程 epoll工作模式LT-水平触发ET-边缘触发两种方式的对比 epoll的使用场景对于poll的改进惊群效应什么是惊群效应如何解决惊群效应原子操作/mutex/spinlock如何选择…

数据结构(java)--队列1

一、我们还是依旧引入一个小例子&#xff08;银行排队&#xff09;&#xff1a; 需要取号排队&#xff0c;服务完下一个 二、队列介绍 1&#xff09;队列是一个有序列表&#xff0c;可以用数组或是链表来实现 2&#xff09;遵循先入先出的原则。即&#xff1a;先存入队列的数…

世界前沿技术发展报告2023《世界信息技术发展报告》(三)量子信息技术

&#xff08;三&#xff09;量子信息技术 1. 概述2. 量子计算2.1 阿里巴巴达摩院成功研制两比特量子芯片&#xff0c;单比特操控精度超99.97%2.2 加拿大Xanadu公司开发出可编程光量子计算机2.3 美国英伟达公司为经典-量子混合计算推出开发架构2.4 日本国家自然科学研究所开发出…

el-tree实现菜单功能

用到element tree组件&#xff0c;需要了解他的一些方法 <template><div><!-- default-expand-all 默认展开全部数据 --><!-- expand-on-click-node 只有点击箭头才会收缩节点 --><!-- check-on-click-node 点击文本选中 --><!-- show-check…

cadence - 在allegro中出报告(Padstack Usage Report)来辅助制作orcad原理图封装

文章目录 cadence - 在allegro中出报告(Padstack Usage Report)来辅助制作orcad原理图封装概述笔记做PCB封装出报告 - Padstack Usage Report做原理图封装END cadence - 在allegro中出报告(Padstack Usage Report)来辅助制作orcad原理图封装 概述 现在做封装, 还是手工弄. 在…

1 MySQL 高级(进阶) SQL 语句(一)

目录 1 MySQL SQL 语句 1.1SELECT 1.2 DISTINCT 1.3 WHERE 1.4 AND OR 1.5 in 1.6 BETWEEN 2 通配符 ----通常通配符都是跟 LIKE 一起使用的 2.1 LIKE 2.2 ORDER BY 3函数 3.1数学函数 3.2 聚合函数 3.3 字符串函数 4 GROUP BY 4.1 HAVING 5 别名 6 子查询 …

《开发实战》17 | 异步处理好用,但非常容易用错

大多数业务项目都是由同步处理、异步处理和定时任务处理三种模式相辅相成实现的。区别于同步处理&#xff0c;异步处理无需同步等待流程处理完毕&#xff0c;因此适用场景主要包括&#xff1a; 服务于主流程的分支流程。比如&#xff0c;在注册流程中&#xff0c;把数据写入数…

基于微信小程序的健身私教预约系统设计与实现(开题报告+任务书+源码+lw+ppt +部署文档+讲解)

文章目录 前言运行环境说明用户微信小程序端主要功能有&#xff1a;教练微信小程序的主要功能有&#xff1a;管理员的主要功能有&#xff1a;具体实现截图详细视频演示为什么选择我自己的网站自己的小程序&#xff08;小蔡coding&#xff09;有保障的售后福利 代码参考论文参考…