此处我配置了三台做集群,单节点只需配置一台
注意,准备三台虚拟机,RabbitMQ集群节点必须在同一网段,如果是跨域,效果会变差。关闭防火墙和SELinux
修改主机名称,添加解析
三台机器都操作:
配置hosts文件更改三台MQ节点的计算机名分别为rabbitmq-1、rabbitmq-2 和rabbitmq-3,然后修改hosts配置文件
[root@rabbitmq-1 ~]# hostnamectl set-hostname rabbitmq-1
[root@rabbitmq-1 ~]# vim /etc/hosts
127.0.0.1 localhost localhost.localdomain localhost4 localhost4.localdomain4
::1 localhost localhost.localdomain localhost6 localhost6.localdomain6
192.168.19.129 rabbitmq-1
192.168.19.130 rabbitmq-2
192.168.19.131 rabbitmq-3
[root@rabbitmq-1 ~]# systemctl stop firewalld;setenforce 0
三个节点配置安装rabbitmq软件
#安装依赖
[root@rabbitmq-1 ~]# yum install -y *epel* gcc-c++ unixODBC unixODBC-devel openssl-devel ncurses-devel wget
[root@rabbitmq-1 ~]# cd /usr/src/
#yum安装erlang
[root@rabbitmq-1 src]# wget --content-disposition https://packagecloud.io/rabbitmq/erlang/packages/el/7/erlang-20.3-1.el7.centos.x86_64.rpm/download.rpm
[root@rabbitmq-1 src]# ls
debug erlang-20.3-1.el7.centos.x86_64.rpm kernels
[root@rabbitmq-1 src]# yum -y install erlang-20.3-1.el7.centos.x86_64.rpm
#测试
[root@rabbitmq-1 src]# erl
Erlang/OTP 20 [erts-9.3] [source] [64-bit] [smp:1:1] [ds:1:1:10] [async-threads:10] [hipe] [kernel-poll:false]
Eshell V9.3 (abort with ^G)
1>
#安装rabbitmq
[root@rabbitmq-1 src]# wget https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7.5/rabbitmq-server-3.7.5-1.el7.noarch.rpm
[root@rabbitmq-1 src]# ls
debug erlang-20.3-1.el7.centos.x86_64.rpm kernels rabbitmq-server-3.7.5-1.el7.noarch.rpm
[root@rabbitmq-1 src]# yum -y install rabbitmq-server-3.7.5-1.el7.noarch.rpm
#启动
[root@rabbitmq-1 src]# systemctl daemon-reload
[root@rabbitmq-1 src]# systemctl start rabbitmq-server
[root@rabbitmq-1 src]# systemctl enable rabbitmq-server
[root@rabbitmq-1 src]# systemctl status rabbitmq-server
#开启rabbitmq的web访问界面
[root@rabbitmq-1 src]# rabbitmq-plugins enable rabbitmq_management
The following plugins have been configured:
rabbitmq_management
rabbitmq_management_agent
rabbitmq_web_dispatch
Applying plugin configuration to rabbit@rabbitmq-1...
The following plugins have been enabled:
rabbitmq_management
rabbitmq_management_agent
rabbitmq_web_dispatch
started 3 plugins.
#添加用户和密码
###在一台机器上操作
[root@rabbitmq-1 src]# rabbitmqctl add_user rabbit1 rabbit
Adding user "rabbit1" ...
#设置用户为管理员
[root@rabbitmq-1 src]# rabbitmqctl set_user_tags rabbit1 administrator
Setting tags for user "rabbit1" to [administrator] ...
#查看用户
[root@rabbitmq-1 src]# rabbitmqctl list_users
Listing users ...
rabbit1 [administrator]
guest [administrator]
#设置权限
[root@rabbitmq-1 src]# rabbitmqctl set_permissions -p "/" rabbit1 ".*" ".*" ".*"
Setting permissions for user "rabbit1" in vhost "/" ...
此处设置权限时注意'.*'之间需要有空格 三个'.*'分别代表了conf权限,read权限与write权限
例如:当没有给rabbit1设置这三个权限前是没有权限查询队列,在ui界面也看不见
#开启用户远程登陆
[root@rabbitmq-1 src]# cp /usr/share/doc/rabbitmq-server-3.7.5/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config
[root@rabbitmq-1 src]# cd /etc/rabbitmq
[root@rabbitmq-1 rabbitmq]# ls
enabled_plugins rabbitmq.config
[root@rabbitmq-1 rabbitmq]# vim rabbitmq.config
{loopback_users, []}
#重启服务
[root@rabbitmq-1 rabbitmq]# systemctl restart rabbitmq-server
4369 -- erlang端口
5672 -- 程序连接端口
15672 -- 管理界面ui端口
25672 -- server间内部通信端口
访问测试:http://192.168.19.129:15672/
rabbitmq默认管理员用户:guest 密码:guest
新添加的用户为:rabbi1 密码:rabbit
开始部署集群三台机器都操作
[root@rabbitmq-1 rabbitmq]# mkdir -p /data/rabbitmq/data
[root@rabbitmq-1 rabbitmq]# mkdir -p /data/rabbitmq/logs
[root@rabbitmq-1 rabbitmq]# chmod -R 777 /data/rabbitmq/
[root@rabbitmq-1 rabbitmq]# chown -R rabbitmq.rabbitmq /data/rabbitmq/
[root@rabbitmq-1 rabbitmq]# ll /data/rabbitmq/
总用量 0
drwxrwxrwx. 2 rabbitmq rabbitmq 6 4月 6 14:29 data
drwxrwxrwx. 2 rabbitmq rabbitmq 6 4月 6 14:29 logs
#新建配置文件
[root@rabbitmq-1 rabbitmq]# vim /etc/rabbitmq/rabbitmq-env.conf
RABBITMQ_MNESIA_BASE=/data/rabbitmq/data
RABBITMQ_LOG_BASE=/data/rabbitmq/logs
#重启服务
[root@rabbitmq-1 rabbitmq]# systemctl restart rabbitmq-server
1. 拷贝erlang.cookie
Rabbitmq的集群是依附于erlang的集群来工作的,所以必须先构建起erlang的集群。Erlang的集群中
各节点是经由各个cookie来实现的,这个cookie存放在/var/lib/rabbitmq/.erlang.cookie中,文件是400的权限。所以必须保证各节点cookie一致,不然节点之间就无法通信.
(官方在介绍集群的文档中提到过.erlang.cookie 一般会存在这两个地址:第一个是home/.erlang.cookie;第二个地方就是/var/lib/rabbitmq/.erlang.cookie。如果我们使用解压缩方式安装部署的rabbitmq,那么这个文件会在{home}目录下,也就是$home/.erlang.cookie。如果我们使用rpm等安装包方式进行安装的,那么这个文件会在/var/lib/rabbitmq目录下。)
#权限属主属组如下
[root@rabbitmq-1 rabbitmq]# ll /var/lib/rabbitmq/.erlang.cookie
-r--------. 1 rabbitmq rabbitmq 20 4月 6 00:00 /var/lib/rabbitmq/.erlang.cookie
[root@rabbitmq-1 rabbitmq]# cat /var/lib/rabbitmq/.erlang.cookie
VIMPZJSWETYQJIZWBVKX
#使用scp的方式将rabbitmq-1节点的.erlang.cookie的值复制到其他两个节点中
[root@rabbitmq-1 rabbitmq]# scp /var/lib/rabbitmq/.erlang.cookie root@192.168.19.130:/var/lib/rabbitmq/
[root@rabbitmq-1 rabbitmq]# scp /var/lib/rabbitmq/.erlang.cookie root@192.168.19.131:/var/lib/rabbitmq/
#另外两台查看
[root@rabbitmq-2 rabbitmq]# cat /var/lib/rabbitmq/.erlang.cookie
VIMPZJSWETYQJIZWBVKX
[root@rabbitmq-3 rabbitmq]# cat /var/lib/rabbitmq/.erlang.cookie
VIMPZJSWETYQJIZWBVKX
2. 将mq-2、mq-3作为内存节点加到mq-1节点集群中
#在mq-2、mq-3执行如下命令
[root@rabbitmq-2 rabbitmq]# systemctl restart rabbitmq-server
[root@rabbitmq-2 rabbitmq]# rabbitmqctl stop_app
Stopping rabbit application on node rabbit@rabbitmq-2 ...
[root@rabbitmq-2 rabbitmq]# rabbitmqctl reset
Resetting node rabbit@rabbitmq-2 ...
#将两个节点加入集群,指定角色
#添加到内存节点
[root@rabbitmq-2 rabbitmq]# rabbitmqctl join_cluster --ram rabbit@rabbitmq-1 #rabbitmq-1为解析的名称注意前面rabbit不是用户
Clustering node rabbit@rabbitmq-2 with rabbit@rabbitmq-1
#启动节点
[root@rabbitmq-2 rabbitmq]# rabbitmqctl start_app
Starting node rabbit@rabbitmq-2 ...
completed with 3 plugins.
(1)默认rabbitmq启动后是磁盘节点,在这个cluster命令下,mq-2和mq-3是内存节点,
mq-1是磁盘节点。
(2)如果要使mq-2、mq-3都是磁盘节点,去掉--ram参数即可。
(3)如果想要更改节点类型,可以使用命令rabbitmqctl change_cluster_node_type
disc(ram),前提是必须停掉rabbitmq应用
注:
#如果有需要使用磁盘节点加入集群
[root@rabbitmq-2 ~]# rabbitmqctl join_cluster rabbit@rabbitmq-1
[root@rabbitmq-3 ~]# rabbitmqctl join_cluster rabbit@rabbitmq-1
3. 查看集群状态
在 RabbitMQ 集群任意节点上执行 rabbitmqctl cluster_status
来查看是否集群配置成功。
#在mq-1磁盘节点上面查看
[root@rabbitmq-1 rabbitmq]# rabbitmqctl cluster_status
Cluster status of node rabbit@rabbitmq-1 ...
[{nodes,[{disc,['rabbit@rabbitmq-1']}, #磁盘节点
{ram,['rabbit@rabbitmq-3','rabbit@rabbitmq-2']}]}, #内存节点
{running_nodes,['rabbit@rabbitmq-3','rabbit@rabbitmq-2','rabbit@rabbitmq-1']}, #集群中节点
{cluster_name,<<"rabbit@rabbitmq-2">>}, #集群名称
{partitions,[]},
{alarms,[{'rabbit@rabbitmq-3',[]},
{'rabbit@rabbitmq-2',[]},
{'rabbit@rabbitmq-1',[]}]}]
每台机器显示出三台节点,表示已经添加成功!
4. 登录rabbitmq web管理控制台,创建新的队列
访问http://192.168.19.129:15672/
image.png根据提示创建队列
image.png创建成功
image.png