开发笔记:Rabbitmq群集搭建

实验介绍

MQ（Message Queue消息队列）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用链接来连接他们。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队指的是应用程序通过队列来通信。队列的使用除去接收和发送应用程序同时执行的要求。

RabbitMQ是实现AMQP（高级消息队列协议）的消息中间件的一种，最初起源于金融系统，用于在分布式系统中存储转发消息，在易用性、扩展性、高可用性等方面表现不俗。RabbitMQ主要是为了实现系统之间的双向解耦而实现的。当生产者大量产生数据时，消费者无法快速消费，那么需要一个中间层。保存这个数据。

AMQP，即Advanced Message Queuing Protocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。消息中间件主要用于组件之间的解耦，消息的发送者无需知道消息使用者的存在，反之亦然。AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。

MQ实际应用

RabbitMQ使用Erlang开发的，集群非常方便，因为Erlang天生就是一门分布式语言，但其本身并不支持负载均衡。RabbitMQ模式大概分为三种：

• 单一模式


• 普通模式（默认就是集群模式）


• 镜像模式（把需要的队列做成镜像队列，存在于多个节点，属于RabbitMQ的HA方案，在对业务可靠性较高的场合中比较适用）
  要实现镜像模式，首先需要搭建一个普通集群模式，在这个模式的基础上再配置镜像模式以实现高可用。

试验环境

实验部署

首先我们需要配置三个节点的hosts文件，将下面内容分别加入到三台服务器上。

[[email&＃160;protected] /]# vim /etc/hosts
192.168.58.141 rabbitmq01
192.168.58.132 rabbitmq02
192,168.58.130 rabbitmq03

然后需要修改三个节点的主机名，修改每个节点的/etc/hostname文件

[[email&＃160;protected] /]# vim /etc/hostname
rabbitmq01

[[email&＃160;protected] /]# vim /etc/hostname
rabbitmq02

[[email&＃160;protected] /]# vim /etc/hostname
rabbitmq03

然后将三个节点重启，当启动以后要关闭防火墙和增强性安全功能。

[[email&＃160;protected] /]# systemctl stop firewalld.service
[[email&＃160;protected] /]# setenforce 0
[[email&＃160;protected] /]# yum install -y epel-release #安装epel源
[[email&＃160;protected] /]# yum install -y rabbitmq-server #安装rabbitmq软件包
[[email&＃160;protected] /]# ln -s /usr/lib/rabbitmq/bin/* /usr/bin #建立软链接，方便直接使用命令
[[email&＃160;protected] /]# rabbitmq-plugins list #查看插件安装情况
[e] amqp_client 3.3.5
[ ] cowboy 0.5.0-rmq3.3.5-git4b93c2d
[ ] eldap 3.3.5-gite309de4
[e] mochiweb 2.7.0-rmq3.3.5-git680dba8
[ ] rabbitmq_amqp1_0 3.3.5
[ ] rabbitmq_auth_backend_ldap 3.3.5
[ ] rabbitmq_auth_mechanism_ssl 3.3.5
[ ] rabbitmq_consistent_hash_exchange 3.3.5
[ ] rabbitmq_federation 3.3.5
[ ] rabbitmq_federation_management 3.3.5
[E] rabbitmq_management 3.3.5
[e] rabbitmq_management_agent 3.3.5
[ ] rabbitmq_management_visualiser 3.3.5
[ ] rabbitmq_mqtt 3.3.5
[ ] rabbitmq_shovel 3.3.5
[ ] rabbitmq_shovel_management 3.3.5
[ ] rabbitmq_stomp 3.3.5
[ ] rabbitmq_test 3.3.5
[ ] rabbitmq_tracing 3.3.5
[e] rabbitmq_web_dispatch 3.3.5
[ ] rabbitmq_web_stomp 3.3.5
[ ] rabbitmq_web_stomp_examples 3.3.5
[ ] sockjs 0.3.4-rmq3.3.5-git3132eb9
[e] webmachine 1.10.3-rmq3.3.5-gite9359c7
[[email&＃160;protected] /]# rabbitmq-plugins enable rabbitmq_management
#启用rabbitmq_management服务
[[email&＃160;protected] /]# systemctl start rabbitmq-server.service #启动mq服务
[[email&＃160;protected] /]# netstat -ntap | grep 5672
tcp 0 0 0.0.0.0:15672 0.0.0.0:* LISTEN 3878/beam
tcp 0 0 0.0.0.0:25672 0.0.0.0:* LISTEN 3878/beam
tcp6 0 0 :::5672 :::* LISTEN 3878/beam

有上面三个端口开启说明正常。15672和55672都是rabbitmq的管理端口，5672是生产者、消费者通信的端口。

[[email&＃160;protected] /]# rabbitmqctl cluster_status
Cluster status of node [email&＃160;protected] ...
[{nodes,[{disc,[[email&＃160;protected]]}]},
{running_nodes,[[email&＃160;protected]]},
{cluster_name,<<"[email&＃160;protected]">>},
{partitions,[]}]
...done.
#检查三台的集群状态，目前相互独立，没有形成集群。
[[email&＃160;protected] /]# vim /var/lib/rabbitmq/.erlang.COOKIE
#三台节点服务器的这个文件中的编码需要配置成一样的，复制内容到其他两台
PKBPLZGDCESRUHHDCOJV

然后将rabbitmq02、rabbitmq03作为内存节点与rabbitmq01磁盘节点连接起来，在rabbitmq02和rabbit03上执行下面的命令：

[[email&＃160;protected] ~]# rabbitmqctl join_cluster --ram [email&＃160;protected]
Clustering node [email&＃160;protected] with [email&＃160;protected] ...
...done.
[[email&＃160;protected] yum.repos.d]# rabbitmqctl join_cluster --ram [email&＃160;protected]
Clustering node [email&＃160;protected] with [email&＃160;protected] ...
...done.

在rabbitmq01节点上查看集群状态：

[[email&＃160;protected] /]# rabbitmqctl cluster_status
Cluster status of node [email&＃160;protected] ...
[{nodes,[{disc,[[email&＃160;protected]]},
{ram,[[email&＃160;protected],[email&＃160;protected]]}]},
{running_nodes,[[email&＃160;protected]]},
{cluster_name,<<"[email&＃160;protected]">>},
{partitions,[]}]
...done.
#可以看到集群中的成员

打开浏览器输入http://192.168.58.141:15672,可以看到访问页面，账号密码都是guest，进入到里面就能看到图形化的界面。