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模式停主节点看一下:
主节点挂了。
从节点的消息还在。
我们之前是主节点挂了,就不能消费了,我们这次在消费一下看看:
也可以消费消息队列。所以使用这种方式的好处就是以后一个节点挂了,不影响我们正常的消息队列使用。
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!