千万PV----RabbitMQ集群配置

时间：2018-10-16 17:46:12 阅读：164 评论：0 收藏：0 [点我收藏+]

RabbitMQ简介：
RabbitMQ是一个消息代理(message broker)，主要功能就是接收和转发消息。向RabbitMQ发送消息的程序叫做Producer（生产者）。从队列接收消息的程序叫做Consumer（消费者）。
队列(queue)用来存储消息，可以理解成一个无限容量的缓冲区。多个Producer可以向一个队列发送消息，多个Consumer也可以从一个队列接收消息。
技术分享图片

实验环境配置：（操作系统：CentOS7）
rabbitma01 192.168.120.138（磁盘节点）
rabbitma02 192.168.120.139（内存节点）
rabbitma03 192.168.120.140（内存节点）
--------------使用Centos7.4自带的YUM源安装--三台都一样------需要公网环境-------

#更改主机名
[root@localhost ~]# vim /etc/hostname
mq01.localdomain （操作相同，只是主机名01、02、03）
[root@localhost ~]# vim /etc/hosts
192.168.120.138 mq01
192.168.120.139 mq02
192.168.120.140 mq03
#重启系统
[root@localhost ~]#init 6
#三台防火墙都关闭
[root@mq01 ~]# systemctl stop firewalld.service
[root@mq01 ~]# setenforce 0
[root@mq01 ~]# yum install epel-release -y
[root@mq01 ~]# yum install rabbitmq-server -y
--------------------磁盘节点01-------------------------
#优化路径
[root@mq01 ~]# ln -s /usr/lib/rabbitmq/bin/ /usr/bin/
[root@mq01 ~]# rabbitmq-plugins list
#开启rabbitmq
[root@mq01 ~]# rabbitmq-plugins enable rabbitmq_management
[root@mq01 ~]# systemctl start rabbitmq-server.service
[root@mq01 ~]# rabbitmqctl cluster_status
Cluster status of node rabbit@mq01 ...br/>[{nodes,[{disc,[rabbit@mq01]}]},
{running_nodes,[rabbit@mq01]},br/>{cluster_name,<<"rabbit@mq01">>},
{partitions,[]}]
...done. ###连接成功###
[root@mq01 ~]# netstat -ntap | grep 5672
tcp 0 0 0.0.0.0:15672 0.0.0.0: LISTEN 3018/beam
tcp 0 0 0.0.0.0:25672 0.0.0.0: LISTEN 3018/beam
tcp6 0 0 :::5672 ::: LISTEN 3018/beam

---------------------内存节点02----------------------------
[root@mq02 ~]# ln -s /usr/lib/rabbitmq/bin/* /usr/bin/
[root@mq02 ~]# rabbitmq-plugins enable rabbitmq_management
[root@mq02 ~]# systemctl start rabbitmq-server.service
[root@mq02 ~]# rabbitmqctl cluster_status
Cluster status of node rabbit@mq02 ...br/>[{nodes,[{disc,[rabbit@mq02]}]},
{running_nodes,[rabbit@mq02]},br/>{cluster_name,<<"rabbit@mq02">>},
{partitions,[]}]
...done.

--------------------内存节点03-----------------------------------
[root@mq03 ~]# ln -s /usr/lib/rabbitmq/bin/* /usr/bin/
[root@mq03 ~]# rabbitmq-plugins enable rabbitmq_management
[root@mq03 ~]# systemctl start rabbitmq-server.service
[root@mq03 ~]# rabbitmqctl cluster_status
Cluster status of node rabbit@mq03 ...br/>[{nodes,[{disc,[rabbit@mq03]}]},
{running_nodes,[rabbit@mq03]},br/>{cluster_name,<<"rabbit@mq03">>},
{partitions,[]}]
...done.
####操作都相同#####
##关闭三台rabbitmq服务##
[root@mq01 ~]# systemctl stop rabbitmq-server.service

##进入第一台##
[root@mq01 ~]# vim /var/lib/rabbitmq/.erlang.cookie
SNBTPYOBNPXOMBFNWAZA ##（复制序列号）

##进入第二台##
[root@mq02 ~]# vim /var/lib/rabbitmq/.erlang.cookie
SNBTPYOBNPXOMBFNWAZA ##将第一台的序列号复制粘贴下来，要一致
##进入第三台##
[root@mq03 ~]# vim /var/lib/rabbitmq/.erlang.cookie
SNBTPYOBNPXOMBFNWAZA ##都和第一台一致

##三台服务启动##
[root@mq01 ~]# systemctl start rabbitmq-server.service
================在02、03上操作-----内存节点=======
[root@mq02 ~]# rabbitmqctl stop_app
Stopping node rabbit@mq02 ...
...done.
##以内存模式进行添加##
[root@mq02 ~]# rabbitmqctl join_cluster --ram rabbit@mq01
Clustering node rabbit@mq02 with rabbit@mq01 ...
...done.
##开启app##
[root@mq02 ~]# rabbitmqctl start_app
Starting node rabbit@mq02 ...
...done.

##第三台同样操作##
[root@mq03 ~]# rabbitmqctl stop_app
Stopping node rabbit@mq03 ...
...done.
[root@mq03 ~]# rabbitmqctl join_cluster --ram rabbit@mq01
Clustering node rabbit@mq03 with rabbit@mq01 ...
...done.
##开启app##
[root@mq03 ~]# rabbitmqctl start_app
Starting node rabbit@mq03 ...
...done.
###验证群集状态###
[root@mq01 ~]# rabbitmqctl cluster_status
Cluster status of node rabbit@mq01 ...br/>[{nodes,[{disc,[rabbit@mq01]},{ram,[rabbit@mq03,rabbit@mq02]}]},
{running_nodes,[rabbit@mq03,rabbit@mq02,rabbit@mq01]},br/>{cluster_name,<<"rabbit@mq01">>},
{partitions,[]}]
...done.