RabbitMQ常见问题之高可用

文章目录

  • 一、集群分类
  • 二、普通集群搭建
      • 1. 准备
      • 2. 配置
      • 3. 运行
  • 三、镜像集群
      • 1. 介绍
      • 2. 启用方式
      • 3. 测试
  • 四、仲裁队列
      • 1. 介绍
      • 2. 创建
  • 五、Java连接RabbitMQ集群方式

一、集群分类

RabbitMQ的是基于Erlang语言编写,而Erlang又是一个面向并发的语言,天然支持集群模式。RabbitMQ的集群有两
种模式：

  • 普通集群：是一种分布式集群，将队列分散到集群的各个节点，从而提高整个集群的并发能力。
  • 镜像集群：是一种主从集群，普通集群的基础上，添加了主从备份功能，提高集群的数据可用性。

镜像集群虽然支持主从,但主从同步并不是强一致的,某些情况下可能有数据丢失的风险。因此在RabbitMQ的3.8版本
以后,推出了新的功能——仲裁队列来代替镜像集群,底层采用Raft协议确保主从的数据一致性。

二、普通集群搭建

在这里插入图片描述

1. 准备

建立如下文件夹结构

./cluster/
├── docker-compose.yml
├── mq1
│   ├── .erlang.cookie
│   └── conf
│       └── rabbitmq.conf
├── mq2
│   ├── .erlang.cookie
│   └── conf
│       └── rabbitmq.conf
└── mq3├── .erlang.cookie└── conf└── rabbitmq.conf

2. 配置

rabbitmq.conf都写入以下内容

loopback_users.guest = false
listeners.tcp.default = 5672
cluster_formation.peer_discovery_backend = rabbit_peer_discovery_classic_config
cluster_formation.classic_config.nodes.1 = rabbit@mq1
cluster_formation.classic_config.nodes.2 = rabbit@mq2
cluster_formation.classic_config.nodes.3 = rabbit@mq3
vm_memory_high_watermark.absolute = 524288000

.erlang.cookie都写入以下内容

SUGWXEQPRCPYJAVYPNZY

集群的所有节点的.erlang.cookie需要保持一致才能互相信任，具体内容并不固定，可以随便新建一个rabbitmq容器去查看其.erlang.cookie然后复制使用即可。

docker-compose.yml写入以下内容

version: "3.8"networks:rabbitmq-normal-cluster:driver: bridgeipam:driver: defaultconfig:- subnet: 172.30.3.0/24services:mq1:container_name: mq1hostname: mq1image: rabbitmq:3-managementenvironment:- RABBITMQ_DEFAULT_USER=rabbitmq- RABBITMQ_DEFAULT_PASS=rabbitmqvolumes:- ./mq1/conf/rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf- ./mq1/.erlang.cookie:/var/lib/rabbitmq/.erlang.cookie:roports:- "8071:5672"- "8081:15672"networks:rabbitmq-normal-cluster:ipv4_address: 172.30.3.11mq2:container_name: mq2hostname: mq2image: rabbitmq:3-managementenvironment:- RABBITMQ_DEFAULT_USER=rabbitmq- RABBITMQ_DEFAULT_PASS=rabbitmqvolumes:- ./mq2/conf/rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf- ./mq2/.erlang.cookie:/var/lib/rabbitmq/.erlang.cookie:roports:- "8072:5672"- "8082:15672"networks:rabbitmq-normal-cluster:ipv4_address: 172.30.3.12mq3:container_name: mq3hostname: mq3image: rabbitmq:3-managementenvironment:- RABBITMQ_DEFAULT_USER=rabbitmq- RABBITMQ_DEFAULT_PASS=rabbitmqvolumes:- ./mq3/conf/rabbitmq.conf:/etc/rabbitmq/rabbitmq.conf- ./mq3/.erlang.cookie:/var/lib/rabbitmq/.erlang.cookie:roports:- "8073:5672"- "8083:15672"networks:rabbitmq-normal-cluster:ipv4_address: 172.30.3.13

3. 运行

docker-compose -p rabbitmq-c up -d

在这里插入图片描述

三、镜像集群

1. 介绍

在这里插入图片描述
镜像模式的配置有3种模式：

ha-modeha-params效果
准确模式exactly队列的副本量count集群中队列副本（主服务器和镜像服务器之和）的数量。count如果为1意味着单个副本：即队列主节点。count值为2表示2个副本：1个队列主和1个队列镜像。换句话说：count = 镜像数量 + 1。如果群集中的节点数少于count，则该队列将镜像到所有节点。如果有集群总数大于count+1，并且包含镜像的节点出现故障，则将在另一个节点上创建一个新的镜像。
all(none)队列在群集中的所有节点之间进行镜像。队列将镜像到任何新加入的节点。镜像到所有节点将对所有群集节点施加额外的压力，包括网络I / O，磁盘I / O和磁盘空间使用情况。推荐使用exactly，设置副本数为（N / 2 +1）。
nodesnode names指定队列创建到哪些节点，如果指定的节点全部不存在，则会出现异常。如果指定的节点在集群中存在，但是暂时不可用，会创建节点到当前客户端连接到的节点。

