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

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

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

拓展 用户账号和权限

默认账号密码: guest guest

//进入容器

docker exec -it rabbitmq bash rabbit01

查看babbitmq用户:

rabbitmqctl list_users

添加用户

rabbitmqctl add_user admin admin

设置用户角色

rabbitmqctl set_user_tags admin administrator

设置用户权限

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

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【LabVIEW学习】3.labview制作安装程序

一。生成exe文件 1.创建可执行文件 &#xff08;1&#xff09;创建项目 注意&#xff1a; 1.创建.exe文件&#xff0c;这个文件在labview环境下才可以运行&#xff0c;如果直接传递给其他电脑&#xff08;没有labview环境&#xff09;&#xff0c;他是不可以运行的。 2.如果已…

创建SpringBoot流程

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言一、pandas是什么&#xff1f;二、操作步骤总结 前言 我使用的是jdk1.8版本的&#xff0c;idea社区版的&#xff08;专业版的应该也差不多吧&#xff09; 提示…

华清远见嵌入式学习——C++——作业2

作业要求&#xff1a; 代码&#xff1a; #include <iostream>using namespace std;class Rect { private:int width;int height;public:void init(int w,int h);void set_w(int w);void set_h(int h);void show(); };void Rect::init(int w,int h) {width w;height h;…

记一次:Python的学习笔记一

前言&#xff1a;之前学习的Python笔记&#xff0c;已经过去很多年了&#xff0c;不久前重新翻了出来练习练习。不完善的地方在缝缝补补 一、环境搭建 1.1、Python的win环境安装 0、python-3.12.0软件安装&#xff1a;Win11环境搭建python-3.12.0-amd64 这里小小注意一下&a…

vuepress-----3、导航栏

3、导航栏 # 页面目录结构约定 . ├── docs │ ├── .vuepress (可选的) │ │ ├── components (可选的) │ │ ├── theme (可选的) │ │ │ └── Layout.vue │ │ ├── public (可选的) │ │ ├── styles (可选的) │ │ │…

身份证mod11-2校验规则

这几天碰到一个需求是实现身份证最后一位的校验&#xff0c;需求文档里面写了个公式&#xff0c;没看懂&#xff08;数学早就还给老师了&#xff09;&#xff0c;于是各种查资料&#xff0c;发现网上的资料要么只给了说明&#xff0c;要么给了个固定的代码&#xff0c;但是写的…

怎样将Halcon导出的数据显示在textBox中

其中textBox1是文本框的名字&#xff0c;hv_Row时一个数组&#xff0c;.D.我的理解是DATA,即数据的意思&#xff0c;“0.00”是显示的数值保留两位小数点的意思。

数据库系统概述之数据库优化

为什么需要进行优化&#xff1f; 数据库性能瓶颈 数据库服务器的性能受许多因素影响&#xff0c;包括硬件能力、系统规模、业务模型及架构、代码设计、数据库表设计、系统环境等。 因此&#xff0c;可以从几个方面进行数据库优化 喜欢点赞收藏&#xff0c;如有疑问&#xff…

RabbitMQ快速学习之WorkQueues模型、三种交换机、消息转换器(基于SpringBoot)

文章目录 前言一、WorkQueues模型消息发送消息接收能者多劳 二、交换机类型1.Fanout交换机消息发送消息接收 2.Direct交换机消息接收消息发送 3.Topic交换机消息发送消息接收 三、编程式声明队列和交换机fanout示例direct示例基于注解 四、消息转换器总结 前言 WorkQueues模型…

关键词挖掘软件-免费批量挖掘关键词的工具

在当今数字化时代&#xff0c;网站的曝光和排名对于吸引流量至关重要。而在这个大数据的背后&#xff0c;SEO&#xff08;Search Engine Optimization&#xff0c;搜索引擎优化&#xff09;成为许多网站主和创作者们追逐的关键。在SEO的世界里&#xff0c;关键词的选择和优化是…

