使用Docker构建RabbitMQ集群

环境准备

本教程将在三台运行CentOS 7.5的操作系统上构建RabbitMQ集群，各节点IP地址分别为192.168.102.128、192.168.102.130和192.168.102.131。确保每台机器都已安装Docker。

为了便于RabbitMQ容器之间的通信，需要在每台机器的hosts文件中添加以下条目：

$ vim /etc/hosts
192.168.102.128 rabbit1
192.168.102.130 rabbit2
192.168.102.131 rabbit3

集群搭建步骤

拉取RabbitMQ镜像

在每台服务器上执行以下命令，下载带有管理界面的RabbitMQ Docker镜像：

$ docker pull rabbitmq:management

启动RabbitMQ容器

接下来，在每台服务器上启动RabbitMQ容器，并配置必要的环境变量。例如，在192.168.102.128上启动名为myrabbit1的容器：

$ docker run --restart=unless-stopped -h rabbit1 -d -p 5672:5672 -p 15672:15672 -p 25672:25672 -p 4369:4369 \
--name myrabbit1 \
-v /home/rabbitmq:/var/lib/rabbitmq:z \
-v /home/rabbitmq/hosts:/etc/hosts \
-e RABBITMQ_DEFAULT_USER=admin \
-e RABBITMQ_DEFAULT_PASS=123456 \
-e RABBITMQ_ERLANG_COOKIE='xxx_2019' \
rabbitmq:management

对于其他两台服务器，仅需更改容器名称、主机名和IP地址，其余配置保持一致。

集群配置

首先，重启并重置第一个节点myrabbit1，然后将剩余节点加入集群。在myrabbit1上执行：

$ docker exec -it myrabbit1 /bin/bash
$ rabbitmqctl stop_app && rabbitmqctl reset && rabbitmqctl start_app

接着，在myrabbit2和myrabbit3上执行类似操作，将其加入到myrabbit1所在的集群：

$ docker exec -it myrabbit2 /bin/bash
$ rabbitmqctl stop_app && rabbitmqctl reset && rabbitmqctl join_cluster rabbit@rabbit1 && rabbitmqctl start_app
$ docker exec -it myrabbit3 /bin/bash
$ rabbitmqctl stop_app && rabbitmqctl reset && rabbitmqctl join_cluster rabbit@rabbit1 && rabbitmqctl start_app

检查集群状态

可以通过以下命令检查集群的状态：

$ rabbitmqctl cluster_status

处理故障节点

如果某个节点出现故障，可以在正常工作的节点上执行命令将其从集群中移除。例如，若myrabbit2发生故障，可以在myrabbit1上执行：

$ docker exec -it myrabbit1 /bin/bash
$ rabbitmqctl forget_cluster_node rabbit@rabbit2

集群模式详解

普通模式

在普通模式下，交换机和队列的元数据会在所有节点上同步，但队列中的实际数据仅存储在创建该队列的节点上。这意味着当消费者尝试从非数据节点访问数据时，会引发额外的数据传输开销，从而可能导致性能瓶颈。

镜像模式

镜像模式下，队列的元数据和实际数据会在所有节点上进行同步。这种方式提高了系统的可用性和数据冗余，但同时也增加了网络带宽的需求和存储成本。

配置镜像策略

可以通过RabbitMQ管理界面或命令行工具配置镜像策略，确保关键队列在所有节点上都有副本。例如，使用命令行工具设置所有队列为镜像：

$ rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'

这将确保所有队列在集群中的每个节点上都有一个副本，从而提高系统的可靠性和容错能力。

结论

根据应用需求选择合适的RabbitMQ集群模式至关重要。对于需要高可用性和数据冗余的应用场景，推荐采用镜像模式。而对于对性能要求较高的场景，则可能需要考虑普通模式或其他优化方案。