2. 启用方式

三种模式启动方式分别如下，基于普通集群之上，命令均需要在单个容器内部执行。

rabbitmqctl set_policy ha-two "^two\." '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'

在这里插入图片描述

rabbitmqctl set_policy ha-all "^all\." '{"ha-mode":"all"}'

在这里插入图片描述

rabbitmqctl set_policy ha-nodes "^nodes\." '{"ha-mode":"nodes","ha-params":["rabbit@nodeA", "rabbit@nodeB"]}'

在这里插入图片描述

3. 测试

这里以exactly为例，在mq1中执行rabbitmqctl set_policy ha-two "^two\." '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'后，所有前缀为two的queue都会有1个主queue和1个副本。

root@mq1:/# rabbitmqctl set_policy ha-two "^two\." '{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}'
Setting policy "ha-two" for pattern "^two\." to "{"ha-mode":"exactly","ha-params":2,"ha-sync-mode":"automatic"}" with priority "0" for vhost "/" ...
root@mq1:/#

来到localhost:8081管理页，找到admin->policies可以看到策略生效。
在这里插入图片描述
来新建一个two.test.queue，可以看到这是一个拥有副本的queue。
在这里插入图片描述
在这里插入图片描述

四、仲裁队列

1. 介绍

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

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

上一章中想要一个镜像队列还要执行各种命令，遵循规定，现在不用了。

2. 创建

在这里插入图片描述
java使用目前只能基于@Bean创建

    @Beanpublic Queue quorumQueue(){return QueueBuilder.durable("quorum.queue2").quorum().build();}

五、Java连接RabbitMQ集群方式

Java使用RabbitMQ集群application.yml中需要修改address

spring:rabbitmq:host: localhost # rabbitMQ的ip地址port: 5672 # 端口

spring:rabbitmq:addresses: localhost:8071, localhost:8072, localhost:8073

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

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

相关文章

vue3实现动态侧边菜单栏的几种方式总结

vue3实现动态侧边菜单栏的几种方式总结

