当前位置：首页 > news >正文

部署RabbitMQ集群详细教程

news 2025/7/7 9:28:40

部署RabbitMQ集群详细教程

下面是一份在 Ubuntu 环境下部署 RabbitMQ 集群的详细步骤说明，涉及主机名设置、Erlang & RabbitMQ 安装、管理插件启用、集群通信 Cookie 配置、节点加入集群、镜像队列策略设置以及集群验证等。为了演示方便，以下示例假设有三台主机，分别命名为 rabbit1, rabbit2, rabbit3，IP 地址分别为 192.168.1.101, 192.168.1.102, 192.168.1.103。请根据自己的实际环境进行修改。

环境准备

操作系统：确保所有节点运行相同版本的操作系统（Linux 是最常见的选择）。
主机名：为每个节点配置唯一的主机名，确保可以通过 DNS 或 /etc/hosts 文件解析到 IP 地址。
时间同步：使用 ntp 或 chrony 服务同步时间。
Erlang：RabbitMQ 依赖 Erlang。确保所有节点安装相同版本的 Erlang。

一、环境准备及主机名设置

RabbitMQ 使用主机名和 Erlang 的 nodename 区分节点，因此每个节点的主机名必须唯一。

修改主机名
在每一台主机上执行以下命令，以设置相应的主机名：
```
# 以 rabbit1 为例
sudo hostnamectl set-hostname rabbit1
```
修改 /etc/hosts 文件
在每台机器的 /etc/hosts 中添加集群中所有节点的主机名与 IP 对应关系，示例如下（所有机器需要保持一致）：
```
192.168.1.101  rabbit1
192.168.1.102  rabbit2
192.168.1.103  rabbit3
```
修改完成后，可以使用 ping rabbit2、ping rabbit3 等来测试是否能正常通过主机名访问。
更新系统软件包索引
在每台机器上执行：
```
sudo apt-get update
```

二、安装 Erlang 和 RabbitMQ

RabbitMQ 依赖 Erlang 环境，所以我们需要先安装 Erlang，然后再安装 RabbitMQ。这里演示使用 Ubuntu 自带源或 RabbitMQ 官方源均可。

2.1 使用 Ubuntu 源（版本可能不是最新）

sudo apt-get install -y erlang
sudo apt-get install -y rabbitmq-server

2.2 启动并查看状态

安装完成后，RabbitMQ 会被自动启动并开机自启动。可以执行以下命令查看状态：

sudo systemctl status rabbitmq-server

如正常启动，会显示 active (running)，后续操作建议在每台节点上都保持服务处于启动状态。

三、启用管理插件并创建管理员账号

RabbitMQ 集群部署完成后，我们通常需要启用管理插件（Management Plugin）来访问可视化管理界面，并创建管理员账号。

启用管理插件
在每台 RabbitMQ 节点上执行：
```
sudo rabbitmq-plugins enable rabbitmq_management
```
启用之后，RabbitMQ 通常会在本地 15672 端口提供 HTTP 管理界面。例如，通过 http://192.168.1.101:15672 可以访问 rabbit1 的管理页面。
创建管理员账号
在每台节点上都可以执行（若已存在相同名称则会提示）：
```
sudo rabbitmqctl add_user admin StrongPassword
sudo rabbitmqctl set_user_tags admin administrator
# 设置该用户在 "/" 虚拟主机下的权限，授予全部读写权限
sudo rabbitmqctl set_permissions -p / admin ".*" ".*" ".*"
```
注意：请使用更强的密码进行生产环境部署，并按照需分配合适的权限或虚拟主机。
不需要每台机器都创建用户，节点接入主节点后，用户可以同步使用。

四、集群通信 Cookie 同步

RabbitMQ 集群依赖 Erlang Cookie 来进行节点间的验证与通信。在同一个集群中的所有节点必须使用相同的 Cookie。该 Cookie 默认保存在 /var/lib/rabbitmq/.erlang.cookie 文件中。

