码迷,mamicode.com
首页 > 其他好文 > 详细

Rabbitmq群集搭建

时间:2018-08-01 11:48:48      阅读:164      评论:0      收藏:0      [点我收藏+]

标签:金融系统   包括   hash   tab   release   使用命令   one   分布式系统   ram   

Rabbitmq群集搭建

实验介绍

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

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

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

MQ实际应用

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

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

试验环境

IP地址 主机名 操作系统 用途
192.168.58.141 rabbitmq01 CentOS7 磁盘节点
192.168.58.132 rabbitmq02 CentOS7 内存节点
192.168.58.130 rabbitmq03 CentOS7 内存节点

实验部署

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

[root@rabbitmq01 /]# vim /etc/hosts
192.168.58.141 rabbitmq01
192.168.58.132 rabbitmq02
192,168.58.130 rabbitmq03

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

[root@rabbitmq01 /]# vim /etc/hostname 
rabbitmq01
[root@rabbitmq02 /]# vim /etc/hostname 
rabbitmq02
[root@rabbitmq03 /]# vim /etc/hostname 
rabbitmq03

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

[root@rabbitmq01 /]# systemctl stop firewalld.service
[root@rabbitmq01 /]# setenforce 0
[root@rabbitmq01 /]# yum install -y epel-release  #安装epel源
[root@rabbitmq01 /]# yum install -y rabbitmq-server  #安装rabbitmq软件包
[root@rabbitmq01 /]# ln -s /usr/lib/rabbitmq/bin/* /usr/bin   #建立软链接,方便直接使用命令
[root@rabbitmq01 /]# 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

[root@rabbitmq01 /]# rabbitmq-plugins enable rabbitmq_management
#启用rabbitmq_management服务
[root@rabbitmq01 /]# systemctl start rabbitmq-server.service   #启动mq服务
[root@rabbitmq01 /]# 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是生产者、消费者通信的端口。

[root@rabbitmq01 /]# rabbitmqctl cluster_status
Cluster status of node rabbit@rabbitmq01 ...
[{nodes,[{disc,[rabbit@rabbitmq01]}]},
 {running_nodes,[rabbit@rabbitmq01]},
 {cluster_name,<<"rabbit@rabbitmq01">>},
 {partitions,[]}]
...done.
#检查三台的集群状态,目前相互独立,没有形成集群。

[root@rabbitmq01 /]# vim /var/lib/rabbitmq/.erlang.cookie 
#三台节点服务器的这个文件中的编码需要配置成一样的,复制内容到其他两台
PKBPLZGDCESRUHHDCOJV

技术分享图片
技术分享图片
技术分享图片
然后将rabbitmq02、rabbitmq03作为内存节点与rabbitmq01磁盘节点连接起来,在rabbitmq02和rabbit03上执行下面的命令:

[root@rabbitmq02 ~]# rabbitmqctl join_cluster --ram rabbit@rabbitmq01
Clustering node rabbit@rabbitmq02 with rabbit@rabbitmq01 ...
...done.
[root@rabbitmq03 yum.repos.d]# rabbitmqctl join_cluster --ram rabbit@rabbitmq01
Clustering node rabbit@rabbitmq03 with rabbit@rabbitmq01 ...
...done.

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

[root@rabbitmq01 /]# rabbitmqctl cluster_status
Cluster status of node rabbit@rabbitmq01 ...
[{nodes,[{disc,[rabbit@rabbitmq01]},
         {ram,[rabbit@rabbitmq03,rabbit@rabbitmq02]}]},
 {running_nodes,[rabbit@rabbitmq01]},
 {cluster_name,<<"rabbit@rabbitmq01">>},
 {partitions,[]}]
...done.
#可以看到集群中的成员

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

Rabbitmq群集搭建

标签:金融系统   包括   hash   tab   release   使用命令   one   分布式系统   ram   

原文地址:http://blog.51cto.com/10693404/2152982

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!