spring security 艰苦学习中

一、初次感知 1.jwt工具类 密钥secret 有点意思。 2.PasswordEncoder 对密码进行加密&#xff0c;在配置类中返回bean. 下面这个关于加密和解密的东西是有误导性的。

用customize-cra+react-app-rewired配置less+css module

1. 安装 npm i less less-loader -D npm i customize-cra-less-loader -D2.添加配置项 //config-overrides.js const { override } require(customize-cra); const addLessLoader require("customize-cra-less-loader");module.exports {webpack: override(addL…

锚索测力计与振弦采集仪组成桥梁安全监测

锚索测力计与振弦采集仪组成桥梁安全监测 在桥梁工程中&#xff0c;安全监测一直是一个重要的方面。桥梁安全监测可以及时发现桥梁的变形、裂缝、位移等问题&#xff0c;为及时修复或维修提供重要的依据。而锚索测力计和振弦采集仪作为桥梁安全监测的两个主要工具&#xff0c;…

内衣洗衣机和手洗哪个干净?内衣洗衣机便宜好用的牌子推荐

单纯的用手清洗内衣&#xff0c;是很难的清洁到内衣物上的每一个角落的污渍。另外&#xff0c;手洗时所用的水以及香皂并不能彻底杀死衣物上的细菌&#xff0c;反而会在内衣物上滋生细菌。长时间穿这种内衣&#xff0c;对身体有潜在的危害。相比较而言&#xff0c;专用的内衣洗…

Flutter加固原理及加密处理

​ 引言 为了保护Flutter应用免受潜在的漏洞和攻击威胁&#xff0c;加固是必不可少的措施之一。Flutter加固原理主要包括代码混淆、数据加密、安全存储、反调试与反分析、动态加载和安全通信等多个方面。通过综合运用这些措施&#xff0c;可以提高Flutter应用的安全性&#xf…

LeetCode(36)旋转图像【矩阵】【中等】

目录 1.题目2.答案3.提交结果截图 链接&#xff1a; 48. 旋转图像 1.题目 给定一个 n n 的二维矩阵 matrix 表示一个图像。请你将图像顺时针旋转 90 度。 你必须在** 原地** 旋转图像&#xff0c;这意味着你需要直接修改输入的二维矩阵。请不要 使用另一个矩阵来旋转图像。 …

日志监控(确保日志在你这台计算机上面)

如果你希望在Linux上面实时监控日志文件的变化并动态刷新&#xff0c;可以考虑使用一些外部工具&#xff0c;如 tail 命令&#xff1a; tail -f your_log_file.logWindows可以使用Notepad&#xff1a;

jdk动态代理和CGLIBE代理

静态代理&#xff1a;由程序员创建或特定工具自动生成源代码&#xff0c;再对其编译。在程序运行前&#xff0c;代理类的.class文件就已经存在了。 动态代理&#xff1a;在程序运行时&#xff0c;运用反射机制动态创建而成。 使用jdk的反射机制&#xff0c;创建对象的能力&…

STM32通讯设计

STM32通讯设计 通讯流程STM32程序 通讯流程 1.使用HT2202芯片配置为主机接收&#xff08;轮询模式&#xff09;。 2.将STM32芯片配置为从机发送&#xff0c;中断模式下发送固定数据。 3.如果HT2202芯片能够收到STM32发送的数据则通讯成功&#xff0c;否则通讯失败。 STM32程序…

虹科分享 | 平衡速度和优先级:为多样化的实时需求打造嵌入式网络(4)——从理论到实践:CANopen源代码配置

正如前文所述&#xff0c;CANopen的适应性在满足实时应用需求方面发挥着至关重要的作用。本系列文章的最后一部分将向您展示 CANopen 源代码配置的技术细节&#xff0c;以及实现高效实时性能的优化方法。 前文回顾&#xff1a; 虹科分享 | 平衡速度和优先级&#xff1a;为多样…