RabbitMQ集群搭建和测试总结_亲测

RabbiMQ简介

RabbitMQ是用Erlang开发的，集群非常方便，因为Erlang天生就是一门分布式语言，但其本身并不支持负载均衡。

RabbitMQ模式

RabbitMQ模式大概分为以下三种:
(1)单一模式。
(2)普通模式(默认的集群模式)。
(3)镜像模式(把需要的队列做成镜像队列，存在于多个节点，属于RabbitMQ的HA方案，在对业务可靠性要求较高的场合中比较适用)。
要实现镜像模式，需要先搭建一个普通集群模式，在这个模式的基础上再配置镜像模式以实现高可用。

RabbitMQ特点

RabbitMQ的集群节点包括:内存节点、磁盘节点。RabbitMQ支持消息的持久化
也就是数据写在磁盘上，最合适的方案就是既有内存节点，又有磁盘节点。

节点环境

192.168.1.17 rabbitmq3 内存节点
192.168.1.18 rabbitmq2 内存节点
192.168.1.19 rabbitmq1 磁盘节点

注意: RabbitMQ集群节点必须在同一网段里，如果是跨广域网，效果会变差。

RabbitMQ普通集群配置

配置hosts文件

更改三台MQ节点的计算机名分别为rabbitmq1、rabbitmq2 和rabbitmq3，然后修改hosts配置文件

#查看主机名
hostname#修改主机名
hostnamectl set-hostname rabbitmq1#或者
vim /etc/hostname    //其他两台相同
rabbitmq1vim /etc/hosts
192.168.1.17 rabbitmq3
192.168.1.18 rabbitmq2
192.168.1.19 rabbitmq1#如果先安装了rabbitMQ后改的主机名,启动可能会有问题
#分别在三台机器上 创建文件 
vim /etc/rabbitmq/rabbitmq-env.conf
NODENAME=rabbit@rabbitmq1 #注意这里的主机名修改对应的节点主机名
rabbitmq软件安装

分别安装三台的rabbitMQ

Centos离线安装RabbitMQ并开启MQTT

arm架构安装RabbitMQ并升级erlang解决Requires: erlang ＞= 23.2

#删除rabbitmq之前启动过生成的文件
cd /var/lib/rabbitmq/
rm -rf *#重启
sudo systemctl restart rabbitmq-server.service#停止
sudo systemctl stop rabbitmq-server.service #查看服务启动状态
sudo systemctl status rabbitmq-server.service #查看开机自启动状态
sudo systemctl is-enabled rabbitmq-server.service#查看状态
rabbitmqctl status#创建用户admin和密码beyond_2021
rabbitmqctl add_user admin beyond_2021#设置admin角色
rabbitmqctl set_user_tags admin administrator#分配权限
rabbitmqctl  set_permissions -p "/" admin '.*' '.*' '.*'  #RabbitMQ提供了一个非常友好的图形化监控页面插件（rabbitmq_management），让我们可以一目了然看见Rabbit的状态或集群状态。
#查看插件安装情况
rabbitmq-plugins list#开启图形化监控页面插件
rabbitmq-plugins enable rabbitmq_management  //管理控制台的默认端口是15672#开启mqtt插件
rabbitmq-plugins enable rabbitmq_mqtt      //默认端口mqtt是1883 mqtt://192.168.1.17:1883#开启Mqtt的websocket插件
rabbitmq-plugins enable rabbitmq_web_mqtt    //默认端口websocket是15675 ws://192.168.1.17:15675/ws path是/ws  #查看监听端口（插件监控的端口是15672）
netstat -ntap |grep 5672
拷贝erlang.cookie

Rabbitmq的集群是依附于erlang的集群来工作的,所以必须先构建起erlang的集群景象。Erlang的集群中各节点是经由过程一个magic cookie来实现的,这个cookie存放在/var/lib/rabbitmq/.erlang.cookie中，文件是400的权限。所以必须保证各节点cookie一致,不然节点之间就无法通信。

