部署RabbitMQ集群详细教程

部署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 区分节点，因此每个节点的主机名必须唯一。

1. 修改主机名
   在每一台主机上执行以下命令，以设置相应的主机名：

   # 以 rabbit1 为例
   sudo hostnamectl set-hostname rabbit1
   

2. 修改 /etc/hosts 文件
   在每台机器的 /etc/hosts 中添加集群中所有节点的主机名与 IP 对应关系，示例如下（所有机器需要保持一致）：

   192.168.1.101  rabbit1
   192.168.1.102  rabbit2
   192.168.1.103  rabbit3
   

   修改完成后，可以使用 ping rabbit2、ping rabbit3 等来测试是否能正常通过主机名访问。

3. 更新系统软件包索引
   在每台机器上执行：

   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）来访问可视化管理界面，并创建管理员账号。

1. 启用管理插件
   在每台 RabbitMQ 节点上执行：

   sudo rabbitmq-plugins enable rabbitmq_management
   

   启用之后，RabbitMQ 通常会在本地 15672 端口提供 HTTP 管理界面。例如，通过 http://192.168.1.101:15672 可以访问 rabbit1 的管理页面。

2. 创建管理员账号
   在每台节点上都可以执行（若已存在相同名称则会提示）：

   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 文件中。

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

2. 复制 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 的集群中。

1. 在 rabbit2 上执行：

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

   • rabbit@rabbit1 表示主机名是 rabbit1，Erlang 内部节点名称是 rabbit。
   • 成功后会输出一串信息，表明已成功加入 rabbit1 所在的集群。

2. 在 rabbit3 上执行：

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

3. 查看集群状态
   可以在任意节点上运行以下命令查看集群状态：

   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 表示将策略应用到队列。

七、验证集群

1. 使用 rabbitmqctl cluster_status 命令查看集群健康状态

   sudo rabbitmqctl cluster_status
   

   确认三个节点都在 running_nodes 列表里。

2. 访问管理界面进行验证
   在浏览器中分别访问三台机器的 http://<节点IP或主机名>:15672，使用前面创建的账号（如 admin）进行登录，查看集群信息、节点信息、队列信息等。

3. 测试队列高可用

   • 连接到其中一个节点，创建一个队列并发送消息。
   • 关闭该节点的 RabbitMQ 服务或者网络，使用另一个节点进行消费，验证消息是否正常可消费、数据是否依旧存在。

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

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

1. 用户访问被拒绝

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

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

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

解决方法

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

   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 语法，主要用于复杂的配置需求，例如队列策略、插件配置等。

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

1. 创建配置文件

   sudo nano /etc/rabbitmq/rabbitmq.conf
   

2. 添加基础配置
   示例内容：

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

3. 保存文件并重启服务

   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 仓库安装

1. 添加一个兼容的 PPA：

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

2. 更新包列表并安装 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.deb

rm rabbitmq-server_4.0.5-1_all.deb

总结

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