加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 综合聚焦 > 服务器 > 安全 > 正文

rabbimtq消息队列部署

发布时间:2020-12-16 01:53:55 所属栏目:安全 来源:网络整理
导读:前期准备 第一步:下载 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 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)
[[email?protected] ~]# rabbitmqctl change_password guest zxw6
?
?
?第六步:zxw6:编辑rabbittmq变量文件
[[email?protected] ~]# 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,<<5000:64/native>>}]"
RABBITMQ_NODE_IP_ADDRESS=192.168.126.6

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

修改ip为
[[email?protected] ~]# vim /etc/rabbitmq/rabbitmq-env.conf
RABBITMQ_NODE_IP_ADDRESS=192.168.126.7

[[email?protected] ~]# scp /etc/rabbitmq/rabbitmq-env.conf zxw8: /etc/rabbitmq/

修改IP为
[[email?protected] ~]# 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,[[email?protected]]}]},节点
{running_nodes,[[email?protected]]},运行节点
{cluster_name,<<"[email?protected]">>},集群名字
{partitions,[]},
{alarms,[{[email?protected],[]}]}]

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

第十四步:重启zxw7和zxw8主机,
[[email?protected] ~]# systemctl restart rabbitmq-server.service
[[email?protected] ~]# systemctl restart rabbitmq-server.service

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

[[email?protected] ~]# rabbitmqctl stop_app
Stopping node [email?protected] ...
您在 /var/spool/mail/root 中有新邮件
[[email?protected] ~]# rabbitmqctl cluster_status
Cluster status of node [email?protected] ...
[{nodes,[[email?protected]]}]},[]}]
[[email?protected] ~]# rabbitmqctl join_cluster --ram [email?protected]
Clustering node [email?protected] with [email?protected] ...
[[email?protected] ~]# rabbitmqctl start_app
Starting node [email?protected] ...
[[email?protected] ~]# rabbitmqctl cluster_status
Cluster status of node [email?protected] ...
[{nodes,[[email?protected]]},[[email?protected],[email?protected]]}]},[[email?protected],[email?protected],[email?protected]]},<<"[email?protected]">>},

第十六步:zxw6检查集群状态
?
[[email?protected] ~]# rabbitmqctl cluster_status
Cluster status of node [email?protected] ...
[{nodes,[[email?protected]]},[[email?protected],[email?protected]]}]},[[email?protected],[email?protected],[email?protected]]},<<"[email?protected]">>},[{[email?protected],{[email?protected],{[email?protected],[]}]}]
第十七步:

?

?

?

?

?
?
其他命令:
(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 [email?protected]
rabbitmqctl reset
rabbitmqctl start_app
rabbitmqctl cluster_status
?
1. 保证集群中至少有一个磁盘类型的节点以防数据丢失,在更改节点类型时尤其要注意。
2. 若整个集群被停掉了,应保证最后一个 down 掉的节点被最先启动,若不能则要使用 forget_cluster_node 命令将其移出集群
3. 若集群中节点几乎同时以不可控的方式 down 了此时在其中一个节点使用 force_boot 命令重启节点

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读