当前位置: 首页 > news >正文

docker搭建rabbit集群

1.去rabbitMQ官网拉去images

我当前使用的是最新版本的镜像:rabbitmq:3.12-management

2.创建一个集群专用网络

docker的容器相互隔离是不可通信的,我们自行创建一个网络后,创建容器时 给他们放在一起,就可以通信了。

docker network create rabbit-net  --driver bridge

我们的网卡名称为:rabbit-net

3.构建出三个实例

我们在做容器时候:run后面参数依次简单说明一下
-name 镜像名称
–hostname 修改主机名
-v 做了宿主机与容器文件映射
-p 做了端口通信
–network 把这几个节点放到同一个网卡上
-d 让容器后台执行
选择镜像版本号

node01
docker run --name rabbit01 --hostname=node01  \
-v /mydata/rabbitMQ/node01:/var/lib/rabbitmq  \
-p 5672:5672  \
-p 15672:15672  \
--network rabbit-net  \
-d  \
rabbitmq:3.12-management
node02
docker run --name rabbit02 --hostname=node02  \
-v /mydata/rabbitMQ/node02:/var/lib/rabbitmq  \
-p 5673:5672  \
-p 15673:15672  \
--network rabbit-net  \
-d  \
rabbitmq:3.12-management
node03
docker run --name rabbit03 --hostname=node03  \
-v /mydata/rabbitMQ/node03:/var/lib/rabbitmq  \
-p 5674:5672  \
-p 15674:15672  \
--network rabbit-net  \
-d  \
rabbitmq:3.12-management

4.修改各个容器的cookie

CLI如何验证节点:Erlang Cookie
RabbitMQ节点和 CLI 工具(例如rabbitmqctl)使用cookie来确定是否允许它们相互通信。
为了使两个节点能够通信,它们必须具有相同的共享密钥,称为 Erlang cookie。cookie 只是一串最多 255 个字符的字母数字字符。
每个集群节点都必须有相同的cookie。

下面将统一使用node01的cookie,以保证每个节点有相同的cookie。

[root@localhost node01]# cat .erlang.cookie 
QLPBURUFDGAORQHBQXIB
[root@localhost node02]# cat .erlang.cookie 
UJJVRAMWCGUDWFMUVZSK
[root@localhost node03]# cat .erlang.cookie 
QRMWUHLBULEHAYJNKPXZ

Node01的cookie:QLPBURUFDGAORQHBQXIB

把rabbit01容器中的/var/lib/rabbitmq/.erlang.cookie复制给rabbit02 rabbit03

由于我们已经做了宿主机与容器的文件映射,这里直接从宿主机网rabbit02 rabbit03即可

[root@localhost]# docker cp /mydata/rabbitMQ/node01/.erlang.cookie  rabbit02:/var/lib/rabbitmq/
Preparing to copy...
Copying to container - 2.048kB
Successfully copied 2.048kB to rabbit02:/var/lib/rabbitmq/
[root@localhost]# docker cp /mydata/rabbitMQ/node01/.erlang.cookie  rabbit03:/var/lib/rabbitmq/
Preparing to copy...
Copying to container - 2.048kB
Successfully copied 2.048kB to rabbit03:/var/lib/rabbitmq/

分别在宿主机node02 node03查看cookie文件

[root@localhost node02]# cat .erlang.cookie 
QLPBURUFDGAORQHBQXIB[root@localhost node02]# 
[root@localhost node03]# cat .erlang.cookie 
QLPBURUFDGAORQHBQXIB[root@localhost node03]# 

Node02 node03都变成了:QLPBURUFDGAORQHBQXIB

给node02 node03 节点重启 是他们cookie生效

[root@localhost]# docker restart rabbit02
rabbit02
[root@localhost]# docker restart rabbit03
rabbit03

5.容器相互挂接

rabbit01 - < rabbit02 -< rabbit03

在这里插入图片描述

我们这里 让rabbit01当做主节点 rabbit02挂到rabbit01上 rabbit03挂到rabbit02上

rabbit01操作步骤:

1.进入容器(docker exec -it rabbit01 bash)
2.只关闭rabbitmq服务(rabbitmqctl stop_app)(rabbitmqctl stop 会将 Erlang 虚拟机关闭,rabbitmqctl stop_app只关闭RabbitMQ 服务)
3.重置这个节点(rabbitmqctl reset)
4.启动服务(rabbitmqctl start_app)
5. exit

[root@localhost]# docker exec -it rabbit01 bash
root@node01:/# rabbitmqctl stop_app
Stopping rabbit application on node rabbit@node01 ...
root@node01:/# rabbitmqctl reset
Resetting node rabbit@node01 ...
root@node01:/# rabbitmqctl start_app
Starting node rabbit@node01 ...
root@node01:/# exit
exit
rabbit02操作步骤:

