设置 RabbitMQ 集群是非常简单的。简单到可以在你的开发系统中设置完整功能的集群。这对于在测试环境测试实际生产中遇到的失败场景是很便利的。现在来动手搭建 RabbitMQ 集群吧。
Step 1：关闭节点，关闭插件
-
关闭节点
在开始配置集群前，需要首先确保现存的 Rabbit 没有运行。如果需要关闭节点的话，则移动到 RabbitMQ 安装目录，然后运行./sbin/rabbitmqctl stop。 -
关闭插件
我们尚未讨论RabbitMQ插件，不过有可能你已经启用了一部分插件了。如果确实如此的话，你需要在启动集群节点前将插件禁用。这是因为像RabbitMQ Management这样的插件会监听专门的端口来提供服务。我们还没有讲到如何设置插件监听不同的端口，所以当第二个和之后的节点启动了它们的插件，就会和第一个启动节点的插件相冲突，然后节点就都崩溃了。
Step 2：启动节点
如果不用额外参数的话，使用rabbitmqserver命令启动节点会默认使用节点名称rabbit和监听端口号5672。如果你尝试在同台机器用这个方法启动其他节点的话，就会因为节点名称和端口冲突导致启动失败。因此在每次调用rabbitmq-server命令前，我们通过设置RABBITMQ_NODENAME和RABBITMQ_NODE_PORT环境变量来明确指定唯一的节点名称和端口号。
#启动第一个节点
$ RABBITMQ_NODENAME=rabbit_one RABBITMQ_NODE_PORT=5672 ./sbin/rabbitmq-server -detached
#启动第二个节点
$ RABBITMQ_NODENAME=rabbit_two RABBITMQ_NODE_PORT=5673 ./sbin/rabbitmq-server -detached
#启动第三个节点
$ RABBITMQ_NODENAME=rabbit_three RABBITMQ_NODE_PORT=5674 ./sbin/rabbitmq-server -detached
现在在开发系统上运行着三个 Rabbit 节点，分别是 rabbit_one、rabbit_two 和 rabbit_three，每个节点都会有系统的主机名，添加在@后。但是每个节点仍然是独立节点，拥有自己的元数据，并且不知道其他节点的存在。
设置集群
集群中的第一个节点将初始元数据带入集群中，并且无须被告知加入。而第二个和之后的节点将加入它并且获取它的元数据。
要加入第二个和第三个节点，首先需要停止 Erlang 节点上运行的 RabbitMQ 应用程序，并重设（清空）它们的元数据。这样它们才可以被加入并且获取集群的元数据。rabbitmqctl 工具会帮你和每个节点通信并完成以上的任务。
- 停止第二个节点上的RabbitMQ应用程序
$ ./sbin/rabbitmqctl -n rabbit_two@localhost stop_app
关闭应用程序反馈信息
- 要重设第二个节点的元数据和状态为清空的状态
$ ./sbin/rabbitmqctl -n rabbit_two@localhost reset
清空节点状态反馈信息
- 将第二个节点加入到第一个集群节点
./sbin/rabbitmqctl -n rabbit_two@localhost join_cluster rabbit_one@localhost --ram
加入集群反馈信息
-n参数指定任何RabbitMQ节点，不管是在你的开发系统上或者是网络上任何可以连接的其他系统上。--ram指定为内存节点
disc：磁盘节点；ram：内存节点
- 重新启动第二个节点的应用程序
$ ./sbin/rabbitmqctl -n rabbit_one@localhost start_app
加入集群后启动应用程序反馈信息
- 查看 RabbitMQ 集群状态
./sbin/rabbitmqctl -n rabbit_one cluster_status
集群状态信息
注意：记住 Erlang 节点间通过认证 Erlang cookie 的方式来允许互相通信。因为 rabbitmqctl 使用 Erlang OTP 通信机制来和 Rabbit 节点通信，运行 rabbitmqctl 的机器和所要连接的 Rabbit 节点必须使用相同的 Erlang cookie。否则会遇到错误。
现在使用相同的命令将第三个节点加入到集群当中，唯一不同的是-n参数指定为第三个节点。之后可以连接到这三个节点中的任何一个，并且开始创建队列，发布消息或者执行其他任何AMQP任务。
网友评论