RabbitMQ 集群部署方法

 更新时间:2026年04月22日 09:08:24   作者:weyyhdke  
文章主要介绍了RabbitMQ在三台CentOS7服务器上的安装和集群配置,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧

RabbitMQ

  • 环境准备:三台服务器,系统是 CentOS7
  • IP地址分别是:
    • rabbitmq1:192.168.152.71
    • rabbitmq2:192.168.152.72
    • rabbitmq3:192.168.152.73

一、安装 RabbitMQ

记得配置yum源,避免不必要的错误

在三台服务器上分别安装 erlang 和 rabbitmq-server

安装 RabbitMQ 运行环境

yum install -y erlang

安装软件 RabbitMQ

yum install -y rabbitmq-server

二、更改配置文件

一下配置在三台服务器上都要修改

更改 RabbitMQ 配置文件

vim /etc/rabbitmq/rabbitmq.config

找到 %%{loopback_users, []}, 改为下面内容,大概在 53 行

{loopback_users, []}

更改 hosts 配置主机名解析

192.168.152.71 rabbitmq1
192.168.152.72 rabbitmq2
192.168.152.73 rabbitmq3

可以 ping 一下看是否配置成功

三、配置集群

改主机名,对照 hosts 配置的主机名解析,把对用服务器的主机名改为相应的解析
如:192.168.152.71

hostnamectl set-hostname rabbitmq1

192.168.152.72

hostnamectl set-hostname rabbitmq2

192.168.152.73

hostnamectl set-hostname rabbitmq3

然后全部都 exit 重新登录

启动三台服务器的 RabbitMQ 服务

systemctl start rabbitmq-server
systemctl enable rabbitmq-server

统一三台服务器的 erlang.cookie,把 rabbitmq1 的 erlang.cookie 传输到其它两台

scp /var/lib/rabbitmq/.erlang.cookie rabbitmq2:/var/lib/rabbitmq/.erlang.cookie
scp /var/lib/rabbitmq/.erlang.cookie rabbitmq3:/var/lib/rabbitmq/.erlang.cookie

运行 cat /var/lib/rabbitmq/.erlang.cookie,查看三台服务器的值是否一致,一致后再重启 rabbitmq2 和 rabbitmq3 的 RabbitMQ 服务

systemctl restart rabbitmq-server

查看 RabbitMQ 的节点状态

rabbitmqctl cluster_status

结果如下即为正确

# rabbitmq1 的结果:
Cluster status of node rabbit@rabbitmq1 ...
[{nodes,[{disc,[rabbit@rabbitmq1]}]},
 {running_nodes,[rabbit@rabbitmq1]},
 {cluster_name,<<"rabbit@rabbitmq1">>},
 {partitions,[]}]
...done.
# rabbitmq2 的结果:
Cluster status of node rabbit@rabbitmq2 ...
[{nodes,[{disc,[rabbit@rabbitmq2]}]},
 {running_nodes,[rabbit@rabbitmq2]},
 {cluster_name,<<"rabbit@rabbitmq2">>},
 {partitions,[]}]
...done.
# rabbitmq3 的结果:
Cluster status of node rabbit@rabbitmq3 ...
[{nodes,[{disc,[rabbit@rabbitmq3]}]},
 {running_nodes,[rabbit@rabbitmq3]},
 {cluster_name,<<"rabbit@rabbitmq3">>},
 {partitions,[]}]
...done.

停止 rabbitmq2 和 rabbitmq3 主机的 RabbitMQ 应用

rabbitmqctl stop_app

让 rabbitmq2 和 rabbitmq3 加入 rabbitmq1 的集群

rabbitmqctl join_cluster rabbit@rabbitmq1

启动 rabbitmq2 和 rabbitmq3 主机的 RabbitMQ 应用,并再次查看 RabbitMQ 的节点状态

rabbitmqctl start_app

再三台服务器上执行 rabbitmqctl cluster_status 命令,结果就会变为下面这样

# rabbitmq1 的结果:
Cluster status of node rabbit@rabbitmq1 ...
[{nodes,[{disc,[rabbit@rabbitmq1,rabbit@rabbitmq2,rabbit@rabbitmq3]}]},
 {running_nodes,[rabbit@rabbitmq2,rabbit@rabbitmq3,rabbit@rabbitmq1]},
 {cluster_name,<<"rabbit@rabbitmq1">>},
 {partitions,[]}]
