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    //其他两台相同
rabbitmq1

vim /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.cookie

sudo 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.log

failed 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 version

erl

erl -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 ...
Basics

Cluster name: rabbit@rabbitmq1

Disk Nodes

rabbit@rabbitmq2
rabbit@rabbitmq3
rabbit@rabbitmq1

Running Nodes

rabbit@rabbitmq2
rabbit@rabbitmq3
rabbit@rabbitmq1

Versions

rabbit@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.4

Maintenance status

Node: rabbit@rabbitmq2, status: not under maintenance
Node: rabbit@rabbitmq3, status: not under maintenance
Node: rabbit@rabbitmq1, status: not under maintenance

Alarms

(none)

Network Partitions

(none)

Listeners

Node: 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 WebSockets

Feature flags

Flag: 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

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

SwiftUI 中限制任意视图为指定的屏幕旋转方向

功能需求 在 SwiftUI 开发中,我们有时需要限制 App 中某些视图为特定的屏幕旋转方向,而另一些视图不做限制(或做其它限制),这可以做到吗? 如上图所示:我们成功的限制了 SwiftUI 中不同视图对应于不同的屏幕旋转方向(Interface Orientations)。 在本篇博文中,您将学到…

Mac操作系统上设置和配置PPPoE连接

嗨,在使用Mac的小伙伴么!你是否在Mac操作系统上尝试设置和配置PPPoE连接,却不知道怎么设置?别担心,今天我将为你一步步教你如何在Mac上进行设置和配置。无论你是新手还是有经验的用户,本文都将帮助你轻松完…

2023国赛数学建模C题思路模型代码 高教社杯

本次比赛我们将会全程更新思路模型及代码,大家查看文末名片获取 之前国赛相关的资料和助攻可以查看 2022数学建模国赛C题思路分析_2022国赛c题matlab_UST数模社_的博客-CSDN博客 2022国赛数学建模A题B题C题D题资料思路汇总 高教社杯_2022国赛c题matlab_UST数模社…

React绑定antd输入框,点击清空或者确定按钮实现清空输入框内容

其实实现原理和vue的双向绑定是一样的,就是监听输入框的onChange事件,绑定value值,当输入框内容发生变化后,就重新设置这个value值。 示例代码:我这里是统一在handleCancel这个函数里面处理清空逻辑了,你们…

【深度学习】实验02 鸢尾花数据集分析

文章目录 鸢尾花数据集分析决策树K-means 鸢尾花数据集分析 决策树 # 导入机器学习相关库 from sklearn import datasets from sklearn import treeimport matplotlib.pyplot as plt import numpy as np# Iris数据集是常用的分类实验数据集, # 由Fisher, 1936收集…

c++存取dat数据

众所周知,dat是一个类似加密的二进制格式文件,很多人喜欢将游戏数据保存在dat文件中,只有知道你的存放格式,才能够将数据破解出来,因而研究了dat文件的存取方式。其实就是c文件的操作,只不过是在取的时候需…

git管理代码

理论上改代码前要pull一次,然后在push前在pull一次 改代码前pull一次是为了获取最新的同步,但是coding也是需要时间的,难保敲代码的这段时间没有人动远程仓库的东西,所以在改完代码要push的时候也应该再pull一下看有无冲突&#x…

jvs-rules(规则引擎)更新:新增功能介绍

jvs-rules更新内容 1.复合变量新增数据补充节点,实现请求回来的数据再以入参方式请求其他数据进行数据补充(例如通过参数A,请求回数据B,再以数据B为入参,请求回数据C) 2.规则流结束节点支持新增、新建、引…

c++都补了c语言哪些坑?

目录 1.命名空间 1.1 定义 1.2 使用 2.缺省参数 2.1 概念 2.2 分类 3.函数重载 4.引用 4.1 概念 4.2 特性 4.3 常引用 4.4 引用和指针的区别 5.内联函数 1.命名空间 在 C/C 中,变量、函数和后面要学到的类都是大量存在的,这些变量、函数和类的名称将…

使用go语言、Python脚本搭建一个简单的chatgpt服务网站。

