rabbitmq构建普通集群docker-compose方式

2024-08-28 09:18

本文主要是介绍rabbitmq构建普通集群docker-compose方式,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1.rabbitmq相关操作命令官方文档:rabbitmq操作命令
2.下载延迟插件:延迟插件下载
下载成功后,上传至安装目录,在此我新建个目录专门作为rabbitmq的安装目录
在这里插入图片描述

3.编写Dockerfile构建新镜像,把延迟插件加进去,或者不用编写Dockerfile直接启动,然后把延迟插件复制进去

以下为编写Dockerfile方式:

Dockerfile文件如下

FROM rabbitmq:3.8.10-rc.5-management-alpine
COPY  rabbitmq_delayed_message_exchange-3.8.0.ez   /plugins
RUN rabbitmq-plugins enable --offline rabbitmq_management rabbitmq_mqtt rabbitmq_federation_management rabbitmq_stomp rabbitmq_delayed_message_exchange rabbitmq_web_stomp rabbitmq_tracing

docker-compose.yml文件如下:

version: '3.9'
services:#服务名称rabbitmq:#构建镜像build: .#镜像名称image: rabbitmq:s1.0#容器名称container_name: rabbitmq#总是重启后启动restart: alwayshostname: rabbitmq01#端口映射ports:- 5672:5672- 15672:15672- 4369:4369- 25672:25672- 61613:61613#挂载volumes:- /data/rabbitmq/data:/var/lib/rabbitmq- /etc/hosts:/etc/hosts- /etc/localtime:/etc/localtimeprivileged: true#环境变量environment:- RABBITMQ_DEFAULT_USER=admin- RABBITMQ_DEFAULT_PASS=qikecheng- RABBITMQ_ERLANG_COOKIE=BGDMHWCMAFHHPOBZEYMG- RABBITMQ_NODENAME=slave01

4.以上文件编写完成,接下来开始启动单个rabbitmq

#启动并构建镜像
docker-compose up --build -d
#如果已构建过可直接使用
docker-compose up -d
#up命令会创建新的容器,down命令会删除已创建的容器
docker-compose down
#以上两个命令容器会受到影响,如果容器已构建成功,正常的停止启动应该使用以下两个命令
#停止
docker-compose stop
#启动
docker-compose start
#更多命令可查看官网或使用帮助命令
docker-compose --help
#查看启动状态
docker-compose ps

5.启动成功查看延时插件是否添加成功
在这里插入图片描述
如果不成功,则可直接进入到容器中再次运行插件启动命令

#查看容器
docker ps
#进入容器
docker exec -it 镜像id /bin/bash
#启用插件
rabbitmq-plugins enable --offline rabbitmq_management rabbitmq_mqtt rabbitmq_federation_management rabbitmq_stomp rabbitmq_delayed_message_exchange

不使用Dockerfile构建方式:
1.直接docker-compose启动rabbitmq,然后再将插件添加到容器中,再运行插件启用命令即可

docker-compose.yml

version: '3.9'
services:#服务名称rabbitmq:#镜像名称image: rabbitmq:3.8.10-rc.5-management-alpine#容器名称container_name: rabbitmq#总是重启后启动restart: alwayshostname: rabbitmq01#端口映射ports:- 5672:5672- 15672:15672- 4369:4369- 25672:25672- 61613:61613#挂载volumes:- /data/rabbitmq/data:/var/lib/rabbitmq- /etc/hosts:/etc/hosts- /etc/localtime:/etc/localtimeprivileged: true#环境变量environment:- RABBITMQ_DEFAULT_USER=admin- RABBITMQ_DEFAULT_PASS=qikecheng- RABBITMQ_ERLANG_COOKIE=BGDMHWCMAFHHPOBZEYMG- RABBITMQ_NODENAME=slave01

2.启动并添加延时插件

#启动并创建容器
docker-compose up -d
#关闭并删除容器,一般不要使用
docker-compose down
#查看启动的容器
docker ps
#将延时插件复制到rabbitmq插件目录中
docker cp rabbitmq_delayed_message_exchange-3.8.0.ez 0f12b4db0d68:/opt/rabbitmq/plugins/
#进入容器
docker exec -it 0f12b4db0d68 /bin/bash
#启用插件
rabbitmq-plugins enable --offline rabbitmq_stomp rabbitmq_delayed_message_exchange
#退出容器
exit

3.重新启动容器,延时插件才会生效

#停止
docker-compose stop
#启动
docker-compose start

4.访问控制台即可查看到容器插件已经添加成功
在这里插入图片描述

构建rabbimq集群:
1.构建前环境准备,我这里构建的集群是分布于三台独立虚拟机的,不是在一台上构建,在同一台上勾建相对简单。
2.配置三台hosts映射,hosts中必须包含刚刚构建yml中指定的虚拟hostname名称
我的三台机器配置如下:
在这里插入图片描述

3.保证三台机.erlang.cookie相同,我这里是在yml中进行了指定,但是新版本已不推荐此方式,如果不在yml中指定,则复制一台机的到另外两台机上,保持一致就行,.erlang.cookie的目录在&HOME目录下,docker-compose方式是存放在映射的目录下,如下图
在这里插入图片描述
4.随便选一台作为集群主机,将其它node节点加入到该集群主机中即可构建成普通集群了

