RabbitMQ的集群

新建一个虚拟机,重新安装一个RabbitMQ,不会安装的可以看下面的连接:

在Linux中安装RabbitMQ_流殇꧂的博客-CSDN博客

        1.修改/etc/hosts映射文件,两台虚拟机都需要修改

vim /etc/hosts
127.0.0.1 node1 localhost.localdomain localhost4 localhost4.localdomain4
::1 node1 localhost.localdomain localhost6 localhost6.localdomain6
192.168.40.100 node1
192.168.40.101 node2

        

        2.修改完成后重启linux服务器:

reboot

        3.查看.erlang.cookie文件的位置: 

find / -name .erlang.cookie

        4.使用跨服务器拷贝.erlang.cookie文件到每台节点

        

scp /var/lib/rabbitmq/.erlang.cookie 192.168.40.101:/root

        回车后输入另一台主机的密码即可

         5.同步完成后需重启linux服务器:

reboot

         6.关闭两台服务器的防火墙,启动RabbitMQ的服务:

               关闭服务器的防火墙:  

systemctl stop firewalld

               启动RabbitMQ的服务:

rabbitmq-server -detached

          7.加入集群节点(一个配置即可):

        

rabbitmqctl stop_app
rabbitmqctl join_cluster rabbit@node1
rabbitmqctl start_app

        8.在任意一台服务器运行该命令:

rabbitmqctl cluster_status

         如下图所以,表示集群配置成功

 

         9.在新的集群中重新手动添加用户(任意节点添加,所有节点共享)

                

rabbitmqctl add_user leq 123456

                

rabbitmqctl set_user_tags leq administrator

        

rabbitmqctl set_permissions -p "/" leq ".*" ".*" ".*"

        

         10.我们通过192.168.40.100来创建一个虚拟机,在192.168.40.101中也可以查看到,两个RabbitMQ共享了数据

 

         此时,集群搭建完毕,但是默认采用的模式普通模式,可靠性不高。因此,需将RabbitMQ改为镜像模式

镜像模式:

       语法:  set_policy {name} {pattern} {definition}

        参数的含义:

        name:表示策略名,名称自定义

        pattern:队列的匹配模式,使用正则表达式进行匹配。"^"表示匹配所有的队列

        definition:镜像定义,包括三个部分ha-mode、ha-params和ha-sync-mode

                ha-mode:High Available高可用,简称HA。指明镜像队列的模式,有效值为all/exactly/nodes(all所有节点,exactly指定多个节点,nodes制定单个节点)

                ha-params:表示ha-mode模式需要用到的参数

                ha-sync-mode:进行队列中消息的同步方式,有效值为automatic和manual 

        1.通过命令的方式设置镜像模式策略,在任意一个节点上执行:

                rabbitmqctl set_policy xall "^" '{"ha-mode":"all"}'

         2.也可以通过RabbitMQ的可视化端口进行设置

        

 

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/37276.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

SpringBoot + Kotlin 中使用 GRPC 进行服务通信