使用go语言、Python脚本搭建一个简单的GPT服务网站 前言 研0在暑假想提升一下自己,自学了go语言编程和机器学习相关学习,但是一味学习理论,终究是枯燥的,于是自己弄点小项目做。 在这之前,建议您需要掌握以下两个技…

人力资源小程序的设计原则与实现方法

随着移动互联网的快速发展,小程序成为了各行各业推广和服务的新利器。对于人力资源行业来说,开发一款定制化的小程序不仅可以提升服务效率,还可以增强品牌形象和用户粘性。那么,如何定制开发人力资源类的小程序呢?下面…

深度丨Serverless + AIGC,一场围绕加速创新的升维布局

作者:褚杏娟 上图来源于基于函数计算部署 SD实现光影效果 前言: Serverless 在中国发展这些年,经历了高潮、低谷、现在重新回到大众视野。很多企业都非常感兴趣,部分企业开始大规模应用;也有一些企业对在生产环境真正…

【pytorch】Unfold和Fold的互逆操作

1. 参数定义 Unfold https://pytorch.org/docs/stable/generated/torch.nn.Unfold.html#torch.nn.Unfold Fold https://pytorch.org/docs/stable/generated/torch.nn.Fold.html#torch.nn.Fold 注意:参数当中的padding是在四周边补零,而当fold后的尺寸…

找风景类视频素材就上这5个网站

免费高清的风景视频素材,我推荐你去这几个网站下载,赶紧收藏起来~ 菜鸟图库 https://www.sucai999.com/video.html?vNTYxMjky 菜鸟图库网素材非常丰富,网站主要还是以设计类素材为主,高清视频素材也很多,像风景、植…

Docker创建Consul并添加权限控制

一、部署Consul 1、拉取镜像&#xff1a; docker pull consul:<consul-version> 2、运行 docker run --name consul1 -p 8300:8300/tcp -p 8301:8301/tcp -p 8301:8301/udp -p 8302:8302/tcp -p 8302:8302/udp -p 8500:8500 -p 8600:8600/tcp -p 8600:8600/udp -v /h…

建设全球研发中心城市,长沙政协将会发挥怎样的作用?

政协力量&#xff0c;会如何推动一座城市的发展&#xff1f;在全国各大城市都力“拼经济、搞创新”的时代大背景下&#xff0c;人民政协的力量会如何助推长沙建设全球研发中心城市呢&#xff1f; 这是笔者此前一直很好奇的两个问题。8月24日&#xff0c;一场由长沙市政协举办的…

《存储IO路径》专题:数据魔法师DMA

初识DMA 大家好,今天我要给大家介绍一位在计算机世界中不可或缺的魔法师——DMA(Direct Memory Access)。让我们一起揭开这位魔法师的神秘面纱,看看它是如何让数据在内存之间自由穿梭的。 DMA这位魔法师可是大有来头。在现代计算机系统中,CPU、内存和各种设备之间需要进…

Android 之 LayoutInflater (布局服务)

本节引言&#xff1a; 本节继续带来的是Android系统服务中的LayoutInflater(布局服务)&#xff0c;说到布局&#xff0c;大家第一时间 可能想起的是写完一个布局的xml&#xff0c;然后调用Activity的setContentView()加载布局&#xff0c;然后把他显示 到屏幕上是吧~其实这个底…

2.含电热联合系统的微电网运行优化

含电热联合系统的微电网运行优化 MATLAB代码&#xff1a;含电热联合系统的微电网运行优化 关键词&#xff1a;微网 电热联合系统 优化调度 参考文档&#xff1a;《含电热联合系统的微电网运行优化》完全复现 仿真平台&#xff1a;MATLAB yalmipcplex [火]主要内容&#xf…

成都睿趣科技:抖音开网店前期的流程是什么

随着互联网的快速发展&#xff0c;电子商务成为了商业领域中的一大利器&#xff0c;而在电商领域中&#xff0c;抖音作为一个强大的平台&#xff0c;也吸引了众多商家的目光。然而&#xff0c;要在抖音上开设一家成功的网店&#xff0c;并不是一件简单的事情&#xff0c;需要经…