在CentOS7上部署Rabbitmq集群配置

在CentOS7上部署Rabbitmq集群配置

概述

RabbitMQ是目前流行的开源消息队列系统。MQ（消息队列）是一种应用程序对应用程序的通信方法。

RabbitMQ的结构图如图所示：

实现步骤

在一个集群里，有三台服务器，其中一台使用磁盘模式，另两台使用内存模式。两台内存模式的节点无疑速度更快，因此通过客户端连接访问它们。但是客户端不可能分别连接两个内存节点，肯定是通过前端反向代理去轮询分发请求如果担心前端反向代理服务器故障，可以通过Keepalived软件做一个高可用架构。而磁盘模式的节点，由于磁盘IO相对较慢，因此仅作数据备份使用。

注意：将三台服务器都连接上互联网并安装软件包。另外RabbitMQ集群节点必须在同一个网段里，如果是跨广域网，效果就会变差。

RabbitMQ集群配置信息如表所示表：

实验步骤

1.配置三个节点的host文件，将以下内容分别加入到三台服务器上。

rabbitmq01: [root@localhost ~]# vim /etc/hostname mq01.localdomain [root@localhost ~]# vim /etc/hosts 192.168.126.138 mq01 #注意-主机名称也要更改 192.168.126.133 mq02 192.168.126.141 mq03 rabbitmq02: [root@localhost ~]# vim /etc/hostname mq02.localdomain [root@localhost ~]# vim /etc/hosts 192.168.126.138 mq01 192.168.126.133 mq02 192.168.126.141 mq03 rabbitmq03: [root@localhost ~]# vim /etc/hostname mq03.localdomain [root@localhost ~]# vim /etc/hosts 192.168.126.138 mq01 192.168.126.133 mq02 192.168.126.141 mq03

2.关闭三台服务器的防火墙并且重启虚拟机便于系统识别

[root@localhost ~]# systemctl stop firewalld.service [root@localhost ~]# setenforce 0 [root@localhost ~]# init 6 #重启

3.准备好YUM源之后，就可以直接使用yum命令安装rabbitmq到三台服务器上。

[root@mq01 ~]# yum install epel-release -y [root@mq01 ~]# yum install rabbitmq-server -y [root@mq01 ~]# ln -s /usr/lib/rabbitmq/bin/* /usr/bin/

4.分别查看三个节点并添加管理服务

[root@mq01 ~]# cd /usr/lib/rabbitmq/bin/ [root@mq01 bin]# ls rabbitmqctl rabbitmq-env rabbitmq-server rabbitmq-defaults rabbitmq-plugins [root@mq01 bin]# rabbitmq-plugins list #查看插件安装情况 [ ] amqp_client 3.3.5 [ ] cowboy 0.5.0-rmq3.3.5-git4b93c2d [ ] eldap 3.3.5-gite309de4 [ ] mochiweb 2.7.0-rmq3.3.5-git680dba8 [ ] rabbitmq_amqp1_0 3.3.5 [ ] rabbitmq_auth_backend_ldap 3.3.5 .......//省略 [root@mq01 bin]# rabbitmq-plugins enable rabbitmq_management #启用管理服务 The following plugins have been enabled: mochiweb webmachine rabbitmq_web_dispatch #网络调度 amqp_client rabbitmq_management_agent rabbitmq_management Plugin configuration has changed. Restart RabbitMQ for changes to take effect. #插件配置发生了变化。重新启动RabbitMQ以使更改生效。

5.启动rabbitmq服务，使用netstat -an | grep 5672进行查看，有如下三个端口开放说明正常。

[root@mq01 bin]# systemctl start rabbitmq-server.service [root@mq01 bin]# netstat -an | grep 5672 tcp 0 0 0.0.0.0:15672 0.0.0.0:* LISTEN tcp 0 0 0.0.0.0:25672 0.0.0.0:* LISTEN tcp6 0 0 :::5672 参数注解： 15672和25672是rabbitmq的管理端口 5672是生产者、消费者通信的端口

6.检查三台的集群状态