#查看rabbitmq1的节点的cookie文件
cat /var/lib/rabbitmq/.erlang.cookie
HKHIEHFDVNFFGGPQ#用scp的方式将rabbitmq1节点的.erlang.cookie的值复制到其他两个节点中。
#rabbitmq1复制到其他两个节点中
scp /var/lib/rabbitmq/.erlang.cookie root@192.168.1.17:/var/lib/rabbitmq/.erlang.cookie#重启服务
sudo systemctl restart rabbitmq-server.service scp /var/lib/rabbitmq/.erlang.cookie root@192.168.1.18:/var/lib/rabbitmq/.erlang.cookiesudo systemctl restart rabbitmq-server.service #如果报错: 参考链接: https://blog.csdn.net/u014209205/article/details/106647229
chown rabbitmq:rabbitmq /var/lib/rabbitmq/.erlang.cookie
chown rabbitmq:rabbitmq /var/lib/rabbitmq
mkdir -pv /var/log/rabbitmq#报错:failed to open log file at '/var/log/rabbitmq/rabbit@rabbitmq3.log', reason: no such file or directory#创建文件vim /var/log/rabbitmq/rabbit@rabbitmq3.logfailed to open log file at '/var/log/rabbitmq/rabbit@rabbitmq3_upgrade.log', reason: no such file or directory
#创建文件vim /var/log/rabbitmq/rabbit@rabbitmq3_upgrade.log
将rabbitmq2、rabbitmq3作为内存节点加入rabbitmq1节点集群中

在rabbitmq2 rabbitmq3下执行

rabbitmqctl stop_app //停掉rabbit应用rabbitmqctl join_cluster --ram rabbit@rabbitmq1 //加入到内存节点#也可以加入到磁盘节点
#rabbitmqctl join_cluster rabbit@rabbitmq1 //加入到磁盘节点rabbitmqctl start_app  //启动rabbit应用#如果加入集群报错
Clustering node rabbit@rabbitmq2 with rabbit@rabbitmq1
Error:
incompatible_feature_flags
表示: Rabbitmq各节点版本不一致导致的

