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模式停主节点看一下:

主节点挂了。

从节点的消息还在。

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

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

相关推荐

最近更新

  1. docker php8.1+nginx base 镜像 dockerfile 配置

    2023-12-24 22:26:05       98 阅读
  2. Could not load dynamic library ‘cudart64_100.dll‘

    2023-12-24 22:26:05       106 阅读
  3. 在Django里面运行非项目文件

    2023-12-24 22:26:05       87 阅读
  4. Python语言-面向对象

    2023-12-24 22:26:05       96 阅读

热门阅读

  1. 数据迁移测试经验分享

    2023-12-24 22:26:05       61 阅读
  2. Python基础(持续更新)

    2023-12-24 22:26:05       46 阅读
  3. 接口功能测试策略

    2023-12-24 22:26:05       64 阅读
  4. 经常使用的排序算法

    2023-12-24 22:26:05       61 阅读
  5. 企业数据治理(2):“数据治理体系建设“

    2023-12-24 22:26:05       53 阅读
  6. npm error code EINTEGRITY 问题的解决方法之一

    2023-12-24 22:26:05       68 阅读
  7. 大数据、知识图谱和强化学习的综合应用

    2023-12-24 22:26:05       60 阅读
  8. LinkedList元素使用Lanbda表达式循环打印

    2023-12-24 22:26:05       49 阅读