rabbimtq消息队列部署

Posted 2022-06-29 itzhao

前期准备
第一步：下载
yum install ntp -y
所以机器做个时间同步
vim /etc/ntp.conf
都删除然后编辑
server 127.127.1.0
restrict 127.0.0.1 查看cat /etc/hosts
restrict 192.168.126.6 mask 255.255.255.0
第四步：重启
systemctl restart ntpd
共享端
第一步：下载
yum install ntpdate -y
第二步 ：同步时间
ntpdate 192.168.126.6
第三步：查看
date

编写计划任务
crontab -e
*/5 * * * * /usr/sbin/ntpdate 192.168.126.6

域名解析
  vim /etc/resolv.conf

 
（3）node1：添加一个openstack的用户，并设密码为admin。并设置权限和成为管理员
node1：
rabbitmqctl add_user openstack admin
rabbitmqctl set_permissions openstack ".*" ".*" ".*"
rabbitmqctl set_user_tags openstack administrator
（1）条件:准备3台linux系统，确保配置好源，及epel源
 
（2）三台机器能够静态解析彼此
cat /etc/hosts
192.168.126.6 zxw6
192.168.126.7 zxw7
192.168.126.8 zxw8
192.168.126.99 zxw99

（3）设置可以无密钥登陆到所有主机
ssh-keygen
ssh-copy-id 192.168.126.7

二、安装过程：
 
第一步：所有主机下载rabbitmq 和erlang
yum install -y erlang rabbitmq-server.noarch

第二步：启动所以主机的rabbitmq
systemctl start rabbitmq-server.service

第三步：查看状态
systemctl status rabbitmq-server.service
 
第四步：查看监听端口：
ss -tnl | grep 5672
LISTEN 0 128 *:25672 *:*
LISTEN 0 128 :::5672 :::*

netstat -lantp | grep 5672
tcp 0 0 0.0.0.0:25672 0.0.0.0:* LISTEN 3693/beam.smp
tcp6 0 0 :::5672 :::* LISTEN 3693/beam.smp

配置文件路径：/etc/rabbitmq/rabbitmq.config
 
第五步：zxw6：修改guest密码为zxw6（默认用户为：guest 密码为：guest)
[root@zxw6 ~]# rabbitmqctl change_password guest zxw6
 
 
 第六步：zxw6：编辑rabbittmq变量文件
[root@zxw6 ~]# vim /etc/rabbitmq/rabbitmq-env.conf

RABBITMQ_NODE_PORT=5672
ulimit -S -n 4096
RABBITMQ_SERVER_ERL_ARGS="+K true +A30 +P 1048576 -kernel inet_default_connect_options [nodelay,true,raw,6,18,<<5000:64/native>>] -kernel inet_default_listen_options [raw,6,18,<<5000:64/native>>]"
RABBITMQ_NODE_IP_ADDRESS=192.168.126.6

第七步：zxw6：将rabbittmq变量文件拷贝到其他两节点，之后并修改相应节点的ip
[root@zxw6 ~]# scp /etc/rabbitmq/rabbitmq-env.conf zxw7: /etc/rabbitmq/

修改ip为
[root@zxw7 ~]# vim /etc/rabbitmq/rabbitmq-env.conf
RABBITMQ_NODE_IP_ADDRESS=192.168.126.7

[root@zxw6 ~]# scp /etc/rabbitmq/rabbitmq-env.conf zxw8: /etc/rabbitmq/

修改IP为
[root@zxw8 ~]# vim /etc/rabbitmq/rabbitmq-env.conf
RABBITMQ_NODE_IP_ADDRESS=192.168.126.8

第八步：查看rabbitmq插件
rabbitmq-plugins list /usr/lib/rabbitmq/bin/rabbitmq-plugins list
 

第九步：所有主机 开启rabbitmq的web管理页面
/usr/lib/rabbitmq/bin/rabbitmq-plugins enable rabbitmq_management mochiweb webmachine rabbitmq_web_dispatch amqp_client rabbitmq_management_agent
或者：
rabbitmq-plugins enable rabbitmq_management

 

第十步：重启rabbitmq并查看状态
systemctl restart rabbitmq-server.service
systemctl status rabbitmq-server.service

第十一步：进行访问

 

 

 
第十二步：查看集群运行状态
rabbitmqctl cluster_status
[nodes,[disc,[rabbit@zxw6]], 节点
running_nodes,[rabbit@zxw6], 运行节点
cluster_name,<<"rabbit@zxw6">>, 集群名字
partitions,[],
alarms,[rabbit@zxw6,[]]]

第十三步：zxw6发送erlang.cookie（认证）到其他节点配置集群
[root@zxw6 ~]# cat /var/lib/rabbitmq/.erlang.cookie
CYCRJBVYHICBYKXJINJL
 