示例项目见:kotlin-grpc 一、导入依赖: import com.google.protobuf.gradle.* plugins { id("org.springframework.boot") version "2.3.1.RELEASE" id("io.spring.dependency-management") version "1.0.9.REL…

idea连接远程MySQL数据库

填写URL,以mysql为例 格式 jdbc:mysql://ip地址:端口号/数据库名 jdbc:mysql://127.0.0.1:3306/ldentification _Information

软件测试基础知识

软件测试的生命周期 软件测试的生命周期和软件的生命周期是不一样的,软件包括需求分析和规划,设计和编码,测试和验证,部署和维护,退役和回收等等,而软件测试的生命周期则是需求分析-测试计划-测试设计&…

对 Jenkins+ANT+Jmeter 接口测试的实践

目录 1、前言 2、框架与数据准备 3、脚本设计 4、整理测试报告 1、前言 JenkinsANTJMeter是一种常见的接口测试实践方案,可以实现自动化的接口测试和持续集成。Jenkins是一个流行的持续集成工具,ANT是一个构建工具,而JMeter是一个功能强大…

maven配置java outofmemory选项

在maven之中选择Add VM options,这样命令就多出来一个关于VM options配置的属性,此时就可以输入对于VM的设置

Ubuntu 放弃了战斗向微软投降

导读这几天看到 Ubuntu 放弃 Unity 和 Mir 开发,转向 Gnome 作为默认桌面环境的新闻,作为一个Linux十几年的老兵和Linux桌面的开发者,内心颇感良多。Ubuntu 做为全世界Linux界的桌面先驱者和创新者,突然宣布放弃自己多年开发的Uni…

jenkins实现easyswoole 持续集成/持续部署

jenkins环境jenkins需要使用root用户启动可通过修改 vim /etc/sysconfig/jenkins改为root,也可直接命令行root启动新增流水线项目安装远程构建插件Generic Webhook Trigger勾选触发远程构建保存之后,访问 /generic-webhook-trigger/invoke?tokeneasyswoole-test,即可自动bui…

【网络】协议的定制与Json序列化和反序列化

文章目录 应用层初识TCP协议通讯流程定制协议再谈协议网络版本计算器Protocal.hppCalServerCalClient Json的安装 应用层 我们程序员写的一个个解决我们实际问题, 满足我们日常需求的网络程序, 都是在应用层 初识TCP协议通讯流程 建立链接和断开链接 基于TCP协议&#xff0c…

nginx相关

1、nginx无默认配置文件 参考文章:nginx配置失败,卸载后重装无 nginx.conf文件_haojuntu的博客-CSDN博客 2、nginx更改服务器的端口号 参考文章:https://www.cnblogs.com/chaosfe/p/16123585.html#:~:text%E6%88%91%E4%BB%AC%E6%9F%A5%E7%…

Java----使用eureka进行注册连接(微服务简单实现)

当采用微服务架构时,各个业务流程被逐一分解,虽说是分解,但还是要进行连接的,最简单的就是使用http请求,将他们联系起来,通过给容器注入restTemplate,然后使用内置的方法进行请求,但…

Java虚拟机(JVM)介绍

JVM是什么 JVM是Java Virtual Machine的缩写。它是一种基于计算设备的规范,是一台虚拟机,即虚构的计算机。 JVM屏蔽了具体操作系统平台的信息(显然,就像是我们在电脑上开了个虚拟机一样),当然,J…

支付宝接入

支付宝接入 python-alipay-sdk pycryptodome一、电脑网站支付 1.1 获取支付宝密钥 沙箱网址 1.APPID 2.应用私钥 3.支付宝公钥1.2 存放密钥 在与 settings.py 的同级目录下创建 pem 文件夹pem 文件夹下创建 app_private_key.pem 和 alipay_public_key.pem app_private_key…

pdf文档加水印怎么弄?用这款软件很方便

在工作中,我们经常需要将PDF文件发送给他人,但无法保证文件内容不被窃取,因此需要添加水印来保证文件的安全性。如果你不知道如何给PDF文件添加水印,以下两款软件可以帮助你轻松实现,一起来看看吧! 方法一&…

爬虫之Scrapy

一 介绍 Scrapy一个开源和协作的框架,其最初是为了页面抓取 (更确切来说, 网络抓取 )所设计的,使用它可以以快速、简单、可扩展的方式从网站中提取所需的数据。但目前Scrapy的用途十分广泛,可用于如数据挖掘、监测和自动化测试等领域&#x…

Python实现Excel文件拷贝图片到另一个的Excel文件(保持原有图片比例)

Python实现Excel文件拷贝图片到另一个的Excel文件(保持原有图片比例) 1、前言1.1 成功拷贝但是比例错误1.2 直接报错 2、解决办法3、号外 1、前言 今天朋友给我一个需求,需要把xlsx文件中的图片拷贝到另一个xlsx中,但是试过网上比…

[Lesson 01] TiDB数据库架构概述

目录 一 章节目标 二 TiDB 体系结构 1 TiDB Server 2.1 TiKV 2.2 TiFlash 3 PD 参考 一 章节目标 理解TiDB数据库整体架构了解TiDB Server TiKV tiFlash 和 PD的主要功能 二 TiDB 体系结构 了解这些体系结构是如何实现TiDB的核心功能的 1 TiDB Server TiDB Serve…

若依官方前端手册 小笔记

提供确认窗体信息 this.$modal.confirm(确认信息).then(function() {... }).then(() > {... }).catch(() > {}); 提供遮罩层信息 // 打开遮罩层 this.$modal.loading("正在导出数据,请稍后...");// 关闭遮罩层 this.$modal.closeLoading(); 验证…

pythonocc进阶学习:faces的inner wire与outer wire

总目录 >> PythonOCC入门进阶到实战(目前已更新入门篇、基础篇和进阶篇) 我们在这篇文章中绘制了带有holes的面, 本篇是在读取到外部文件如brep,igs,stp后获取面的性质,寻找面中的wires的正向与逆向 只显示外wire from O…

【LeetCode热题100】打卡第37天:岛屿数量反转链表

文章目录 【LeetCode热题100】打卡第37天:岛屿数量&反转链表⛅前言 岛屿数量🔒题目🔑题解 反转链表🔒题目🔑题解 【LeetCode热题100】打卡第37天:岛屿数量&反转链表 ⛅前言 大家好,我是…

【Spring core学习二】创建Spring 项目 Spring的存

目录 🌟一、创建最原始的Spring-core项目。 🌟二、怎么往Spring中存取对象? 🌷1、在Spring中存对象 🌷2、通过getBean获取对象的三种方式 🌷3、通过factory方式获取对象 🌟三、对存对象的…