RabbitMq学习笔记11（小滴课堂）

讲解RabbitMQ高可用普通集群模式介绍

讲解RabbitMQ高可用mirror镜像集群模式介绍

讲解RabbitMQ高可用普通集群搭建基础准备

停止节点：

删除单节点：

我们已经查不到之前的容器了。

我们看到了我们创建的映射文件。

这样我们的准备工作就做完了，我们创建了3个rabbitmq。

讲解RabbitMQ高可用普通集群搭建

进入到第一台mq中。

这里也相当于一个小型的linux系统。

我们需要先重置一下相关的配置：

我们重新启动后去查看一下mq的状态：

然后同样的方式去处理其他的节点。

这里--ram后面的参数分别是节点名和hostname。

配置完我们可以看到全部的节点信息。

页面上也显示出三个节点。

我们在1672主节点创建一个队列：

其他节点也都可以看到这个队列。

我们再在15674节点创建一个交换机：

同理其它节点也能看到这个交换机。

我们在节点一发布一个消息：

我们在三个节点都看到了我们的消息。

那如果我们的主节点挂了：

节点一已经无法启动了。

消息也查不到了。

再把这个节点启动一下：

恢复了

再发送个消息：

可以看到消息。

再把二节点停止：

再启动：

还能看到这个消息。

在发布消息的时候可以选择消息是否持久化（persistent）。

• SpringBoot项目配置集群

先修改rabbitmq的密码。

注释掉我们之前的队列。

之前项目的监听器都注释掉。

注释掉之前的代码。

还原成最原始的mq配置：

一个交换机一个队列。

创建我们的监听器。

使用集群模式就要修改我们的配置文件：

我们模拟一下发送:

就只发送一条消息。

为了不消费我们把监听先关闭掉。

controller也注释掉。

在mq里添加虚拟主机：

我们发送一下消息：

我们现在停掉节点1：

我们启动消费者：

我们停止服务重新开启节点1：

消息恢复了。

再启动消费者：

讲解RabbitMQ高可用mirror镜像集群配置策略配置

我们就添加了这个策略。

使用SpringBoot项目整合RabbitMQ高可用集群

这里不需要改我们的配置。

我们去先把消费者的注解注释掉。

发送一条消息：

每个节点都能看到消息。

普通模式停掉主节点，内存节点也看不到消息了，我们在mirror模式停主节点看一下：

主节点挂了。

从节点的消息还在。

我们之前是主节点挂了，就不能消费了，我们这次在消费一下看看：

也可以消费消息队列。所以使用这种方式的好处就是以后一个节点挂了，不影响我们正常的消息队列使用。