centos7.3 rabbitmq集群
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了centos7.3 rabbitmq集群相关的知识，希望对你有一定的参考价值。
RabbitMQ集群概述
通过 Erlang 的分布式特性（通过 magic cookie 认证节点）进行 RabbitMQ 集群，各 RabbitMQ 服务为对等节点，即每个节点都提供服务给客户端连接，进行消息发送与接收。
这些节点通过 RabbitMQ HA 队列（镜像队列）进行消息队列结构复制。本方案中搭建 3 个节点，并且都是磁盘节点（所有节点状态保持一致，节点完全对等），只要有任何一个节点能够工作，RabbitMQ 集群对外就能提供服务。
安装 Erlang、RabbitMQ
http://yanconggod.blog.51cto.com/1351649/1933009
修改 /etc/hosts
加入集群 3 个节点的对应关系：
10.0.0.231 node1
10.0.0.232 node2
10.0.0.233 node3
设置 Erlang Cookie
RabbitMQ节点之间和命令行工具 (e.g. rabbitmqctl)是使用Cookie互通的，Cookie是一组随机的数字+字母的字符串。当RabbitMQ服务器启动的时候，Erlang VM会自动创建一个随机内容的Cookie文件。如果是通过yum源安装RabbitMQ的话，Erlang Cookie 文件在/var/lib/rabbitmq/.erlang.cookie。如果是通过源码安装的RabbitMQ，Erlang Cookie文件$HOME/.erlang.cookie。
本文演示的实例是用源码安装，由于这个文件权限是 400，所以需要先修改 node2、node3 中的该文件权限为 777：
node1： [email protected]:~$ chmod 777 .erlang.cookie node2： [email protected]:~$ chmod 777 .erlang.cookie [email protected]:~$ scp -r node1:/home/yancongadmin/.erlang.cookie ~/ [email protected]‘s password: .erlang.cookie 100% 20 0.0KB/s 00:00 node3： [email protected]:~$ chmod 777 .erlang.cookie [email protected]:~$ scp -r node1:/home/yancongadmin/.erlang.cookie ~/ [email protected]‘s password: .erlang.cookie 100% 20 0.0KB/s 00:00
分别在node1、node2、node3将权限恢复过来：
[email protected]:~$ chmod 400 .erlang.cookie
最后分别在确认三台机器上的.erlang.cookie的值是一致的
[email protected]:~$ cat .erlang.cookie VORMVSAAOFOFEQKTNWBB [email protected]:~$ cat .erlang.cookie VORMVSAAOFOFEQKTNWBB [email protected]:~$ cat .erlang.cookie VORMVSAAOFOFEQKTNWBB
使用detached参数，在后台启动Rabbit Node
[email protected]:~$ rabbitmqctl stop Stopping and halting node [email protected] ... Gracefully halting Erlang VM [email protected]:~$ rabbitmq-server -detached
通过rabbitmqctl cluster_status命令，可以查看和个节点的状态，节点的名称是[email protected]，
node1: [email protected]:~$ rabbitmqctl cluster_status Cluster status of node [email protected] ... [{nodes,[{disc,[[email protected]]}]}, {running_nodes,[[email protected]]}, {cluster_name,<<"[email protected]">>}, {partitions,[]}, {alarms,[{[email protected],[]}]}] node2: [email protected]:~$ rabbitmqctl cluster_status Cluster status of node [email protected] ... [{nodes,[{disc,[[email protected]]}]}, {running_nodes,[[email protected]]}, {cluster_name,<<"[email protected]">>}, {partitions,[]}, {alarms,[{[email protected],[]}]}] node3: [email protected]:~$ rabbitmqctl cluster_status Cluster status of node [email protected] ... [{nodes,[{disc,[[email protected]]}]}, {running_nodes,[[email protected]]}, {cluster_name,<<"[email protected]">>}, {partitions,[]}, {alarms,[{[email protected],[]}]}]
将node1、node2、node3组成集群
因为rabbitmq-server启动时，会一起启动节点和应用，它预先设置RabbitMQ应用为standalone模式。要将一个节点加入到现有的集群中，你需要停止这个应用并将节点设置为原始状态，然后就为加入集群准备好了。如果使用./rabbitmqctl stop，应用和节点都将被关闭。所以使用rabbitmqctl stop_app仅仅关闭应用。
node2: [email protected]:~$ rabbitmqctl stop_app Stopping node [email protected] ... [email protected]:~$ rabbitmqctl join_cluster [email protected] Clustering node [email protected] with [email protected] ... [email protected]:~$ rabbitmqctl start_app Starting node [email protected] ... node3: [email protected]:~$ rabbitmqctl stop_app Stopping node [email protected] ... [email protected]:~$ rabbitmqctl join_cluster [email protected] Clustering node [email protected] with [email protected] ... [email protected]:~$ rabbitmqctl start_app Starting node [email protected] ...
此时 node2 与 node3 也会自动建立连接。
如果要使用内存节点，则可以使用以下命令：
[email protected]:~$ rabbitmqctl join_cluster --ram [email protected]
集群配置好后，可以在 RabbitMQ 任意节点上执行 rabbitmqctl cluster_status 来查看是否集群配置成功。
node1: [email protected]:~$ rabbitmqctl cluster_status Cluster status of node [email protected] ... [{nodes,[{disc,[[email protected],[email protected],[email protected]]}]}, {running_nodes,[[email protected]]}, {cluster_name,<<"[email protected]">>}, {partitions,[]}, {alarms,[{[email protected],[]}]}] node2: [email protected]:~$ rabbitmqctl cluster_status Cluster status of node [email protected] ... [{nodes,[{disc,[[email protected],[email protected]]}]},{alarms,[{[email protected],[]}]}] node3: [email protected]:~$ rabbitmqctl cluster_status Cluster status of node [email protected] ... [{nodes,[{disc,[[email protected],[email protected],[email protected]]}]}, {alarms,[{[email protected],[]}]}]
RabbitMQ镜像功能
使用Rabbit镜像功能，需要基于RabbitMQ策略来实现，策略是用来控制和修改群集范围的某个vhost队列行为和Exchange行为
[email protected]:~$ rabbitmqctl set_policy -p hrsystem ha-allqueue"^" ‘{"ha-mode":"all"}‘
这行命令在vhost名称为hrsystem创建了一个策略，策略名称为ha-allqueue,策略模式为 all 即复制到所有节点，包含新增节点，策略正则表达式为 “^” 表示所有匹配所有队列名称。
例如下面的命令，^message 这个规则要根据自己修改，这个是指同步”message”开头的队列名称，我们配置时使用的应用于所有队列，所以表达式为”^”。
[email protected]:~$ rabbitmqctl set_policy -p hrsystem ha-allqueue "^message" ‘{"ha-mode":"all"}‘
参考：http://idoall.org/blog/post/lion/15
本文出自 “禅剑一如” 博客，请务必保留此出处http://yanconggod.blog.51cto.com/1351649/1933930
以上是关于centos7.3 rabbitmq集群的主要内容，如果未能解决你的问题，请参考以下文章
带你从头进行RabbitMQ安装集群搭建镜像队列配置和代码验证