(1）默认rabbitmq启动后是磁盘节点，在这个cluster命令下，rabbitmq2和rabbitmq3是内存节点，rabbitmq1是磁盘节点。
（2）如果要使rabbitmq2、rabbitmq3都是磁盘节点，去掉–ram参数即可。
（3）如果想要更改节点类型，可以使用命令rabbitmqctl change_cluster_node_type disc(ram),前提是必须停掉rabbit应用

在RabbitMQ集群中，必须至少有一个磁盘节点，否则队列元数据无法写入到集群中，当磁盘节点宕掉时，集群将无法写入新的队列元数据信息。

保持版本一致,rabbitmq卸载与升级

我这里有rabbitmq3.8.2和3.8.18版本的rpm包,有需要可以给我留言或评论

#查看版本
rabbitmqctl versionerlerl -version#查询rpm安装包
rpm -qa rabbitmq
rpm -qa epel-release
rpm -qa erlang#rpm卸载老版本
sudo rpm -e rabbitmq-server-3.8.2-1.el7.noarch.rpm 
sudo rpm -e erlang-22.2.8-1.el7.x86_64.rpm 
sudo rpm -e epel-release-7-11.noarch.rpm#yum查询安装包与卸载
yum list | grep rabbitmq
yum -y remove rabbitmq-server.noarch
yum list | grep erlang
yum remove erlang.x86_64
yum remove socat#安装最新的,相同的版本
sudo rpm -ivh epel-release-7-13.noarch.rpm
sudo rpm -ivh erlang-23.3.4.4-1.el7.x86_64.rpm
sudo rpm -ivh rabbitmq-server-3.8.18-1.el7.noarch.rpm#然后重新加入到集群
rabbitmqctl join_cluster --ram rabbit@rabbitmq1
查看集群状态
#查看集群状态
rabbitmqctl cluster_status
#显示如下:
Cluster status of node rabbit@rabbitmq1 ...
BasicsCluster name: rabbit@rabbitmq1Disk Nodesrabbit@rabbitmq2
rabbit@rabbitmq3
rabbit@rabbitmq1Running Nodesrabbit@rabbitmq2
rabbit@rabbitmq3
rabbit@rabbitmq1Versionsrabbit@rabbitmq2: RabbitMQ 3.8.18 on Erlang 23.3.4.4
rabbit@rabbitmq3: RabbitMQ 3.8.18 on Erlang 23.3.4.4
rabbit@rabbitmq1: RabbitMQ 3.8.18 on Erlang 23.3.4.4Maintenance statusNode: rabbit@rabbitmq2, status: not under maintenance
Node: rabbit@rabbitmq3, status: not under maintenance
Node: rabbit@rabbitmq1, status: not under maintenanceAlarms(none)Network Partitions(none)ListenersNode: rabbit@rabbitmq2, interface: [::], port: 15672, protocol: http, purpose: HTTP API
Node: rabbit@rabbitmq2, interface: [::], port: 1883, protocol: mqtt, purpose: MQTT
Node: rabbit@rabbitmq2, interface: [::], port: 15675, protocol: http/web-mqtt, purpose: MQTT over WebSockets
Node: rabbit@rabbitmq2, interface: [::], port: 25672, protocol: clustering, purpose: inter-node and CLI tool communication
Node: rabbit@rabbitmq2, interface: [::], port: 5672, protocol: amqp, purpose: AMQP 0-9-1 and AMQP 1.0
Node: rabbit@rabbitmq3, interface: [::], port: 15672, protocol: http, purpose: HTTP API
Node: rabbit@rabbitmq3, interface: [::], port: 1883, protocol: mqtt, purpose: MQTT
Node: rabbit@rabbitmq3, interface: [::], port: 15675, protocol: http/web-mqtt, purpose: MQTT over WebSockets
Node: rabbit@rabbitmq3, interface: [::], port: 25672, protocol: clustering, purpose: inter-node and CLI tool communication
Node: rabbit@rabbitmq3, interface: [::], port: 5672, protocol: amqp, purpose: AMQP 0-9-1 and AMQP 1.0
Node: rabbit@rabbitmq4, interface: [::], port: 25672, protocol: clustering, purpose: inter-node and CLI tool communication
Node: rabbit@rabbitmq1, interface: [::], port: 5672, protocol: amqp, purpose: AMQP 0-9-1 and AMQP 1.0
Node: rabbit@rabbitmq1, interface: [::], port: 15672, protocol: http, purpose: HTTP API
Node: rabbit@rabbitmq1, interface: [::], port: 1883, protocol: mqtt, purpose: MQTT
Node: rabbit@rabbitmq1, interface: [::], port: 15675, protocol: http/web-mqtt, purpose: MQTT over WebSocketsFeature flagsFlag: drop_unroutable_metric, state: enabled
Flag: empty_basic_get_metric, state: enabled
Flag: implicit_default_bindings, state: enabled
Flag: maintenance_mode_status, state: enabled
Flag: quorum_queue, state: enabled
Flag: user_limits, state: enabled
Flag: virtual_host_metadata, state: enabled

rabbitmq集群节点的移除

#停止rabbitmq2 rabbitmq3服务或者rabbitmqctl stop_app停止应用后
#在rabbitmq1上 从集群中 移除节点
rabbitmqctl forget_cluster_node rabbit@rabbitmq2
rabbitmqctl forget_cluster_node rabbit@rabbitmq3#重置数据, 用户名密码都会要重新设置
rabbitmqctl stop_app
rabbitmqctl reset   #修改成磁盘节点
rabbitmqctl stop_app
rabbitmqctl change_cluster_node_type disc(ram)
rabbitmqctl start_app
登录rabbitmq web管理控制台，创建新的队列

打开浏览器输入任意一个节点的: 比如17节点, http://192.168.1.17:15672, 输入之前创建的用户Username：admin，输入Password:beyond_2021 ,登录后出现如图所示的界面。

在这里插入图片描述

根据界面提示创建一条队列

在这里插入图片描述

队列创建成功

在这里插入图片描述

在RabbitMQ集群中，必须至少有一个磁盘节点，否则队列元数据无法写入到集群中，当磁盘节点宕掉时，集群将无法写入新的队列元数据信息。

RabbitMQ镜像集群配置

上面已经完成RabbitMQ默认集群模式，但并不保证队列的高可用性，尽管交换机、绑定这些可以复制到集群里的任何一个节点，但是队列内容不会复制。虽然该模式解决一项目组节点压力，但队列节点宕机直接导致该队列无法应用，只能等待重启，所以要想在队列节点宕机或故障也能正常应用，就要复制队列内容到集群里的每个节点，必须要创建镜像队列。

镜像队列是基于普通的集群模式的，然后再添加一些策略，所以你还是得先配置普通集群，然后才能设置镜像队列，我们就以上面的集群接着做。

设置的镜像队列可以通过开启的网页的管理端，也可以通过命令，这里说的是其中的网页设置方式。

创建rabbitmq策略

在任一节点控制台上创建策略
比如:在rabbitmq1节点的控制台上创建策略:http://192.168.1.17:15672

（1）Web网页配置 点击Admin菜单–->右侧的Policies选项–->左侧最下下边的Add/update a policy。

（2）按照图中的内容根据自己的需求填写。

在这里插入图片描述

  • Name: my_liang

  • Pattern: ^

  • Definition: ha-mode=all

  • Apply to Queues

  • Name:策略名称

  • Pattern：匹配的规则，(^ a)表示匹配a开头的队列，如果是匹配所有的队列，那就是^.

  • Definition:使用ha-mode模式中的all，也就是同步所有匹配的队列。问号链接帮助文档。

（3）点击Add policy添加策略

在这里插入图片描述

此时分别登陆rabbitmq2、rabbitmq3两个节点的控制台，可以看到上面添加的这个策略

添加队列

添加队列: 可以在控制台添加,也可以用代码或工具订阅会自己创建队列

控制台创建

在rabbitmq1节点的控制台上添加队列
（1）点击Queues菜单–>左侧下边的Add a new queue
（2）输入Name和Arguments参数的值，别的值默认即可

在这里插入图片描述

  • Name:队列名称
  • Durability:队列是否持久化
  • Node：消息队列的节点
  • Auto delete：自动删除
  • Arguments:使用的策略类型

（3）点击Add queue

在这里插入图片描述

将鼠标指向+2可以显示出另外两台消息节点。

往队列里发送消息

(1）点击ab队列按钮
（2）拖动滚动条，点击publish message
（3）填写相关内容

在这里插入图片描述

  • Persistent:表示持久化
  • Headers:随便填写即可
  • Properties:点击问号，选择一个消息ID号
  • Payload:消息内容

（4）点击Publish message按钮 发送消息

关闭消息发送提示窗口

点击queue按钮，发现ab队列的Ready和Total中多了一条消息记录。

在这里插入图片描述

做破坏性测试

(1）将rabbitmq1节点的服务关闭，再通过rabbitmq2和rabbitmq3查看消息记录是否还存在。

rabbitmqctl stop_app //停掉rabbitmq1的rabbit应用

查看rabbitmq2或rabbitmq3节点的控制台

在这里插入图片描述

从中可以看到ab队列已经从之前的+2显示成+1了，而且消息记录是存在的。

(2）再将rabbitmq2节点的服务关闭，通过rabbitmq3查看消息记录是否还存在。

rabbitmqctl stop_app //停掉rabbitmq2的rabbit应用

从rabbitmq3控制台中可以看到ab队列和消息记录还是存在的，只是变成了一个节点了。

（3）将rabbitmq1和rabbitmq2的服务再启动起来

rabbitmqctl start_app //启动rabbitmq1、rabbitmq2的rabbit应用

在这里插入图片描述

从中可以看到ab队列后面+2变成了粉色，鼠标指上去显示镜像无法同步。如果这时候停掉rabbitmq3节点的服务，那么队列里面的消息将会丢失。

采取的解决办法是选择在rabbitmq1或rabbitmq2节点上执行同步命令。

rabbitmqctl sync_queue ab //同步ab队列

同步完成后，+2又变成了蓝色。

这样，我们就测试了rabbitmq集群的破坏性测试，说明集群配置成功。

参考链接:
https://blog.51cto.com/11134648/2155934

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

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

相关文章

工厂生产作业流程合规检测

工厂生产作业流程合规检测

工厂生产作业流程合规检测系统通过yolov7网络模型算法，工厂生产作业流程合规检测对作业人员的操作行为进行全面监测，通过图像识别算法和数据分析，对人员的操作动作、工具使用、安全防护等方面进行检测和评估，能够实时监测工人的操…
阅读更多...
Verilog 实现超声波测距

Verilog 实现超声波测距

Verilog 实现超声波测距 教学视频： https://www.bilibili.com/video/BV1Ve411x75W?p33&spm_id_frompageDriver&vd_source19ae31dff4056e52d2729a4ca212602b 超声波测距原理 参考资料：STM32的超声波测距程序_超声波测距stm32程序_VaderZhang的…
阅读更多...
Python工具箱系列(四十一)

Python工具箱系列(四十一)

使用zip批量压缩文件 前文的代码示例了使用gzip对单个文件进行压缩。本文示例使用更通用的zipfile来批量压缩文件。zipfile也是python内置的库，使用起来非常方便。废话不说，直接上代码示例。 import dbm import glob import zipfile# 保存压缩计划的库名…
阅读更多...
AtCoder Beginner Contest 317(D-G)

AtCoder Beginner Contest 317(D-G)

D - President (atcoder.jp) （1）题目大意 （2）解题思路 考虑到z最大不超过1e5，N最多不超过100，因此可以考虑用背包来写，dp[j]表示拿高桥拿j分最少需要花费多少个选民转换，最后把答案取…
阅读更多...
防御网络攻击风险的4个步骤

防御网络攻击风险的4个步骤

如今，人们正在做大量工作来保护 IT 系统免受网络犯罪的侵害。令人担忧的是，对于运营技术系统来说，情况却并非如此，运营技术系统用于运行从工厂到石油管道再到发电厂的所有业务。 组织应该强化其网络安全策略，因为针对…
阅读更多...
移动电源专用的单节锂离子电池充电器和恒定 5V 升压控制器HU5715

移动电源专用的单节锂离子电池充电器和恒定 5V 升压控制器HU5715

航誉微HU5715 为一款移动电源专用的单节锂离子电池充电器和恒定 5V 升压控制器，充电 部分集高精度电压和充电电流调节器、预充、充电状态指示和充电截止等功能于一体， 可以输出最大 1A 充电电流。而升压电路采用 CMOS 工艺制造的空载电流极低的 VFM 开 关…
阅读更多...
运用Python解析HTML页面获取资料

运用Python解析HTML页面获取资料

在网络爬虫的应用中，我们经常需要从HTML页面中提取图片、音频和文字资源。本文将介绍如何使用Python的requests库和BeautifulSoup解析HTML页面，获取这些资源。 一、环境准备 首先，确保您已经安装了Python环境。接下来，我们需要安…
阅读更多...
【Java基础篇】一文搞懂Java方法的调用与重载（超详细）

【Java基础篇】一文搞懂Java方法的调用与重载（超详细）

个人主页：兜里有颗棉花糖 欢迎 点赞👍 收藏✨ 留言✉ 加关注💓本文由 兜里有颗棉花糖 原创 收录于专栏【JavaSE_primary】 目录 一、方法的概念以及使用1.1什么是方法1.2方法定义1.3方法调用的执行过程1.4形参和实参的关系 二、方法的重载方…
阅读更多...
聚观早报｜2023戴尔科技峰会助力创新；小米汽车电池供应商敲定

聚观早报｜2023戴尔科技峰会助力创新；小米汽车电池供应商敲定

【聚观365】8月23日消息 2023戴尔科技峰会助力企业创新 小米汽车电池供应商敲定中创新航和宁德时代 iPhone15预计有6种配色 王小川卸任自动驾驶企业禾多科技董事 特斯拉动力总成副总裁宣布离职 2023戴尔科技峰会助力企业创新 近日“新生万物 数实新格局 —— 2023戴尔科技…
阅读更多...
暑期实习总结（焊点数据管理软件开发）:Python操作MySQL数据库、Django搭建前端网页、以及Excel中数据与MySQL数据库的互转

暑期实习总结（焊点数据管理软件开发）:Python操作MySQL数据库、Django搭建前端网页、以及Excel中数据与MySQL数据库的互转

暑期实习总结（焊点数据管理软件开发）:Python操作MySQL数据库、Django搭建前端网页、以及Excel中数据与MySQL数据库的互转 ​ 这一周是我在企业实习的最后一周，在企业做的项目已基本完成。这篇博客的目的也是总结一些项目中的一些小问题&…
阅读更多...
实用的面试经验分享：程序员们谈论他们的面试历程

实用的面试经验分享：程序员们谈论他们的面试历程

🌷🍁 博主猫头虎 带您 Go to New World.✨🍁 🦄 博客首页——猫头虎的博客🎐 🐳《面试题大全专栏》 文章图文并茂🦕生动形象🦖简单易学！欢迎大家来踩踩~🌺 &a…
阅读更多...
全套解决方案：基于pytorch、transformers的中文NLP训练框架，支持大模型训练和文本生成，快速上手，海量训练数据！

全套解决方案：基于pytorch、transformers的中文NLP训练框架，支持大模型训练和文本生成，快速上手，海量训练数据！

全套解决方案：基于pytorch、transformers的中文NLP训练框架，支持大模型训练和文本生成，快速上手，海量训练数据！ 1.简介 目标：基于pytorch、transformers做中文领域的nlp开箱即用的训练框架，提…
阅读更多...
老Python程序员职业生涯感悟—写给正在迷茫的你

老Python程序员职业生涯感悟—写给正在迷茫的你

我来讲几个极其重要，但是大多数Python小白都在一直犯的思维错误吧！如果你能早点了解清楚这些，会改变你的一生的。所以这一期专门总结了大家问的最多的，关于学习Python相关的问题来给大家聊。希望能带给大家不一样的参考。或者能提…
阅读更多...
Cento7 Docker-compose安装RabbitMQ

Cento7 Docker-compose安装RabbitMQ

RabbitMQ是一个消息中间件，是用Erlang语言编写的。RabbitMQ据说具有良好的性能和时效性，同时还能够非常好的支持集群和负载部署，非常适合在较大规模的分布式系统中使用。接下来我们就以docker形式安装。 1.先安装docker环境 yum -y install…
阅读更多...
移动端h5项目的兼容和适配问题

移动端h5项目的兼容和适配问题

解决兼容性问题的关键在于对移动端产品的生存环境进行梳理，在此基础之上制定应对策略。 所谓生存环境主要分为三个维度： 硬件环境，细分为品牌和机型，决定了屏幕大小、性能等硬件限制 操作系统，比如iOS6和iOS7&#xf…
阅读更多...
四川玖璨电子商务有限公司：抖店运营攻略

四川玖璨电子商务有限公司：抖店运营攻略

抖店运营，是指在抖音平台上进行电商销售的一种新型商业模式。随着抖音平台越来越受到年轻人的喜爱和关注，抖店运营正变得越来越重要。那么，抖店运营应该如何做呢？我们来谈谈抖店运营的一些攻略。 第一，选对产品。选择…
阅读更多...
什么是住宅ip，静态和动态怎么选？

什么是住宅ip，静态和动态怎么选？

上文我们介绍了数据中心代理，这次我们来介绍下住宅代理ip，住宅代理ip分类两种类型：静态住宅代理和动态住宅代理，他们有什么区别又能用在什么场景呢？我们先从他们是如何运作开始。 一、什么是住宅代理ip isp住宅代理i…
阅读更多...
【java】【springboot】【idea】springboot项目pom.xml 灰色下划线

【java】【springboot】【idea】springboot项目pom.xml 灰色下划线

解决方案： 这里我们找到了原因，就是因为选择了Ignored Files导致pom.xml文件被设置在maven忽略文件清单中，所以我们将打勾的选项取消，点击Apply,然后点击OK
阅读更多...
Spark 启动时，报JAVA_HOME is not set

Spark 启动时，报JAVA_HOME is not set

文章目录 1、报错内容2、解决方式3、再次启动Spark集群 1、报错内容 Spark启动时报错： hadoop104: JAVA_HOME is not set2、解决方式 解决方式： 打开启动配置文件 cd /opt/module/spark-standalone/sbin/ vim spark-config.sh配置Java的环境变量 …
阅读更多...
clickhouse一次异常排查记录

clickhouse一次异常排查记录

clickhouse中报错 关闭了自启动，删了status，重启了clickhouse还是报错 1，排查定时执行的脚本日志（每小时第5分钟执行） INSERT INTO quality0529.previously_reported_urls (url) SELECT url FROM quality0529.hourly_…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023