基于自建json数据的动态侧边菜单栏 后端接口json数据 src/api/menuList.js const menuList [{url: ,name: 人员管理,icon: icon-renyuan,menuId: 1,children: [{url: /user,name: 用户管理,icon: icon-jurassic_user,menuId: 1001,children: []},{url: /role,name: 角色管…
阅读更多...
vite 打包优化

vite 打包优化

✨专栏介绍 在当今数字化时代，Web应用程序已经成为了人们生活和工作中不可或缺的一部分。而要构建出令人印象深刻且功能强大的Web应用程序，就需要掌握一系列前端技术。前端技术涵盖了HTML、CSS和JavaScript等核心技术，以及各种框架、库和工具…
阅读更多...
一篇综述洞悉医学大型语言模型的原理，应用和挑战

一篇综述洞悉医学大型语言模型的原理，应用和挑战

在过去的一年中，随着 GPT-4、LLaMA、Mistral，PaLM 等先进技术的突飞猛进，大型语言模型（Large Language Models）已经引领全球人工智能进入了一个全新的基础模型时代，这一时代不仅开启了技术创新的新篇章&…
阅读更多...
opencv多张图片实现全景拼接

opencv多张图片实现全景拼接

最近camera项目需要用到全景拼接，故此查阅大量资料，终于将此功能应用在实际项目上，下面总结一下此过程中遇到的一些问题及解决方式，同时也会将源码附在结尾处，供大家参考，本文采用的opencv版本为3.4.12。 首…
阅读更多...
Base64编码原理解析

Base64编码原理解析

文章目录 一、Base64Base64编码的原理如下：以字符串"hello world"为例，它的ASCII码为（下面👇是ASCII码对照表）：将这些ASCII码转换为二进制（对照上表）：将上述二…
阅读更多...
Pyside6入门教学——编写一个UI界面并显示

Pyside6入门教学——编写一个UI界面并显示

1、安装Pyside6 输入下列命令安装Pyside6。 pip install Pyside6 2、设计UI 打开Qt设计工具（在安装Pyside6包的目录下）。 【注】我这用的是anaconda虚拟环境，所以我的路径是D:\App\Anaconda3\envs\snake\Lib\site-packages\PySide6。设计…
阅读更多...
前端（html+css+javascript）作业--展现家乡的网页

前端（html+css+javascript）作业--展现家乡的网页

期末期间，老师布置了前端作业，现在放到这里，给各位同志参考。 桂平市是广西壮族自治区的一个美丽的城市，拥有丰富的历史文化和自然景观，属于贵港市管辖，那为什么是看起来是市级而不是县级，其实他…
阅读更多...
GaussDB(DWS)查询优化技术大揭秘

GaussDB(DWS)查询优化技术大揭秘

GaussDB(DWS)查询优化技术大揭秘 大数据时代，数据量呈爆发式增长，经常面临百亿、千亿数据查询场景，当数据仓库数据量较大、SQL语句执行效率低时，数据仓库性能会受到影响。本文将深入讲解在GaussDB(DWS)中如何进行表结构设计&#…
阅读更多...
uni-app 经验分享，从入门到离职（年度实战总结:经验篇）——上传图片以及小程序隐私保护指引设置

uni-app 经验分享，从入门到离职（年度实战总结:经验篇）——上传图片以及小程序隐私保护指引设置

文章目录 🔥年度征文📋前言⏬关于专栏 🎯关于上传图片需求🎯前置知识点和示例代码🧩uni.chooseImage()🧩uni.chooseMedia()📌uni.chooseImage() 与 uni.chooseMedia() 🧩uni.chooseF…
阅读更多...
5D动感影院新奇体验丰富环境特效7D互动影院

5D动感影院新奇体验丰富环境特效7D互动影院

5D动感影院太火啦！凭借真实互动感、全视景高清屏幕、立体环绕音效、D打造新颖沉浸式观影体验，成为年轻人/家长/小朋友的新晋打卡聚集地，时刻上演着精彩绝伦的视觉盛宴！ 1、5D动感影院【硬件组成】：动感平台、金属银幕、…
阅读更多...
Alinx ZYNQ 7020 LED调试--in RAM

Alinx ZYNQ 7020 LED调试--in RAM

设置拨码开关为JTAG方式 烧写LED bit stream a. 点击“Program device”烧录程序到FPGA中（重新上电程序就丢失了） b. /01_led/led.runs/impl_1/led.bit 程序烧录到Flash中 ZYNQ与以往的直接烧录Flash不同，首先必须PS，然后烧…
阅读更多...
PXE和kickstart无人值守安装

PXE和kickstart无人值守安装

PXE高效批量网络装机 引言 1.系统装机的引导方式 启动 操作 系统 1.硬盘 2.光驱（u盘） 3.网络启动 pxe 重装系统？ 在已有操作系统 新到货了一台服务器， 装操作系统 系统镜像 u盘 光盘 pe： 小型的 操作系统 在操…
阅读更多...
HTTP/HTTPS代理IP在多线程爬虫项目中的实践

HTTP/HTTPS代理IP在多线程爬虫项目中的实践

在多线程爬虫项目中，HTTP/HTTPS代理IP的实践主要包括以下几个关键步骤： 1. 收集代理IP资源： - 从免费或付费代理IP提供商、公开代理列表网站（如西刺代理、无忧代理等）抓取代理IP和端口信息。 - 存储这些IP到数据库或者…
阅读更多...
统计学-R语言-5.3

统计学-R语言-5.3

文章目录 前言分位数统计量的标准误总结 前言 本篇文章即为概率与分布的最后一篇文章。 分位数 分位数函数是累积分布函数的反函数。 p-分位数是具有这样性质的一个值：小于或等于它的概率为p。 根据定义，中位数即50%分位数。 分位数通常用于置信区间的…
阅读更多...
RT-Thread 15. list_timer与软定时器

RT-Thread 15. list_timer与软定时器

1. 代码 void rt_thread_usr1_entry(void *parameter) {/* set LED2 pin mode to output */rt_pin_mode(LED2_PIN, PIN_MODE_OUTPUT);while (1){rt_pin_write(LED2_PIN, PIN_HIGH);rt_thread_mdelay(2000);rt_pin_write(LED2_PIN, PIN_LOW);rt_thread_mdelay(3000);} }int ma…
阅读更多...
前端公共组件库优化

前端公共组件库优化

背景 前段时间入职了新公司后，做一些内部前端基建的工作，其中一个工作就是优化现有的frontend-common公共组件库。之前的组件库一直是以源码依赖的形式存在，即各个项目通过git submodule的方式将该仓库引入到各个项目中，作为一个…
阅读更多...
【K8S 云原生】K8S的对外服务—ingress

【K8S 云原生】K8S的对外服务—ingress

目录 一、K8S的Service 1、Service的作用 2、Service类型： 二、ingress 1、ingress的组成： 2、ingress资源的定义项： 3、ingress暴露服务端的方式 3.1、DeploymentLoadBalancer模式： 1、工作流程图： 3.2、Dae…
阅读更多...
PDF转PowerPoint - Java实现方法

PDF转PowerPoint - Java实现方法

通过编程实现PDF转PPT的功能，可以自动化转换过程，减少手动操作的工作量，并根据需要进行批量转换。将PDF文件转换为PPT文档后，可以利用PPT的丰富功能和动画效果，达到更好的演示效果。 在Java中，我们可以使用…
阅读更多...
PyTorch损失函数（二）

PyTorch损失函数（二）

损失函数 5、nn.L1Loss nn.L1Loss是一个用于计算输入和目标之间差异的损失函数，它计算输入和目标之间的绝对值差异。 主要参数： reduction：计算模式，可以是none、sum或mean。 none：逐个元素计算损失，返…
阅读更多...
清晰光谱空间：全自动可调波长系统的高光谱成像优势

清晰光谱空间：全自动可调波长系统的高光谱成像优势

高光谱成像技术 高光谱成像技术是一种捕获和分析宽波长信息的技术，能够对材料和特征进行详细的光谱分析和识别。高光谱成像技术的实现通过高光谱相机，其工作原理是使用多个光学传感器或光学滤波器分离不同波长的光，并捕获每个波段的图像&…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023