rabbitmq 集群部署

安装 erlang 环境
yum安装socat 的rpm包
安装 rabbitmq

安装Erlang
[[email protected] ~]# vim /etc/yum.repos.d/erlang.repo
[rabbitmq-erlang]
name=rabbitmq-erlang
baseurl=https://dl.bintray.com/rabbitmq-erlang/rpm/erlang/21/el/7
gpgcheck=1
gpgkey=https://dl.bintray.com/rabbitmq/Keys/rabbitmq-release-signing-key.asc
repo_gpgcheck=0
enabled=1
[[email protected] ~]# yum -y install erlang

安装RabbitMQ
wget https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.7.13/rabbitmq-server-3.7.13-1.el7.noarch.rpm
yum -y install rabbitmq-server-3.7.13-1.el7.noarch.rpm

修改配置文件

cp /usr/share/doc/rabbitmq-server-3.7.13/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config
vim /etc/rabbitmq/rabbitmq.config   //打开配置文件去掉%%和逗号

安装插件并启动服务

rabbitmq-plugins enable rabbitmq_management     //web管理界面工具
systemctl restart rabbitmq-server

集群部署-先前准备

同步各个主机的相同配置 做域名解析 设置主机名 同步/cookie
找到erlang cookie文件的位置，源码包部署一般会存在~/.erlang.cookie；rpm包部署一般是在/var/lib/rabbitmq/.erlang.cookie。

导入rabbitmq 的管理界面

rabbitmq-plugins enable rabbitmq_management

rabbitmqctl stop                    //关闭服务
rabbitmq-server -detached       //运行节点，warning不用理会
Warning: PID file not written; -detached was passed.

rabbitmqctl cluster_status        //查看节点状态。

5、添加用户并设置密码
由于guest这个用户,只能在本地访问,所以我们要新增一个用户并赋予对/的所有权限，然后添加到管理员组中，让此用户能够远程访问
rabbitmqctl add_user admin 123456
rabbitmqctl set_permissions -p “/” admin “." ".” “.*”
rabbitmqctl set_user_tags admin administrator

组成集群
作用： rabbitmq-server 启动时，会一起启动节点和应用，它预先设置RabbitMQ应用为standalone模式。要将一个节点加入到现有的集群中，你需要停止这个应用，并将节点设置为原始状态。如果使用./rabbitmqctl stop，应用和节点都将被关闭。所以使用rabbitmqctl stop_app仅仅关闭应用。
1、准备多台主机按照上述配置, 例如node1、node2 、node3 三台主机
node2、node3加入到node1中组成集群

node2# rabbitmqctl stop_app      
node2# rabbitmqctl join_cluster [email protected]               ##集群名字一定不要写错
node2# rabbitmqctl start_app

node3# rabbitmqctl stop_app      
node3# rabbitmqctl join_cluster [email protected]               ##集群名字一定不要写错
node3# rabbitmqctl start_app

#使用内存节点加入集群

node2 # rabbitmqctl join_cluster --ram [email protected]

2、在任意节点上查看集群状态

node3# rabbitmqctl cluster_status
Cluster status of node [email protected] ...
[{nodes,[{disc,[[email protected],[email protected],[email protected]]}]},
 {running_nodes,[[email protected],[email protected],[email protected]]},
 {cluster_name,<"[email protected]">},      #集群的名称默认为 [email protected]
 {partitions,[]},
 {alarms,[{[email protected],[]},{[email protected],[]},{[email protected],[]}]}]

3、在任意节点上设置镜像队列策略
在web界面登陆，点击“Admin–Virtual Hosts（页面右侧）”，在打开的页面上的下方的“Add a new virtual host”处增加一个虚拟主机，同时给用户“admin”和“guest”均加上权限（在页面直接设置、点点点即可）；

然后在linux中设置镜像队列策略：

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

注释：
“coresystem”：vhost名称
“^”：queue的匹配模式为匹配所有的队列
ha-all：策略名称
{}为镜像定义，包括三个部分ha-mode, ha-params, ha-sync-mode
ha-mode:指明镜像队列的模式，有效值为 all/exactly/nodes
all：表示在集群中所有的节点上进行镜像，包含新增节点
exactly：表示在指定个数的节点上进行镜像，节点的个数由ha-params指定
nodes：表示在指定的节点上进行镜像，节点名称通过ha-params指定
ha-params：ha-mode模式需要用到的参数
ha-sync-mode：进行队列中消息的同步方式，有效值为automatic和manual
此时镜像队列设置成功。队列会被复制到各个节点，各个节点状态保持一致（这里的虚拟主机coresystem是代码中需要用到的虚拟主机，虚拟主机的作用是做一个消息的隔离，本质上可认为是一个rabbitmq-server，是否增加虚拟主机，增加几个，这是由开发中的业务决定，即有哪几类服务，哪些服务用哪一个虚拟主机，这是一个规划）。