#查看启动的容器
docker ps
#将延时插件复制到rabbitmq插件目录中
docker cp rabbitmq_delayed_message_exchange-3.8.0.ez 0f12b4db0d68:/opt/rabbitmq/plugins/
#进入容器
docker exec -it 0f12b4db0d68 /bin/bash
#停止el虚拟机
rabbitmqctl stop_app
rabbitmqctl reset
#加入集群
rabbitmqctl join_cluster master01@rabbitmq00
#再次启动
rabbitmqctl start_app
#要加入的节点执行以上操作即可加入集群

master01@rabbitmq00名称必须要与主节点一致,不然找不到,会报错,大多错误原因由此引起
在这里插入图片描述

5.加入完成,进行如任意主机页面查看,即可看到构建成功的集群
在这里插入图片描述

6.将slave01@rabbitmq01节点移除集群

rabbitmqctl forget_cluster_node slave01@rabbitmq01

7.至此普通集群已构建完成,如果想设置为镜像队列,可做如下策略设置
设置镜像队列命令:“rabbitmqctl set_policy 名称 匹配模式(正则) 镜像定义”

#设置惊醒队列
rabbitmqctl set_policy ha-all "^" '{"ha-mode":"all"}'
#查看集群状态
rabbitmqctl status

控制台查看是否成功,也可控制台设置
在这里插入图片描述
创建的测试queue
在这里插入图片描述
在这里插入图片描述

这篇关于rabbitmq构建普通集群docker-compose方式的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1114354

相关文章

使用docker搭建嵌入式Linux开发环境

《使用docker搭建嵌入式Linux开发环境》本文主要介绍了使用docker搭建嵌入式Linux开发环境,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录1、前言2、安装docker3、编写容器管理脚本4、创建容器1、前言在日常开发全志、rk等不同

Three.js构建一个 3D 商品展示空间完整实战项目

《Three.js构建一个3D商品展示空间完整实战项目》Three.js是一个强大的JavaScript库,专用于在Web浏览器中创建3D图形,:本文主要介绍Three.js构建一个3D商品展... 目录引言项目核心技术1. 项目架构与资源组织2. 多模型切换、交互热点绑定3. 移动端适配与帧率优化4. 可

HTTP 与 SpringBoot 参数提交与接收协议方式

《HTTP与SpringBoot参数提交与接收协议方式》HTTP参数提交方式包括URL查询、表单、JSON/XML、路径变量、头部、Cookie、GraphQL、WebSocket和SSE,依据... 目录HTTP 协议支持多种参数提交方式,主要取决于请求方法(Method)和内容类型(Content-Ty

RabbitMQ 延时队列插件安装与使用示例详解(基于 Delayed Message Plugin)

《RabbitMQ延时队列插件安装与使用示例详解(基于DelayedMessagePlugin)》本文详解RabbitMQ通过安装rabbitmq_delayed_message_exchan... 目录 一、什么是 RabbitMQ 延时队列? 二、安装前准备✅ RabbitMQ 环境要求 三、安装延时队

使用shardingsphere实现mysql数据库分片方式

《使用shardingsphere实现mysql数据库分片方式》本文介绍如何使用ShardingSphere-JDBC在SpringBoot中实现MySQL水平分库,涵盖分片策略、路由算法及零侵入配置... 目录一、ShardingSphere 简介1.1 对比1.2 核心概念1.3 Sharding-Sp

Spring创建Bean的八种主要方式详解

《Spring创建Bean的八种主要方式详解》Spring(尤其是SpringBoot)提供了多种方式来让容器创建和管理Bean,@Component、@Configuration+@Bean、@En... 目录引言一、Spring 创建 Bean 的 8 种主要方式1. @Component 及其衍生注解

Redis中哨兵机制和集群的区别及说明

《Redis中哨兵机制和集群的区别及说明》Redis哨兵通过主从复制实现高可用,适用于中小规模数据;集群采用分布式分片,支持动态扩展,适合大规模数据,哨兵管理简单但扩展性弱,集群性能更强但架构复杂,根... 目录一、架构设计与节点角色1. 哨兵机制(Sentinel)2. 集群(Cluster)二、数据分片

python中的显式声明类型参数使用方式

《python中的显式声明类型参数使用方式》文章探讨了Python3.10+版本中类型注解的使用,指出FastAPI官方示例强调显式声明参数类型,通过|操作符替代Union/Optional,可提升代... 目录背景python函数显式声明的类型汇总基本类型集合类型Optional and Union(py

Linux系统管理与进程任务管理方式

《Linux系统管理与进程任务管理方式》本文系统讲解Linux管理核心技能,涵盖引导流程、服务控制(Systemd与GRUB2)、进程管理(前台/后台运行、工具使用)、计划任务(at/cron)及常用... 目录引言一、linux系统引导过程与服务控制1.1 系统引导的五个关键阶段1.2 GRUB2的进化优

Python利用PySpark和Kafka实现流处理引擎构建指南

《Python利用PySpark和Kafka实现流处理引擎构建指南》本文将深入解剖基于Python的实时处理黄金组合:Kafka(分布式消息队列)与PySpark(分布式计算引擎)的化学反应,并构建一... 目录引言:数据洪流时代的生存法则第一章 Kafka:数据世界的中央神经系统消息引擎核心设计哲学高吞吐