RabbitMQ集群搭建

╰半橙微兮° 2022-12-28 15:26 165阅读 0赞

### RabbitMQ集群搭建 ###

*  RabbitMQ集群搭建
 *   *  准备工作
     *  副本集群
     *   *  副本集群架构
         *  集群搭建
         *   *  集群规划
             *  配置ip映射
             *   *  配置master主机
                 *  远程同步slave
             *  安装RabbitMQ
             *   *  上传rpm
                 *  同步rpm到slave
                 *  安装rpm
                 *  拷贝配置文件
                 *  修改配置文件
                 *  启动RabbitMQ的插件管理功能
                 *  启动并查看状态
                 *  浏览器访问管理界面
             *  同步.erlang.cookie
             *   *  关闭RabbitMQ服务
                 *  同步.erlang.cookie
             *  启动master
             *  将slave加入到集群
             *  启动slave
     *  镜像集群
     *   *  镜像集群架构
         *  配置集群架构
         *   *  策略说明
             *  查看当前策略
             *  添加策略
             *  删除策略

# RabbitMQ集群搭建 #

## 准备工作 ##

开始本课程之前，先按文章

> [环境搭建篇–04、虚拟机的克隆与配置][04]

克隆三个虚拟机，修改主机名依次为：RabbitMQ01、RabbitMQ02、RabbitMQ03；修改ip地址依次为192.168.10.201、192.168.10.202、192.168.10.203。今天我们要是用的虚拟机环境就搭建完成了。

RabbitMQ的集群大致分为两类：**副本集群**和**镜像集群**

## 副本集群 ##

### 副本集群架构 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center]

理解：该种架构中，消费者可以从所有节点访问消息队列，但是消息队列仅存储在`master`节点，slave节点仅仅同步`Exchange`，如果消费者监听的是slave节点，那么slave节点会跟master节点通信，取得相应的队列消息传递给消费者消费。如果master宕机，无法进行主从切换，该种架构解决的主要问题即：**当集群中某一时刻master节点宕机，可以对消息队列进行备份**，所以该架构又称之为`主备架构`

该架构如果master宕机slave不会转正，因此rabbitMQ服务无法再对外提供服务，所以该架构**不满足**高可用的特性

### 集群搭建 ###

#### 集群规划 ####

node1:192.168.10.201   master    主节点
    node2:192.168.10.202   salve01   副本集节点01
    node2:192.168.10.203   salve02   副本集节点02

#### 配置ip映射 ####

##### 配置master主机 #####

以master主机为例，使用`vim`命令打开**hosts**，添加以下配置

192.168.10.201 RabbitMQ01
    192.168.10.202 RabbitMQ02
    192.168.10.203 RabbitMQ03

![在这里插入图片描述][20201218003501600.png_pic_center]

##### 远程同步slave #####

执行命令`scp /etc/hosts root@RabbitMQ02:/etc`、`scp /etc/hosts root@RabbitMQ03:/etc`

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 1]

期间有两处要注意，其一是否确定继续远程连接，选择`yes`；其二要输入远程机器的密码；

同步成功后，我们查看slave01的hosts文件

![在这里插入图片描述][20201218003526311.png_pic_center]

可以看到文件已经同步成功。按照上述操作，同步slave02机器即可

#### 安装RabbitMQ ####

##### 上传rpm #####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 2]

##### 同步rpm到slave #####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 3]

##### 安装rpm #####

按照**erlang、socat、rabbitmq**的顺序在三台机器上依次执行`rpm -ivh **.rpm`命令安装上面三个rpm

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 4]

##### 拷贝配置文件 #####

分别在三台机器上执行命令`cp /usr/share/doc/rabbitmq-server-3.7.18/rabbitmq.config.example /etc/rabbitmq/rabbitmq.config`

##### 修改配置文件 #####

分别在三台机器上执行命令`vim /etc/rabbitmq/rabbitmq.config`，修改行如下

