首页 > 其他分享 >MQ集群扩容

MQ集群扩容

时间:2023-06-29 17:04:17浏览次数:31  
标签:扩容 queue quorum mq rabbitmq mq1 rabbitmqctl 集群 MQ

集群扩容

加入集群

1)启动一个新的MQ容器:

点击查看代码
docker run -d --net mq-net \
-v ${PWD}/.erlang.cookie:/var/lib/rabbitmq/.erlang.cookie \
-e RABBITMQ_DEFAULT_USER=quccw \
-e RABBITMQ_DEFAULT_PASS=123321 \
--name mq4 \
--hostname mq5 \
-p 8074:15672 \
-p 8084:15672 \
rabbitmq:3.8-management



2)进入容器控制台:
docker exec -it mq4 bash

3)停止mq进程
rabbitmqctl stop_app

4)重置RabbitMQ中的数据:
rabbitmqctl reset

5)加入mq1:
rabbitmqctl join_cluster rabbit@mq1

6)再次启动mq进程
rabbitmqctl start_app
整个过程如下:

访问浏览器访问新加的mq

增加仲裁队列副本

我们先查看下quorum.queue这个队列目前的副本情况,进入mq1容器:
docker exec -it mq1 bash
执行命令:
rabbitmq-queues quorum_status "quorum.queue"
如下图,我们只看到mq1、mq2、mq3这几个,

现在我们将节点mq4加进来
rabbitmq-queues add_member "quorum.queue" "rabbit@mq5" (这里我们设置的主节点主机名称其实是mq5要和节点名称区分开来)

查看控制台,发现quorum.queue的镜像数量也从原来的 +2 变成了 +3:

但是要注意,cluster.quorum.queue这个是我们在java代码中加的,好像并没有变,那可能是因为java代码加的队列对控制台添加的不生效。

标签:扩容,queue,quorum,mq,rabbitmq,mq1,rabbitmqctl,集群,MQ
From: https://www.cnblogs.com/wekenyblog/p/17514623.html

相关文章

  • Java连接MQ集群
    Java代码创建仲裁队列点击查看代码@BeanpublicQueuequorumQueue(){returnQueueBuilder.durable("cluster.quorum.queue").quorum().build();}......
  • MQ集群之仲裁队列
    仲裁队列:仲裁队列是3.8版本以后才有的新功能,用来替代镜像队列,具备下列特征:与镜像队列一样,都是主从模式,支持主从数据同步使用非常简单,没有复杂的配置主从同步基于Raft协议,强一致从RabbitMQ3.8版本开始,引入了新的仲裁队列,他具备与镜像队里类似的功能,但使用更加方便。添加仲......
  • 解读 RocketMQ 5.0 全新的高可用设计
    作者:斜阳高可用架构演进背景在分布式系统中不可避免的会遇到网络故障,机器宕机,磁盘损坏等问题,为了向用户不中断且正确的提供服务,要求系统有一定的冗余与容错能力。RocketMQ在日志,统计分析,在线交易,金融交易等丰富的生产场景中发挥着至关重要的作用,而不同环境对基础设施的成本与可......
  • MQC
    MQC目录MQC基本概念实验在VLAN中的应用(一)在VLAN中的应用(二)在VLAN中的应用(三)标签:MQC、QOS、VLAN二三层隔离、策略路由基本概念MQC:modularqoscommand-lineinterface(模块化QOS命令行)模块化,最大的优点的修改和调用都很方便;MQC本身并不能“完成任务”,需要被调用才能生效,比......
  • 制作有延迟插件的rabbitmq镜像
    插件Git官方地址:https://github.com/rabbitmq/rabbitmq-delayed-message-exchangeDockerfileFROMrabbitmq:3.8.2-managementADD./rabbitmq_delayed_message_exchange-3.8.0.ez/pluginsRUNchown-Rrabbitmq./plugins/rabbitmq_delayed_message_exchange-3.8.0.ezRUNrabb......
  • 3、Elasticsearch集群安装脚本
    #!/bin/bashES_VERSION=7.17.5UBUNTU_URL="https://mirrors.tuna.tsinghua.edu.cn/elasticstack/7.x/apt/pool/main/e/elasticsearch/elasticsearch-${ES_VERSION}-amd64.deb"RHEL_URL="https://mirrors.tuna.tsinghua.edu.cn/elasticstack/7.x/yum/${ES_......
  • 树莓派集群真的可以顶上一台高性能计算机吗?(扩展篇)
    之前写过文章:树莓派集群真的可以顶上一台高性能计算机吗讨论过树莓派集群是否可以比得上一台高性能计算机的问题,本篇这里是对前文的扩展。   ========================================================  之所以写了本篇扩展是因为无意中在网上发现了下文:https://a......
  • RabbitMQ02
    1.rabbitmq五种消息模型1.1work消息模型-工作队列模型工作队列,又称任务队列。主要思想就是避免执行资源密集型任务时,必须等待它执行完成。相反我们稍后完成任务,我们将任务封装为消息并将其发送到队列。在后台运行的工作进程将获取任务并最终执行作业。当你运行许多消费者时......
  • wifi智能计量插座-10A 定时上传插座状态,电压,电流有功功率,视在功率,功率因数电量,温度 至
    wifi智能计量插座-10A定时上传插座状态,电压,电流有功功率,视在功率,功率因数电量,温度至MQTT服务器wifi智能计量插座-10A定时上传wifi智能计量插座-10A定时上传插座状态,电压,电流有功功率,视在功率,功率因数电量,温度至MQTT服务器插座状态,电压,电流有功功率,视在功率,功率因数电量,温度......
  • RabbitMQ消息持久化
    我们看下之前启动idea测试消息发送的时候在后台生成的一条消息,现在已经在消息队列里面还没有被消费。 现在我们重启下RabbitMQ,执行linux命令:dockerrestartmq看上图实时显示的错误信息,失去连接了,接下来刷新这个页面,可以发现这个对象没有了。 说明rabbit消息并不会持久化,不......