选择一台节点作为 Cookie 源
通常以 rabbit1 为源。

复制 Cookie 到其他节点
在 rabbit1 上查看 Cookie：

sudo cat /var/lib/rabbitmq/.erlang.cookie

将内容复制，然后分别在 rabbit2、rabbit3 上执行：

sudo systemctl stop rabbitmq-server
echo "上一步复制的Cookie字符串" | sudo tee /var/lib/rabbitmq/.erlang.cookie
sudo chmod 400 /var/lib/rabbitmq/.erlang.cookie
sudo chown rabbitmq:rabbitmq /var/lib/rabbitmq/.erlang.cookie
sudo systemctl start rabbitmq-server

确保三台节点的 Cookie 完全一致，并且权限和拥有者正确，才能保证后续正常组建集群。

五、节点加入集群

下面以 rabbit1 作为主节点，先将 rabbit2、rabbit3 加入到 rabbit1 的集群中。

在 rabbit2 上执行：
```
sudo rabbitmqctl stop_app
sudo rabbitmqctl join_cluster rabbit@rabbit1
sudo rabbitmqctl start_app
```
- rabbit@rabbit1 表示主机名是 rabbit1，Erlang 内部节点名称是 rabbit。
- 成功后会输出一串信息，表明已成功加入 rabbit1 所在的集群。

在 rabbit3 上执行：

sudo rabbitmqctl stop_app
sudo rabbitmqctl join_cluster rabbit@rabbit1
sudo rabbitmqctl start_app

查看集群状态
可以在任意节点上运行以下命令查看集群状态：
```
sudo rabbitmqctl cluster_status
```
若一切顺利，会看到类似如下输出，其中 running_nodes 中包含 rabbit@rabbit1、rabbit@rabbit2、rabbit@rabbit3：
```
Cluster status of node rabbit@rabbit1 ...
Basics
Cluster name: rabbit@rabbit1
...Running nodes are:
rabbit@rabbit1
rabbit@rabbit2
rabbit@rabbit3
...
```

六、设置镜像队列（HA）策略

为保证队列数据在集群节点之间进行复制，我们需要设置 镜像队列策略。这里示例设置所有队列自动镜像到所有节点上，并自动同步。


sudo rabbitmqctl set_policy ha-all "^.*" '{"ha-mode":"all","ha-sync-mode":"automatic"}' --priority 0 --apply-to queues

ha-mode: all 表示所有队列将镜像到集群中的所有节点。
ha-sync-mode: automatic 表示当新的节点加入时，会自动同步队列数据。
^.* 是正则表达式，表示对名称匹配任意队列生效；如需针对特定队列或前缀，可自行修改。
--apply-to queues 表示将策略应用到队列。

七、验证集群

使用 rabbitmqctl cluster_status 命令查看集群健康状态
```
sudo rabbitmqctl cluster_status
```
确认三个节点都在 running_nodes 列表里。
访问管理界面进行验证
在浏览器中分别访问三台机器的 http://<节点IP或主机名>:15672，使用前面创建的账号（如 admin）进行登录，查看集群信息、节点信息、队列信息等。
测试队列高可用
- 连接到其中一个节点，创建一个队列并发送消息。
- 关闭该节点的 RabbitMQ 服务或者网络，使用另一个节点进行消费，验证消息是否正常可消费、数据是否依旧存在。

若一切无误，则说明 RabbitMQ 集群部署成功并具备了高可用能力。

八、安装过程中遇到的问题

1. 用户访问被拒绝

以下日志行表明用户 guest 无法从远程登录管理界面：

HTTP access denied: user 'guest' - User can only log in via localhost

原因：RabbitMQ 默认配置限制 guest 用户只能从 localhost 登录。

解决方法

创建新用户
为远程登录创建一个新的管理员用户：

sudo rabbitmqctl add_user myadmin mypassword
sudo rabbitmqctl set_user_tags myadmin administrator
sudo rabbitmqctl set_permissions -p / myadmin ".*" ".*" ".*"

