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

相关文章

使用Sentinel自定义返回和实现区分来源方式

《使用Sentinel自定义返回和实现区分来源方式》:本文主要介绍使用Sentinel自定义返回和实现区分来源方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Sentinel自定义返回和实现区分来源1. 自定义错误返回2. 实现区分来源总结Sentinel自定

Springboot处理跨域的实现方式(附Demo)

《Springboot处理跨域的实现方式(附Demo)》:本文主要介绍Springboot处理跨域的实现方式(附Demo),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不... 目录Springboot处理跨域的方式1. 基本知识2. @CrossOrigin3. 全局跨域设置4.

springboot security使用jwt认证方式

《springbootsecurity使用jwt认证方式》:本文主要介绍springbootsecurity使用jwt认证方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录前言代码示例依赖定义mapper定义用户信息的实体beansecurity相关的类提供登录接口测试提供一

springboot security之前后端分离配置方式

《springbootsecurity之前后端分离配置方式》:本文主要介绍springbootsecurity之前后端分离配置方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的... 目录前言自定义配置认证失败自定义处理登录相关接口匿名访问前置文章总结前言spring boot secu

SpringBoot中封装Cors自动配置方式

《SpringBoot中封装Cors自动配置方式》:本文主要介绍SpringBoot中封装Cors自动配置方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录SpringBoot封装Cors自动配置背景实现步骤1. 创建 GlobalCorsProperties

Flutter打包APK的几种方式小结

《Flutter打包APK的几种方式小结》Flutter打包不同于RN,Flutter可以在AndroidStudio里编写Flutter代码并最终打包为APK,本篇主要阐述涉及到的几种打包方式,通... 目录前言1. android原生打包APK方式2. Flutter通过原生工程打包方式3. Futte

一文详解如何从零构建Spring Boot Starter并实现整合

《一文详解如何从零构建SpringBootStarter并实现整合》SpringBoot是一个开源的Java基础框架,用于创建独立、生产级的基于Spring框架的应用程序,:本文主要介绍如何从... 目录一、Spring Boot Starter的核心价值二、Starter项目创建全流程2.1 项目初始化(

Docker镜像pull失败两种解决办法小结

《Docker镜像pull失败两种解决办法小结》有时候我们在拉取Docker镜像的过程中会遇到一些问题,:本文主要介绍Docker镜像pull失败两种解决办法的相关资料,文中通过代码介绍的非常详细... 目录docker 镜像 pull 失败解决办法1DrQwWCocker 镜像 pull 失败解决方法2总

使用Java实现通用树形结构构建工具类

《使用Java实现通用树形结构构建工具类》这篇文章主要为大家详细介绍了如何使用Java实现通用树形结构构建工具类,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录完整代码一、设计思想与核心功能二、核心实现原理1. 数据结构准备阶段2. 循环依赖检测算法3. 树形结构构建4. 搜索子

在C#中调用Python代码的两种实现方式

《在C#中调用Python代码的两种实现方式》:本文主要介绍在C#中调用Python代码的两种实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录C#调用python代码的方式1. 使用 Python.NET2. 使用外部进程调用 Python 脚本总结C#调