环境准备

192.168.226.22RabbitMQMySQLrabbitmq-2Rocky_linux9.4192.168.226.23RabbitMQrabbitmq-3Rocky_linux9.4192.168.226.24RabbitMQ

修改主机名#192.168.226.22

rabbitmq-3注修改完后都手动断开重新连接不要使用bash

配置域名解析三台虚拟机都配置

EOF参考博文RabbitMQ消息中间件介绍与安装-CSDN博客

开始配置集群

/etc/rabbitmq/rabbitmq-env.conf

EOF

RABBITMQ_MNESIA_BASE/data/rabbitmq/data

RABBITMQ_LOG_BASE/data/rabbitmq/logs

EOF重启服务

Rabbitmq的集群是依附于erlang的集群来⼯作的,所以必须先构建起erlang的集群景象。

Erlang的集群中

cookie来实现的,这个cookie存放在/var/lib/rabbitmq/.erlang.cookie中⽂件是400的权限。

所以必须保证各节点cookie⼀致,不然节点之间就⽆法通信.

一般会存在这两个地址第一个是home/.erlang.cookie第二个地方就是/var/lib/rabbitmq/.erlang.cookie。

如果我们使用解压缩方式安装部署的rabbitmq那么这个文件会在{home}下。

)

[rootrabbitmq-1

/var/lib/rabbitmq/.erlang.cookie

HVYPGZCOFCYBEZHGUHQB⽤scp的⽅式将rabbitmq-1节点的.erlang.cookie的值复制到其他两个节点中,一次保证cookie一致。

[rootrabbitmq-1

/var/lib/rabbitmq/.erlang.cookie

root192.168.226.23:/var/lib/rabbitmq/

[rootrabbitmq-1

/var/lib/rabbitmq/.erlang.cookie

root192.168.226.24:/var/lib/rabbitmq/

3.将rabbitmq-2、rabbitmq-3作为内存节点加⼊rabbitmq-1节点集群中

[rootrabbitmq-2

...1默认rabbitmq启动后是磁盘节点在这个cluster命令下mq-2和mq-3是内存节点

2如果要使mq-2、mq-3都是磁盘节点去掉--ram参数即可。

#如果有需要使用磁盘节点加入集群使用下述命令格式默认即为磁盘节点内存节点是加上--ram参数

rabbitmqctl

rabbitrabbitmq-1#如果执行rabbitmqctl

stop_app

1默认rabbitmq启动后是磁盘节点在这个cluster命令下mq-2和mq-3是内存节点mq-1是磁盘节点。

2如果要使mq-2、mq-3都是磁盘节点去掉--ram参数即可。

rabbit应用

在RabbitMQ集群集群中必须⾄少有⼀个磁盘节点否则队列元数据⽆法写⼊到集群中当磁盘节点宕掉时集群将⽆法写⼊新的队列元数据信息。

5.登录rabbitmq

打开浏览器输⼊http://192.168.226.22:15672

输入用户名密码进入

在RabbitMQ集群集群中必须⾄少有⼀个磁盘节点否则队列元数据⽆法写⼊到集群中当

RabbitMQ镜像集群配置

上面已经完成RabbitMQ默认集群模式但并不保证队列的高可用性尽管交换机、绑定这些可以复制到集群里的任何一个节点但是队列内容不会复制。

但队列节点宕机直接导致该队列无法应用只能等待重启所以要想在队列节点宕机或故障也能正常应用就要复制队列内容到集群里的每个节点必须要创建镜像队列。

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

保证各个节点之间数据同步

set_policy这是RabbitMQ的命令行工具rabbitmqctl中设置策略的命令。

ha-all这是策略定义的名称可以为任何你选择的名称这里选择的是ha-all。

^这是策略模式这里的^代表这个策略将应用到所有的队列和交换器上。

{ha-mode:all}这是策略的定义这里设置的是ha-mode高可用模式为all。

这意味着所有的队列将在所有的节点上进行镜像来提供一个高可用的队列。

0这是策略的优先级。

如果一个队列同时匹配多个策略那么优先级高的策略将被使用。

这里设置的优先级为0。

for

/这是策略应用的虚拟主机这里是应用到了默认的虚拟主机上。

则此时镜像队列设置成功。

这里的虚拟主机是代码中需要用到的虚拟主机虚拟主机的作用是做一个消息的隔离本质上可认为是一个rabbitmq-server是否增加虚拟主机增加几个这是由开发中的业务决定即有哪几类服务哪些服务用哪一个虚拟主机这是一个规划。

再次查看队列已经同步到其他两台节点:

ha-sync-modeha-mode:指明镜像队列的模式有效值为

all/exactly/nodesall表示在集群中所有的节点上进行镜像exactly表示在指定个数的节点上进行镜像节点的个数由ha-params指定nodes表示在指定的节点上进行镜像节点名称通过ha-params指定ha-paramsha-mode模式需要用到的参数ha-sync-mode进行队列中消息的同步方式有效值为automatic和manual

准备测试

https://gitea.beyourself.org.cn/newrain001/rabbitmq-test.git

[rootrabbitmq-1

rabbitmq-server-3.13.3-1.el8.noarch.rpm

-rw-r--r--

#修改如下图所示要把版本号去掉原因是因为当前系统没有这个版本去掉让其自行安装别的版本即可

然后视情况修改这个配置文件改对应的IP如果对应的IP在本机可以使用localhost不用改不在本机上的话就必须改用户名和密码也要改成你自己的。

[rootrabbitmq-1

https://mirrors.aliyun.com/pypi/simple

[rootrabbitmq-1

mq集群队列中开始记录下单的数据这时由于下单但是还没有付费成交数据并没有写入到数据库中可以查看下mysql数据库

mysql

sec)现在模式成交后的数据来到http://192.168.226.22/read

再次查看mysql发现数据这时才会写入下数据库中由于前面我们点击发货的是200也就是模拟正式交易成功的数据数量是200此时查看这个库中记录也是200

mysql

注意如果使用阿里云可以使用阿里云的内网slb来实现负载均衡不用自己搭建HA。

主机名系统IP服务haproxyRocky_linux192.168.226.25HAProxy

#修改主机名

/etc/haproxy/haproxy.cfg在该配置文件删除其中所有内容复制下面的配置信息粘贴进去保存退出注意你做的需要把最后三行的主机名和IP修改成你对应的主机名和IP

globallog

#---------------------------------------------------------------------

defaultsmode

#---------------------------------------------------------------------

##监控查看本地状态#####

####################################

###反代监控

浏览器输入http://192.168.226.25/haproxy查看rabbitmq的状态。

密码123456

现在重新配置Flask应用的配置改成负载均衡的IP端口也改成负载均衡监听的端口然后换个队列名实验。

[rootrabbitmq-1