栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

镜像集群搭建及Springboot连接镜像集群

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

镜像集群搭建及Springboot连接镜像集群

        前面已经搭建了由3个节点组成的普通集群,接下来在普通集群的基础上搭建镜像集群,实现高可用以及消息备份。

登录任意节点的管控台:

Admin-->policies-->Add / update a policy

 

Name: 策略名称
Pattern: 匹配任意队列或交换机
ha-mode:all 在所有节点同步消息
ha-sync-mode:automatic 自动同步消息

在任意节点上创建1个测试队列,如果看到如下node里有其他节点信息,说明镜像集群搭建完成

 

以后如果需要对集群进行重启顺序是这样:

启动顺序:磁盘节点==>内存节点

关闭顺序:内存节点==>磁盘节点

创建集群时,指定了节点类型磁盘节点或者内存节点,要按照如上方式进行启动或关闭,否则可能会启动失败,或者丢失消息。 

springboot项目连接镜像集群与连接普通集群的方式相同,使用前面连接普通集群的项目进行测试。

启动项目,调用send接口发送消息,根据日志可以看到项目连接的是node2节点,去管控台查看:

发现order_queue被创建,里面有一条消息

根据项目的连接日志,我们直到消息存储在节点node2上,现在我们停掉node2,看order_queue中的消息是否能被使用。

node2已经下线

 

通过管控台,我们发现,一开始创建时order_queue属于node2节点,但是node2下线后,order_queue现在已经归属于node3。

我们启动程序,根据服务日志可以发现可以正常消费队列中的消息

msgTag=1
message=(Body:'新订单 1' MessageProperties [headers={}, contentType=text/plain, contentEncoding=UTF-8, contentLength=0, receivedDeliveryMode=PERSISTENT, priority=0, redelivered=true, receivedExchange=exchange_order, receivedRoutingKey=order.new, deliveryTag=1, consumerTag=amq.ctag-fIfWNwHmdF9QPxbjr-m_Sw, consumerQueue=order_queue])
body=新订单 1
*****************************

根据测试,可以验证出如下结论:镜像集群,除了同步虚拟主机、交换机、队列等元数据,还会同步消息,具有高可用性,某些节点宕机不影响集群使用,消息在多个节点上同步备份,因此不会丢失消息。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/434367.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号