...done.
# rabbitmq2 的结果:
Cluster status of node rabbit@rabbitmq2 ...
[{nodes,[{disc,[rabbit@rabbitmq1,rabbit@rabbitmq2,rabbit@rabbitmq3]}]},
 {running_nodes,[rabbit@rabbitmq1,rabbit@rabbitmq3,rabbit@rabbitmq2]},
 {cluster_name,<<"rabbit@rabbitmq1">>},
 {partitions,[]}]
...done.
# rabbitmq3 的结果:
Cluster status of node rabbit@rabbitmq3 ...
[{nodes,[{disc,[rabbit@rabbitmq1,rabbit@rabbitmq2,rabbit@rabbitmq3]}]},
 {running_nodes,[rabbit@rabbitmq2,rabbit@rabbitmq1,rabbit@rabbitmq3]},
 {cluster_name,<<"rabbit@rabbitmq1">>},
 {partitions,[]}]
...done.

此时集群配置成功

四、测试

可以可以启用 RabbitMQ 可视化web管理插件,更直观的看到集群状态,也方便测试
三台服务器都要开启

rabbitmq-plugins enable rabbitmq_management
systemctl restart rabbitmq-server

通过IP地址加端口号访问,端口号为 15672
如:192.168.152.71:15672,默认的用户名:guest,密码:guest

可以再其中一台添加用户,看其它几台是否有变化,有则配置成功

到此这篇关于RabbitMQ 集群部署方法的文章就介绍到这了,更多相关RabbitMQ 集群部署内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • Java 切割字符串的几种方式集合

    Java 切割字符串的几种方式集合

    这篇文章主要介绍了Java 切割字符串的几种方式集合,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-09-09
  • Java中连接Mongodb进行增删改查的操作详解

    Java中连接Mongodb进行增删改查的操作详解

    MongoDB是一个基于分布式文件存储的数据库,由C++语言编写,旨在为WEB应用提供可扩展的高性能数据存储解决方案,本文给大家介绍了Java中连接Mongodb进行操作,文中有详细的代码示例供大家参考,需要的朋友可以参考下
    2024-06-06
  • Java使用OpenCV3.2实现视频读取与播放

    Java使用OpenCV3.2实现视频读取与播放

    这篇文章主要为大家详细介绍了Java使用OpenCV3.2实现视频读取与播放,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-07-07
  • JAVA 根据Url把多文件打包成ZIP下载实例

    JAVA 根据Url把多文件打包成ZIP下载实例

    这篇文章主要介绍了JAVA 根据Url把多文件打包成ZIP下载的相关资料,需要的朋友可以参考下
    2017-08-08
  • spring mvc实现文件上传与下载功能

    spring mvc实现文件上传与下载功能

    这篇文章主要为大家详细介绍了spring mvc实现文件上传与下载功能,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-12-12
  • spring boot项目中如何使用nacos作为配置中心

    spring boot项目中如何使用nacos作为配置中心

    这篇文章主要介绍了spring boot项目中如何使用nacos作为配置中心问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-12-12
  • Java基础之类型封装器示例

    Java基础之类型封装器示例

    这篇文章主要介绍了Java基础之类型封装器,结合实例形式分析了java类型封装相关原理与操作技巧,需要的朋友可以参考下
    2019-08-08
  • Java Collection集合iterator方法解析

    Java Collection集合iterator方法解析

    这篇文章主要介绍了Java Collection集合iterator方法解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-01-01
  • Java对象流实例代码

    Java对象流实例代码

    这篇文章主要介绍了Java对象流实例代码,具有一定借鉴价值,需要的朋友可以参考下
    2018-01-01
  • Java基础之toString的序列化 匿名对象 复杂度精解

    Java基础之toString的序列化 匿名对象 复杂度精解

    序列化即为把内存中的对象转换为字节写入文件或通过网络传输到远端服务器,本章节将带你了解Java toString的序列化 匿名对象 复杂度,需要的朋友可以参考下
    2021-09-09

最新评论