![在这里插入图片描述][20201218003609938.png_pic_center]

##### 启动RabbitMQ的插件管理功能 #####

在三台机器上执行以下命令`rabbitmq-plugins enable rabbitmq_management`，执行结果如下图则说明插件管理服务启动成功

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 5]

##### 启动并查看状态 #####

三台机器上一次执行命令`systemctl start rabbitmq-server`、`systemctl status rabbitmq-server`

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 6]

##### 浏览器访问管理界面 #####

依次输入地址`http://192.168.10.201:15672`、`http://192.168.10.202:15672`、`http://192.168.10.203:15672`，使用`guest/guest`用户名密码登录

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 7]

#### 同步.erlang.cookie ####

##### 关闭RabbitMQ服务 #####

同步\*\*.erlang.cookie\*\*之前记得首先关闭RabbitMQ服务，三台机器依次执行`systemctl stop rabbitmq-server`，然后使用命令`systemctl status rabbitmq-server`查看状态

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 8]

##### 同步.erlang.cookie #####

我们这里以master的cookie为主，执行命令`scp /var/lib/rabbitmq/.erlang.cookie root@RabbitMQ02:/var/lib/rabbitmq/`、`scp /var/lib/rabbitmq/.erlang.cookie root@RabbitMQ03:/var/lib/rabbitmq/`同步master的.erlang.cookie到salve中

![在这里插入图片描述][20201218003712577.png_pic_center]

#### 启动master ####

集群的启动方式跟单机有所区别，官方建议我们使用命令`rabbitmq-server -detached`，这种方式是后台启动方式，并没有启动界面管理功能，这时候我们访问界面是访问不到的。依次在三台机器上执行该命令启动RabbitMQ服务

#### 将slave加入到集群 ####

走到这里终于拨开云雾见青天了，这里开始正式搭建集群，首先要确保两个从机是关闭的（不包括master），如果不确定可以执行关闭命令`rabbitmqctl stop_app`。最后在slave执行命令`rabbitmqctl join_cluster rabbit@RabbitMQ01`

![在这里插入图片描述][20201218003724169.png_pic_center]

#### 启动slave ####

slave加入到master之后就可以执行命令`rabbitmqctl start_app`启动两台slave服务器

![在这里插入图片描述][20201218003734595.png_pic_center]

这里注意的是通过命令`rabbitmqctl start_app`的方式启动服务并不是以后台的方式启动的，最后控制台也打印出了`cmpleted with 3 plugins`这说明管理界面也被加载了，这会更改整个集群的状态。我们之前之前我们的master是以后台方式启动的，并不能访问管理界面，现在我们再去看下master的管理界面已经可以打开了，而且显示出了集群目前的状态

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 9]

现在我们可以在任意节点执行命令`rabbitmqctl cluster_status`来查看当前集群的状态

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 10]

*  **nodes**：节点显示当前集群所有的节点
 *  **running\_nodes**：显示当前集群中正在运行的节点
 *  **cluster\_name**：就是当前的master节点

## 镜像集群 ##

镜像集群队列机制就是将队列在三个节点之间设置主从关系，消息会在三个节点之间进行自动同步，且如果其中一个节点不可用，并不会导致消息丢失或服务不可用的情况，提升MQ集群的整体高可用性

镜像集群是通过上面我们配置的副本集群的基础上配置而来

### 镜像集群架构 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 11]

### 配置集群架构 ###

#### 策略说明 ####

上面说了镜像集群是通过配置来实现的，配置主要是策略的配置，线面对策略进行一下简要的说明

rabbitmqctl set_policy [-p <vhost>] [--priority <priority>] [--apply-to <apply-to>] <name> <pattern> <definition>

*  \[-p vhost\]： 可选参数，针对指定vhost下的queue进行设置
 *  \[–priority \]：可选参数，policy的优先级，一般不写
 *  \[–apply-to \]：可选参数，指定策略的应用对象，是应用于交换机还是应用于队列，一般不写
 *  ：policy的名称
 *  ：queue的匹配模式(正则表达式)
 *  ：镜像定义，包括三个部分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

