CentOS7-RabbitMQ集群搭建

目标

在CentOS7中快速安装RabbitMQ

此次安装的RabbitMQ版本为：3.8.3，erlang版本为：22.3.2

下载erlang时需要注意版本兼容性问题：https://www.rabbitmq.com/which-erlang.html

前提

1.时间同步(检查时间)

2.设置selinux

sed -i 's/SELINUX=enforcing/SELINUX=disabled/g' /etc/sysconfig/selinux
sed -i 's/SELINUX=enforcing/SELINUX=disabled/g' /etc/selinux/config
setenforce 0

3.设置firewalld策略（关闭防火墙）

systemctl stop firewalld
systemctl disable firewalld

4.设置hostname，及其hosts

设置hostname目的是为了防止启动管理界面时候出现的错误，和加入集群也会出错，这是避坑第一步

#每台服务器设置hostname
hostnamectl set-hostname ns1
hostnamectl set-hostname ns2
hostnamectl set-hostname ns3

# 设置 /etc/hosts
echo 10.80.210.67 ns1 >> /etc/hosts
echo 10.80.210.68 ns2 >> /etc/hosts
echo 10.80.210.69 ns3 >> /etc/hosts

安装及配置RabbitMQ

安装依赖环境

yum install build-essential openssl openssl-devel unixODBC unixODBC-devel make gcc gcc-c++ kernel-devel m4 ncurses-devel tk tc xz

根据官方文档说明建议也要先安装socat和logrotate：yum install socat logrotate

安装erlang

rpm包下载：https://packagecloud.io/rabbitmq/erlang/packages/el/7/erlang-22.3.2-1.el7.x86_64.rpm

安装：rpm -Uvh erlang-22.3.2-1.el7.x86_64.rpm

安装RabbitMQ

rpm包下载：https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.8.3/rabbitmq-server-3.8.3-1.el7.noarch.rpm

or:https://packagecloud.io/rabbitmq/rabbitmq-server/packages/el/7/rabbitmq-server-3.8.3-1.el7.noarch.rpm

安装：rpm -ivh rabbitmq-server-3.8.3-1.el7.noarch.rpm

安装路径默认在：/usr/lib/rabbitmq/lib/rabbitmq_server-3.8.3/ebin

开启管理界面及配置

# 开启rabbitmq management及远程登录
rabbitmq-plugins enable rabbitmq_management

# 开启 mqtt （如果需要mqtt则需要开启，3.8.x开启默认内置）
rabbitmq-plugins enable rabbitmq_mqtt

启动停止服务

systemctl start rabbitmq-server # 启动服务
systemctl stop rabbitmq-server # 停止服务
systemctl restart rabbitmq-server # 重启服务

命令行方式初始化管理员账号

默认存在一个guest账号，但是guest账号只能在本机登录（centos本机）

解决办法：新建一个新的管理员账号

# 创建用户
rabbitmqctl add_user xinsec DB.xinsec

#设置超级管理员
rabbitmqctl set_user_tags xinsec administrator

#授权远程访问（也可以登录后，可视化配置）
rabbitmqctl set_permissions -p / xinsec "." "." ".*"

#---以下命令可忽略---
#查看用户列表
rabbitmqctl  list_users
#修改对应用户密码
rabbitmqctl  change_password  username  'newpasswd'

访问界面

http://IP:15672

添加用户 出现以下错误，请检查 /etc/hosts 是否加入!!

Error: unable to perform an operation on node 'rabbit@ns'. Please see diagnostics information and suggestions below.

RabbitMQ普通集群搭建

接下来我们开始集群的配置。

ns2/ns3服务器中先执行：systemctl stop rabbitmq-server

ns1服务器执行把.erlang.cookie复制到ns2/ns3

scp .erlang.cookie ns2:/var/lib/rabbitmq/.erlang.cookie
scp .erlang.cookie ns3:/var/lib/rabbitmq/.erlang.cookie

然后分别执行如下命令将 ns2/ns3加入ns1集群中：

systemctl restart rabbitmq-server 

# 加入ns1集群
rabbitmqctl stop_app
rabbitmqctl reset
rabbitmqctl join_cluster rabbit@ns1
rabbitmqctl start_app

#---以下命令可忽略---
# 查看集群的状态
rabbitmqctl cluster_status

进入界面，可以看到，此时集群中已经有三个节点了

搭建镜像集群-普通集群转镜像集群

因为普通集群无法实现高可用

但所谓的``镜像集群模式`并不需要额外搭建，只需要我们将队列配置为镜像队列即可。

这个配置可以通过网页配置，也可以通过命令行配置

在任意一个节点上面执行即可。

默认是将所有的队列都设置为镜像队列，在消息会在不同节点之间复制，各节点的状态保持一致。

网页配置

先来看看网页上如何配置镜像队列。

点击 Admin 选项卡，然后点击右边的 Policies，再点击 Add/update a policy，如下图：

接下来添加一个策略，如下图：

各参数含义如下：

• Name: policy 的名称。
• Pattern: queue 的匹配模式(正则表达式)。
• Definition：镜像定义，主要有三个参数：ha-mode, ha-params, ha-sync-mode。
  • ha-mode：指明镜像队列的模式，有效值为 all、exactly、nodes。其中 all 表示在集群中所有的节点上进行镜像（默认即此）；exactly 表示在指定个数的节点上进行镜像，节点的个数由 ha-params 指定；nodes 表示在指定的节点上进行镜像，节点名称通过 ha-params 指定。
  • ha-params：ha-mode 模式需要用到的参数。
  • ha-sync-mode：进行队列中消息的同步方式，有效值为 automatic 和 manual。
• priority 为可选参数，表示 policy 的优先级。

配置完成后，点击下面的 add/update policy 按钮，完成策略的添加

命令行配置

命令行的配置格式如下：

rabbitmqctl set_policy [-p vhost] [--priority priority] [--apply-to apply-to] {name} {pattern} {definition}

配置案例：

rabbitmqctl set_policy -p / --apply-to queues my_queue_mirror "^" '{"ha-mode":"all","ha-sync-mode":"automatic"}'