替换 myadmin 和 mypassword 为你自己的用户名和密码。

2. 安装日志查看

查看 RabbitMQ 日志文件，定位配置文件未加载的原因：

sudo tail -f /var/log/rabbitmq/rabbit@$(hostname).log

3. 检查监听端口

使用以下命令确认 RabbitMQ 是否在配置的端口上运行：

sudo netstat -tlnp | grep beam

4. 如何创建 RabbitMQ 配置文件

rabbitmq.conf 位于 /etc/rabbitmq/rabbitmq.conf，这是 RabbitMQ 的主配置文件，采用 INI 格式，用来定义更高级别的功能，如集群、插件、TLS、虚拟主机等。

advanced.config 位于 /etc/rabbitmq/advanced.config，这是 RabbitMQ 的高级配置文件，采用 Erlang 的 term 语法，主要用于复杂的配置需求，例如队列策略、插件配置等。

默认配置文件可能不存在，可以手动创建：

创建配置文件
```
sudo nano /etc/rabbitmq/rabbitmq.conf
```

添加基础配置
示例内容：

## Basic configuration
listeners.tcp.default = 5672
management.listener.port = 15672
management.listener.ip = 0.0.0.0

保存文件并重启服务
```
sudo systemctl restart rabbitmq-server
```

5. Erlang 安装可能会失败，另一种安装方式

这种安装方式会安装最新版本的Erlang，需要注意RabbitMQ版本和Erlang版本的适配

检查 Erlang 版本

打开终端并运行以下命令：

erl -version

或者：

erl

如果 Erlang 已安装，命令会返回版本号或进入交互式 Erlang shell：

Erlang/OTP 25 [erts-13.1.5] ...

按下 Ctrl+C 后，再按 a 退出 shell。

*使用 ppa 仓库安装

添加一个兼容的 PPA：

sudo add-apt-repository ppa:rabbitmq/rabbitmq-erlang

更新包列表并安装 Erlang：

sudo apt-get update
sudo apt-get install -y erlang

6. 配置RabbitMQ 节点名

RabbitMQ 的节点名通常以 rabbit@<主机名> 的形式表示。你可以通过配置 rabbitmq-env.conf 文件来设置节点名和监听地址。

编辑环境配置文件

在每个节点上编辑 /etc/rabbitmq/rabbitmq-env.conf 文件：

sudo nano /etc/rabbitmq/rabbitmq-env.conf

内容如下：

NODENAME=rabbit@node1       # 当前节点名称，需唯一
NODE_IP_ADDRESS=0.0.0.0     # 监听所有网络接口
NODE_PORT=5672              # AMQP 默认端口

根据节点分别设置：

node1 的 NODENAME 为 rabbit@node1
node2 的 NODENAME 为 rabbit@node2
node3 的 NODENAME 为 rabbit@node3

7. 安装指定版本的RabbitMQ

sudo apt-get install -y rabbitmq-server
这个命令安装的rabbitmq版本可能不是最新的，可能会和Erlang版本不适配。

关于RabbitMQ和Erlang的版本适配，详情需要参考：
https://www.rabbitmq.com/docs/which-erlang

这里介绍另一种指定版本的安装方式。官方文档参考：
https://www.rabbitmq.com/docs/install-debian#manual-installation

执行脚本

# sync package metadata
sudo apt-get update
# install dependencies manually
sudo apt-get -y install logrotate init-system-helpers adduser# download the package
sudo apt-get -y install wget
wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v4.0.5/rabbitmq-server_4.0.5-1_all.deb# install the package with dpkg
sudo dpkg -i rabbitmq-server_4.0.5-1_all.debrm rabbitmq-server_4.0.5-1_all.deb

总结

在实际生产环境中，建议配合负载均衡（如 HAProxy、Nginx）或 Kubernetes 等容器化编排方案，以实现更灵活的集群管理与更高的可用性。同时，也可根据业务需求针对镜像队列策略进行更细化的调优与分配。

在这里插入图片描述