#### 查看当前策略 ####

在集群中的任一节点执行命令`rabbitmqctl list_policies`，查看当前集群的策略

![在这里插入图片描述][20201218003840554.png_pic_center]

可以看到当前集群中只有默认的一个虚拟主机且没有配置任何策略

#### 添加策略 ####

添加策略之前我们先新建一个**hello**队列

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 12]

#策略正则表达式为 “^” 表示所有匹配所有队列名称  ^hello:匹配hello开头队列
    rabbitmqctl set_policy ha-all '^hello' '{"ha-mode":"all","ha-sync-mode":"automatic"}'

在任一节点执行上述命令后，再次查看管理界面

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 13]

对**可对外提供服务的节点**可以理解为最多几个主机宕机或是整个服务瘫痪

上图**node+2**意思是我们上面搭建的副本集群通过上面的策略配置已经变成了镜像集群，如果master节点宕机，那么slave就会自动切换成master，这样就实现了集群的高可用

#### 删除策略 ####

删除策略使用命令`rabbitmqctl clear_policy <name>` 比如我们删除上面的策略**ha-all**的命令就是`rabbitmqctl clear_policy ha-all`

![在这里插入图片描述][20201218003922317.png_pic_center]

这里需要注意是，如果策略被全部删除，那么镜像集群又会回退到副本集群，这时候该集群也就失去了高可用的特性，如下图

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 14]

[04]: https://blog.csdn.net/bbxylqf126com/article/details/105468650
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/3d5d82b5d6784d5e82c038baaf529b1c.png
[20201218003501600.png_pic_center]: /images/20221120/4bab5f716b204e809a6656db0e89aa49.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221120/c08463566f5a4e9fa89f77c463218dad.png
[20201218003526311.png_pic_center]: /images/20221120/7ee2795219d847ea84947288429a9413.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221120/404962686b314e1495b60a5703ca80e8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221120/7546190dc584440b95e4ab465351038e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 4]: https://img-blog.csdnimg.cn/20201218003558383.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20=,size_16,color_FFFFFF,t_70#pic_center
[20201218003609938.png_pic_center]: https://img-blog.csdnimg.cn/20201218003609938.png#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 5]: https://img-blog.csdnimg.cn/20201218003623502.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20=,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 6]: https://img-blog.csdnimg.cn/20201218003635561.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20=,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 7]: https://img-blog.csdnimg.cn/20201218003647125.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20=,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 8]: https://img-blog.csdnimg.cn/20201218003657498.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20=,size_16,color_FFFFFF,t_70#pic_center
[20201218003712577.png_pic_center]: https://img-blog.csdnimg.cn/20201218003712577.png#pic_center
[20201218003724169.png_pic_center]: https://img-blog.csdnimg.cn/20201218003724169.png#pic_center
[20201218003734595.png_pic_center]: https://img-blog.csdnimg.cn/20201218003734595.png#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 9]: https://img-blog.csdnimg.cn/20201218003745123.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20=,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 10]: https://img-blog.csdnimg.cn/20201218003758782.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20=,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 11]: https://img-blog.csdnimg.cn/20201218003821752.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20=,size_16,color_FFFFFF,t_70#pic_center
[20201218003840554.png_pic_center]: https://img-blog.csdnimg.cn/20201218003840554.png#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 12]: https://img-blog.csdnimg.cn/20201218003854511.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20=,size_16,color_FFFFFF,t_70#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 13]: https://img-blog.csdnimg.cn/20201218003909502.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20=,size_16,color_FFFFFF,t_70#pic_center
[20201218003922317.png_pic_center]: https://img-blog.csdnimg.cn/20201218003922317.png#pic_center
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70_pic_center 14]: https://img-blog.csdnimg.cn/20201218003933243.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20=,size_16,color_FFFFFF,t_70#pic_center