1.进入容器(docker exec -it rabbit02 bash)
2.只关闭rabbitmq服务(rabbitmqctl stop_app)(rabbitmqctl stop 会将 Erlang 虚拟机关闭,rabbitmqctl stop_app只关闭RabbitMQ 服务)
3.重置这个节点(rabbitmqctl reset)
4.加入节点rabbit01(rabbitmqctl join_cluster rabbit@node01)
5.启动服务(rabbitmqctl start_app)
6. exit

[root@localhost rabbitMQ]# docker exec -it rabbit02 bash
root@node02:/# rabbitmqctl stop_app
Stopping rabbit application on node rabbit@node02 ...
root@node02:/# rabbitmqctl reset
Resetting node rabbit@node02 ...
root@node02:/# rabbitmqctl join_cluster rabbit@node01
Clustering node rabbit@node02 with rabbit@node01
root@node02:/# rabbitmqctl start_app
Starting node rabbit@node02 ...
root@node02:/# exit
exit
rabbit03步骤:

1.进入容器(docker exec -it rabbit03 bash)
2.只关闭rabbitmq服务(rabbitmqctl stop_app)(rabbitmqctl stop 会将 Erlang 虚拟机关闭,rabbitmqctl stop_app只关闭RabbitMQ 服务)
3.重置这个节点(rabbitmqctl reset)
4.加入节点rabbit02(rabbitmqctl join_cluster rabbit@node02)
5.启动服务(rabbitmqctl start_app)
6. exit

[root@localhost]# docker exec -it rabbit03 bash
root@node03:/# rabbitmqctl stop_app
Stopping rabbit application on node rabbit@node03 ...
root@node03:/# rabbitmqctl reset
Resetting node rabbit@node03 ...
root@node03:/# rabbitmqctl join_cluster rabbit@node02
Clustering node rabbit@node03 with rabbit@node02
root@node03:/# rabbitmqctl start_app
Starting node rabbit@node03 ...
root@node03:/# exit
exit

至此,我们操作完成了 然后随便登录一个节点 看看我们的成果!

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

相关文章:

docker搭建rabbit集群

1.去rabbitMQ官网拉去images 我当前使用的是最新版本的镜像&#xff1a;rabbitmq:3.12-management 2.创建一个集群专用网络 docker的容器相互隔离是不可通信的&#xff0c;我们自行创建一个网络后&#xff0c;创建容器时 给他们放在一起&#xff0c;就可以通信了。 docker netw…...

西南科技大学C++程序设计实验一(C++基础知识)

目录 一、实验目的 二、实验任务 三、预习内容(复习书中前3章内容,说明C++相对于C的扩展有哪些?) 四、问题思考与讨论 一、实验目的 1.熟悉编程环境 2.掌握程序调试方法。 3.熟悉枚举类型、结构体类型等自定义数据类型的使用 4.熟悉函数的定义、说明与使用 5.熟悉引用…...

Rust内存布局