[root@zxw6 ~]# scp /var/lib/rabbitmq/.erlang.cookie zxw7:/var/lib/rabbitmq/
root@zxw7‘s password:
.erlang.cookie 100% 20 0.0KB/s 00:00
[root@zxw6 ~]# scp /var/lib/rabbitmq/.erlang.cookie zxw8:/var/lib/rabbitmq/
root@zxw8‘s password:
.erlang.cookie 100% 20 0.0KB/s 00:00

第十四步：重启zxw7和zxw8主机，
[root@zxw7 ~]# systemctl restart rabbitmq-server.service
[root@zxw8 ~]# systemctl restart rabbitmq-server.service

第十五步：zxw7和zxw8以ram的方式加入zxw6节点，之后重启应用
 
[root@zxw7 ~]# rabbitmqctl stop_app 停止节点
Stopping node rabbit@zxw7 ...
[root@zxw7 ~]# rabbitmqctl cluster_statu 查看节点状态
Cluster status of node rabbit@zxw7 ...
[nodes,[disc,[rabbit@zxw7]],alarms,[]]
[root@zxw7 ~]# rabbitmqctl join_cluster --ram rabbit@zxw6
添加zxw7到zxw6节点集群
Clustering node rabbit@zxw7 with rabbit@zxw6 ...
[root@zxw7 ~]# rabbitmqctl start_app 开启节点
Starting node rabbit@zxw7 ...
[root@zxw7 ~]# rabbitmqctl cluster_status 再次查看状态
Cluster status of node rabbit@zxw7 ...
[nodes,[disc,[rabbit@zxw6],ram,[rabbit@zxw7]],
running_nodes,[rabbit@zxw6,rabbit@zxw7],
cluster_name,<<"rabbit@zxw6">>,
partitions,[],
alarms,[rabbit@zxw6,[],rabbit@zxw7,[]]]

[root@zxw8 ~]# rabbitmqctl stop_app
Stopping node rabbit@zxw8 ...
您在 /var/spool/mail/root 中有新邮件
[root@zxw8 ~]# rabbitmqctl cluster_status
Cluster status of node rabbit@zxw8 ...
[nodes,[disc,[rabbit@zxw8]],alarms,[]]
[root@zxw8 ~]# rabbitmqctl join_cluster --ram rabbit@zxw6
Clustering node rabbit@zxw8 with rabbit@zxw6 ...
[root@zxw8 ~]# rabbitmqctl start_app
Starting node rabbit@zxw8 ...
[root@zxw8 ~]# rabbitmqctl cluster_status
Cluster status of node rabbit@zxw8 ...
[nodes,[disc,[rabbit@zxw6],ram,[rabbit@zxw8,rabbit@zxw7]],
running_nodes,[rabbit@zxw7,rabbit@zxw6,rabbit@zxw8],
cluster_name,<<"rabbit@zxw6">>,
partitions,[],

第十六步：zxw6检查集群状态
 
[root@zxw6 ~]# rabbitmqctl cluster_status
Cluster status of node rabbit@zxw6 ...
[nodes,[disc,[rabbit@zxw6],ram,[rabbit@zxw8,rabbit@zxw7]],
running_nodes,[rabbit@zxw8,rabbit@zxw7,rabbit@zxw6],
cluster_name,<<"rabbit@zxw6">>,
partitions,[],
alarms,[rabbit@zxw8,[],rabbit@zxw7,[],rabbit@zxw6,[]]]
第十七步：

 

 

 

 

 
 
其他命令：
（1）添加管理员：
rabbitmqctl add_user mqadmin mqadmin
添加用户

rabbitmqctl set_user_tags mqadmin administrator
设置类型

rabbitmqctl set_permissions -p / mqadmin ".*" ".*" ".*"
给予权限

rabbitmqctl list_users
查看用户详细信息

rabbitmqctl change_password guest zxw6
修个密码

（2）更改节点类型（内存型或磁盘型）
rabbitmqctl stop_app
rabbitmqctl change_cluster_node_type disc 或
rabbitmqctl change_cluster_node_type ram
rabbitmqctl start_app
 
（3）从集群移除节点（或者重置节点）
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl start_app
rabbitmqctl cluster_status
 
（4）从某个节点移除集群中其他节点
rabbitmqctl stop_app
rabbitmqctl forget_cluster_node rabbit@node3
rabbitmqctl reset
rabbitmqctl start_app
rabbitmqctl cluster_status
 
1. 保证集群中至少有一个磁盘类型的节点以防数据丢失，在更改节点类型时尤其要注意。
2. 若整个集群被停掉了，应保证最后一个 down 掉的节点被最先启动，若不能则要使用 forget_cluster_node 命令将其移出集群
3. 若集群中节点几乎同时以不可控的方式 down 了此时在其中一个节点使用 force_boot 命令重启节点