[root@mq01 bin]# rabbitmqctl cluster_status Cluster status of node rabbit@mq01 ... #目前相互独立，没有形成集群 [{nodes,[{disc,[rabbit@mq01]}]}, {running_nodes,[rabbit@mq01]}, {cluster_name,<<"rabbit@mq01">>}, {partitions,[]}] ...done.

7.停止三台服务器的rabbitmq服务

[root@mq01 bin]# systemctl stop rabbitmq-server.service

8.在三台服务器上构建Erlang的集群环境

[root@mq01 bin]# vim /var/lib/rabbitmq/.erlang.cookie GYIIPFNYPZITHCELVPZU

注意： 在Erlang的集群中，各节点是通过一个magic cookie来实现的，这个coolie存放在/var/lib/rabbitmq/.erlang.cookie中，文件是400的权限。所以必须保证各节cookie保持一致，否则节点间就无法通信！

9.开启rabbitmq服务

[root@mq01 bin]# systemctl start rabbitmq-server.service

10.将rabbitmq02、rabbitmq03作为内存节点与rabbitmq01磁盘节点连接起来。

rabbitmq02： [root@mq02 bin]# rabbitmqctl stop_app #停止rabbitmq [root@mq02 bin]# rabbitmqctl join_cluster --ram rabbit@mq01 #将mq02连接到mq01，成为一个集群 Clustering node rabbit@mq02 with rabbit@mq01 ... ...done. [root@mq02 bin]# rabbitmqctl start_app #开启rabbitmq [root@mq02 bin]# rabbitmqctl cluster_status #验证群集状态 Cluster status of node rabbit@mq02 ... [{nodes,[{disc,[rabbit@mq01]},{ram,[rabbit@mq02]}]}, {running_nodes,[rabbit@mq01,rabbit@mq02]}, {cluster_name,<<"rabbit@mq01">>}, {partitions,[]}] ...done. rabbitmq03： [root@mq03 bin]# rabbitmqctl cluster_status #验证群集 Cluster status of node rabbit@mq03 ... [{nodes,[{disc,[rabbit@mq01]},{ram,[rabbit@mq03,rabbit@mq02]}]}, {running_nodes,[rabbit@mq02,rabbit@mq01,rabbit@mq03]}, {cluster_name,<<"rabbit@mq01">>}, {partitions,[]}] ...done. #验证成功

策略创建、查看、添加队列

参数注释： Name:策略名称 pattern:匹配的规则 Definition:使用ha-mode模式中的all，也就是同步所以匹配的队列。‘？’类型与帮助文档 Priority:优先级，默认为0,值越大优先级越大。

参数注解： Name:队列的名称 Durability:队列是否持久化（Durable持久化） Node:消息队列的节点 Auto delete:自动删除 Arguments：使用的策略类型

4）进行破坏性测试看看群集效果是否成功。

将rabbitmq01节点关闭，再通过mq02、mq03查看消息记录是否还存在。

[root@mq01 ~]# systemctl stop rabbitmq-server.service

从上图可以看到ht队列已经不存在了，说明没有做镜像模式。而aa队列已经从之前的+2显示成+1了，而且消息还是存在的。

再将mq02节点的服务关闭，通过mq03查看消息记录是否还存在。如图所示：

[root@mq02 ~]# systemctl stop rabbitmq-server.service

在mq02节点服务器上执行rabbitmqctl sync_queue aa，同步完成后+2变成蓝色。如图所示：

[root@mq02 ~]# rabbitmqctl sync_queue aa

[root@mq01 ~]# ll /var/lib/rabbitmq/mnesia/rabbit\@mq01/queues/ 总用量 0 drwxr-xr-x. 2 rabbitmq rabbitmq 38 8月 1 15:07 81NI5XJ4KZDI2KGNS7MV3CP7T drwxr-xr-x. 2 rabbitmq rabbitmq 38 8月 1 14:39 COUUYINKJGWZ16DIMV5GJZ5Z7

rabbitmq集群的破坏性测试成功，说明集群配置成功。

注意： 消息节点一般都是程序直接调用，去创建队列、消息等等。程序里面如果想使用消息高可用集群配置，那么代码需要指定ha参数，如果不指定x-ha-prolicy的话将无法复制。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。