搭建RabbitMQ集群需至少两台服务器，安装RabbitMQ并配置相同Erlang Cookie，通过join_cluster命令将节点加入主节点，使用cluster_status验证状态，可选配置镜像队列或仲裁队列以提高可用性，推荐使用Management UI、Prometheus+Grafana等工具监控队列长度、消息速率、连接数、节点状态等关键指标。
rabbitmq 集群主要用于提高消息队列系统的可用性和吞吐量。通过将消息队列分布在多个节点上，集群可以容忍单个节点的故障，并提供更高的并发处理能力。
rabbitmq 集群的搭建与使用
如何搭建一个简单的 RabbitMQ 集群？
搭建 RabbitMQ 集群，最基本的方法是利用 RabbitMQ 自带的集群功能。你需要至少两台服务器，并且保证它们之间网络互通。
-
安装 RabbitMQ： 在每台服务器上安装 RabbitMQ 服务。你可以使用
apt-get(Debian/Ubuntu) 或yum(CentOS/RHEL) 等包管理器，或者直接从 RabbitMQ 官网下载安装包。# Debian/Ubuntu sudo apt-get update sudo apt-get install rabbitmq-server # CentOS/RHEL sudo yum install rabbitmq-server systemctl enable rabbitmq-server systemctl start rabbitmq-server
-
配置 Erlang Cookie： RabbitMQ 集群依赖 Erlang 的分布式特性，所以所有节点必须使用相同的 Erlang Cookie。这个 Cookie 通常位于
/var/lib/rabbitmq/.erlang.cookie。将其中一个节点的 Cookie 复制到其他所有节点上。# 在节点 1 上 sudo cat /var/lib/rabbitmq/.erlang.cookie # 将节点 1 的 Cookie 复制到节点 2 和节点 3 的 /var/lib/rabbitmq/.erlang.cookie 文件中
-
加入集群： 选择一个节点作为 "主节点"，其他节点加入到这个主节点。首先，停止其他节点上的 RabbitMQ 服务。
sudo rabbitmqctl stop_app
然后，使用
rabbitmqctl join_cluster命令将其他节点加入到主节点。# 在节点 2 上 sudo rabbitmqctl join_cluster rabbit@node1 # node1 是主节点的 hostname # 在节点 3 上 sudo rabbitmqctl join_cluster rabbit@node1
最后，启动这些节点上的 RabbitMQ 服务。
sudo rabbitmqctl start_app
-
验证集群状态： 在任意一个节点上，使用
rabbitmqctl cluster_status命令查看集群状态。sudo rabbitmqctl cluster_status
你应该能看到所有节点都显示在集群状态中。
-
配置镜像队列（可选）： 为了提高可用性，可以配置镜像队列。镜像队列会将队列的消息复制到多个节点上。
sudo rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'这个命令会将所有队列设置为镜像队列，消息会复制到所有节点。
集群模式有哪些？quorum queues 和 classic mirrored queues 有什么区别？
RabbitMQ 集群主要有两种模式：经典镜像队列（Classic Mirrored Queues）和仲裁队列（Quorum Queues）。
-
经典镜像队列（Classic Mirrored Queues）： 这是 RabbitMQ 早期版本提供的集群模式。在这种模式下，一个队列会被镜像到多个节点上，其中一个节点作为主节点，其他节点作为镜像节点。当主节点发生故障时，其中一个镜像节点会被提升为新的主节点。
- 优点： 实现简单，配置容易。
- 缺点： 数据一致性问题。如果主节点在确认消息之前发生故障，消息可能会丢失或重复。切换主节点时可能导致短暂的服务中断。
-
仲裁队列（Quorum Queues）： 这是 RabbitMQ 3.8 引入的一种新的队列类型，旨在解决经典镜像队列的数据一致性问题。仲裁队列基于 Raft 一致性算法，确保所有节点上的消息顺序和内容一致。
- 优点： 数据一致性高，即使在节点故障的情况下也能保证消息的可靠性。
- 缺点： 性能略低于经典镜像队列。配置相对复杂。
区别总结：
| 特性 | 经典镜像队列 (Classic Mirrored Queues) | 仲裁队列 (Quorum Queues) |
|---|---|---|
| 数据一致性 | 较低 | 较高 |
| 一致性算法 | 无 | Raft |
| 性能 | 较高 | 略低 |
| 复杂性 | 较低 | 较高 |
| 适用场景 | 对数据一致性要求不高的场景 | 对数据一致性要求高的场景 |
选择哪种模式取决于你的应用场景。如果你的应用对数据一致性要求非常高，那么仲裁队列是更好的选择。如果你的应用对性能要求更高，并且可以容忍一定程度的数据不一致，那么经典镜像队列可能更适合你。
如何监控 RabbitMQ 集群的健康状态？
监控 RabbitMQ 集群的健康状态至关重要，可以帮助你及时发现并解决问题。
RabbitMQ Management UI： RabbitMQ 自带一个 Web 管理界面，可以用来监控集群的各种指标，如队列长度、消息速率、连接数等。你可以在浏览器中访问
http://your_server_ip:15672(默认端口是 15672) 来打开管理界面。RabbitMQ CLI 工具： 使用
rabbitmqctl命令可以获取集群的各种信息。例如，可以使用rabbitmqctl cluster_status命令查看集群状态，使用rabbitmqctl list_queues命令查看队列信息。-
Prometheus 和 Grafana： 可以使用 Prometheus 收集 RabbitMQ 的指标，然后使用 Grafana 可视化这些指标。你需要安装 RabbitMQ 的 Prometheus 插件，并配置 Prometheus 来抓取这些指标。
-
安装 Prometheus 插件：
sudo rabbitmq-plugins enable rabbitmq_prometheus
-
配置 Prometheus： 在
prometheus.yml文件中添加 RabbitMQ 的配置。scrape_configs: - job_name: 'rabbitmq' static_configs: - targets: ['your_rabbitmq_server_ip:15692'] # 默认端口是 15692 使用 Grafana 可视化： 在 Grafana 中导入 RabbitMQ 的 Dashboard，可以方便地查看各种指标。
-
使用第三方监控工具： 有很多第三方监控工具可以用来监控 RabbitMQ 集群，如 Datadog、New Relic 等。这些工具通常提供更丰富的功能和更强大的可视化能力。
需要监控的关键指标：
- 队列长度： 队列长度过长可能表示消费者处理能力不足，需要增加消费者数量或者优化消费者代码。
- 消息速率： 消息速率过高可能导致 RabbitMQ 性能下降，需要优化生产者代码或者增加 RabbitMQ 节点。
- 连接数： 连接数过多可能导致 RabbitMQ 资源耗尽，需要检查连接是否被正确关闭。
- 节点状态： 确保所有节点都处于健康状态，没有节点发生故障。
- 磁盘空间： 磁盘空间不足可能导致 RabbitMQ 无法正常工作，需要及时清理磁盘空间。
- 内存使用： 内存使用过高可能导致 RabbitMQ 性能下降，需要增加内存或者优化配置。
通过监控这些关键指标，你可以及时发现并解决 RabbitMQ 集群的问题，确保消息队列系统的稳定运行。