题图忘了来自哪里.. 整型,浮点型,struct,vec!,enum 本文是对 Rust内存布局 的学习与记录 struct A { a: i64, b: u64,}struct B { a: i32, b: u64,}struct C { a: i64, b: u64, c: i32,}struct D { a: i32, b: u64, c: i32, d: u64,}fn main(…...

android 12 添加菜单

1.创建一级菜单 packages\apps\Settings\res\xml\top_level_settings.xml <com.android.settings.widget.HomepagePreferenceandroid:fragment"com.android.settings.DeviceStatusSettings"android:icon"drawable/ic_settings_display_white"android:…...

Map 的 5 种遍历方式

Map 的 5 种遍历方式 强烈推荐 for-each entrySet()遍历 和 lambda 表达式遍历 &#xff0c;简洁又好用&#xff01;&#xff01;&#xff01; package com.maptest; import java.util.HashMap; import java.util.Iterator; import java.util.Map; import java.util.Set;pub…...

Linux的基本指令 ( 一 )

目录 前言 Linux基本指令 快速认识五个指令 ls指令 补充内容 pwd指令 补充内容 cd指令 补充内容 重新认识指令 指令的本质 which指令 alias指令 最后 一个文件的三种时间 tree指令及安装 tree指令 前言 关于Linux操作系统的桌面&#xff0c;在学校教学中我们…...

【深度学习】学习率及多种选择策略

学习率是最影响性能的超参数之一&#xff0c;如果我们只能调整一个超参数&#xff0c;那么最好的选择就是它。相比于其它超参数学习率以一种更加复杂的方式控制着模型的有效容量&#xff0c;当学习率最优时&#xff0c;模型的有效容量最大。本文从手动选择学习率到使用预热机制…...

具有“真实触感”的动捕数据手套mhand pro,提供更精确的动作捕捉

随着人工智能的普及和万物互联&#xff0c;vr虚拟技术备受关注&#xff0c;为了更加真实的虚拟现实交互体验&#xff0c;动捕数据手套的使用逐渐普及&#xff0c;vr手套可以实时采集各手指关节运动数据&#xff0c;使用动捕数据手套可以在虚拟现实的场景中实现对真实手部运动的…...

Mongodb使用killCursors停止运行的cursor

cursor指向查询结果的游标&#xff0c;通过游标向下移动&#xff0c;获得下一条查询结果。MongoDB分批向用户返回数据结果。通过游标的移动&#xff0c; mongodb确定当前返回结果的位置&#xff0c;是否要加载更多数据到内存当中。cursor有默认的超时时间&#xff0c; 超时后cu…...

电脑风扇转一下停一下,无法正常开机问题解决

今天同事电话说电脑开不了机了&#xff0c;只听见风扇不停地呜呜地作响。笔者第一反应是不是硬件哪里出问题了&#xff0c;于是二话没说拿起心爱的螺丝刀就闪了过去。 按下电源&#xff0c;确实如电话所述。但感觉风扇并非一直在转&#xff0c;而是时断时续。由于听不大真切&a…...

无需部署服务器,如何结合内网穿透实现公网访问导航页工具Dashy

文章目录 简介1. 安装Dashy2. 安装cpolar3.配置公网访问地址4. 固定域名访问 简介 Dashy 是一个开源的自托管的导航页配置服务&#xff0c;具有易于使用的可视化编辑器、状态检查、小工具和主题等功能。你可以将自己常用的一些网站聚合起来放在一起&#xff0c;形成自己的导航…...

Go GORM简介

GORM&#xff08;Go Object-Relational Mapping&#xff09;是一个用于Go语言的ORM库&#xff0c;它提供了一种简单、优雅的方式来操作数据库。GORM支持多种数据库&#xff0c;包括MySQL、PostgreSQL、SQLite和SQL Server。以下是GORM的一些主要特性 全功能ORM&#xff1a;GORM…...

前端量子纠缠 效果炸裂 multipleWindow3dScene

我 | 在这里 &#x1f575;️ 读书 | 长沙 ⭐软件工程 ⭐ 本科 &#x1f3e0; 工作 | 广州 ⭐ Java 全栈开发&#xff08;软件工程师&#xff09; &#x1f383; 爱好 | 研究技术、旅游、阅读、运动、喜欢流行歌曲 ✈️已经旅游的地点 | 新疆-乌鲁木齐、新疆-吐鲁番、广东-广州…...

第十七章 处理空字符串和 Null 值 - XMLIGNORENULL、XMLNIL 和 XMLUSEMPTYELEMENT 的详细信息

文章目录 第十七章 处理空字符串和 Null 值 - XMLIGNORENULL、XMLNIL 和 XMLUSEMPTYELEMENT 的详细信息XMLIGNORENULL、XMLNIL 和 XMLUSEMPTYELEMENT 的详细信息XMLIGNORENULLXMLNILXMLUSEEMPTYELEMENT 导入值 第十七章 处理空字符串和 Null 值 - XMLIGNORENULL、XMLNIL 和 XML…...

Asp.net core WebApi 配置自定义swaggerUI和中文注释

1.创建asp.net core webApi项目 默认会引入swagger的Nuget包 <PackageReference Include"Swashbuckle.AspNetCore" Version"6.2.3" />2.配置基本信息和中文注释&#xff08;默认是没有中文注释的&#xff09; 2.1创建一个新的controller using Micr…...

Xilinx SDK获取代码运行时间

Xilinx SDK获取代码运行时间 一、API 头文件 “xtime_l.h”函数XTime_GetTime(XTime * xtime),获取周期数时钟频率宏 COUNTS_PER_SECOND 二、使用 #include "xtime_l.h"int main(){XTime tBegin, tEnd;unsigned int t_us;unsigned long long cycles;XTime_GetTim…...

【力扣】189. 轮转数组

【力扣】189. 轮转数组 文章目录 【力扣】189. 轮转数组1. 题目介绍2. 解法2.1 方法一&#xff1a;不太正规&#xff0c;但是简单2.2 方法二&#xff1a;使用额外的数组2.3 方法三&#xff1a;环状替换2.4 方法四&#xff1a;数组翻转 3. Danger参考 1. 题目介绍 给定一个整数…...

Spring 拾枝杂谈—Spring原生容器结构剖析(通俗易懂)

目录 一、前言 二、Spring快速入门 1.简介 : 2. 入门实例 : 三、Spring容器结构分析 1.bean配置信息的存储 : 2.bean对象的存储 : 3.bean-id的快捷访问 : 四、总结 一、前言 开门见山&#xff0c;11.25日开始我们正式进入Java框架—Spring的学习&#xff0c;此前&…...

Java核心知识点整理大全22-笔记

目录 19.1.14. CAP 一致性&#xff08;C&#xff09;&#xff1a; 可用性&#xff08;A&#xff09;&#xff1a; 分区容忍性&#xff08;P&#xff09;&#xff1a; 20. 一致性算法 20.1.1. Paxos Paxos 三种角色&#xff1a;Proposer&#xff0c;Acceptor&#xff0c;L…...

qt 5.15.2读取csv文件功能

qt 5.15.2读取csv文件功能 工程文件.pro 内容&#xff1a; QT core#添加网络模块 QT networkCONFIG c17 cmdline# You can make your code fail to compile if it uses deprecated APIs. # In order to do so, uncomment the following line. #DEFINES QT_DISABLE_DEPREC…...

生成xcframework

打包 XCFramework 的方法 XCFramework 是苹果推出的一种多平台二进制分发格式&#xff0c;可以包含多个架构和平台的代码。打包 XCFramework 通常用于分发库或框架。 使用 Xcode 命令行工具打包 通过 xcodebuild 命令可以打包 XCFramework。确保项目已经配置好需要支持的平台…...

1688商品列表API与其他数据源的对接思路

将1688商品列表API与其他数据源对接时&#xff0c;需结合业务场景设计数据流转链路&#xff0c;重点关注数据格式兼容性、接口调用频率控制及数据一致性维护。以下是具体对接思路及关键技术点&#xff1a; 一、核心对接场景与目标 商品数据同步 场景&#xff1a;将1688商品信息…...

unix/linux,sudo,其发展历程详细时间线、由来、历史背景

sudo 的诞生和演化,本身就是一部 Unix/Linux 系统管理哲学变迁的微缩史。来,让我们拨开时间的迷雾,一同探寻 sudo 那波澜壮阔(也颇为实用主义)的发展历程。 历史背景:su的时代与困境 ( 20 世纪 70 年代 - 80 年代初) 在 sudo 出现之前,Unix 系统管理员和需要特权操作的…...

零基础在实践中学习网络安全-皮卡丘靶场(第九期-Unsafe Fileupload模块)(yakit方式)

本期内容并不是很难&#xff0c;相信大家会学的很愉快&#xff0c;当然对于有后端基础的朋友来说&#xff0c;本期内容更加容易了解&#xff0c;当然没有基础的也别担心&#xff0c;本期内容会详细解释有关内容 本期用到的软件&#xff1a;yakit&#xff08;因为经过之前好多期…...

安卓基础(aar)

重新设置java21的环境&#xff0c;临时设置 $env:JAVA_HOME "D:\Android Studio\jbr" 查看当前环境变量 JAVA_HOME 的值 echo $env:JAVA_HOME 构建ARR文件 ./gradlew :private-lib:assembleRelease 目录是这样的&#xff1a; MyApp/ ├── app/ …...

Netty从入门到进阶(二)

二、Netty入门 1. 概述 1.1 Netty是什么 Netty is an asynchronous event-driven network application framework for rapid development of maintainable high performance protocol servers & clients. Netty是一个异步的、基于事件驱动的网络应用框架&#xff0c;用于…...

Mysql8 忘记密码重置,以及问题解决

1.使用免密登录 找到配置MySQL文件&#xff0c;我的文件路径是/etc/mysql/my.cnf&#xff0c;有的人的是/etc/mysql/mysql.cnf 在里最后加入 skip-grant-tables重启MySQL服务 service mysql restartShutting down MySQL… SUCCESS! Starting MySQL… SUCCESS! 重启成功 2.登…...

Linux 中如何提取压缩文件 ?

Linux 是一种流行的开源操作系统&#xff0c;它提供了许多工具来管理、压缩和解压缩文件。压缩文件有助于节省存储空间&#xff0c;使数据传输更快。本指南将向您展示如何在 Linux 中提取不同类型的压缩文件。 1. Unpacking ZIP Files ZIP 文件是非常常见的&#xff0c;要在 …...

uniapp 字符包含的相关方法

在uniapp中&#xff0c;如果你想检查一个字符串是否包含另一个子字符串&#xff0c;你可以使用JavaScript中的includes()方法或者indexOf()方法。这两种方法都可以达到目的&#xff0c;但它们在处理方式和返回值上有所不同。 使用includes()方法 includes()方法用于判断一个字…...

通过 Ansible 在 Windows 2022 上安装 IIS Web 服务器

拓扑结构 这是一个用于通过 Ansible 部署 IIS Web 服务器的实验室拓扑。 前提条件&#xff1a; 在被管理的节点上安装WinRm 准备一张自签名的证书 开放防火墙入站tcp 5985 5986端口 准备自签名证书 PS C:\Users\azureuser> $cert New-SelfSignedCertificate -DnsName &…...