RabbitMq学习笔记11(小滴课堂)

2023-12-24 17:34:15

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

主节点挂了。

从节点的消息还在。

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

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

文章来源:https://blog.csdn.net/weixin_52618349/article/details/134961654
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。