DockerCompose部署RabbitMQ集群

DockerCompose部署RabbitMQ集群

最近小黄在工作中正好需要部署RabbitMQ集群，借此来记录一下，也希望可以帮助到大家

前置条件

简单介绍一下咱们公司现有的条件以及想要达成的效果

服务器3台，3台都是属于一个专有网络中，也就是说3台机子形成局域网，可以互相访问

  • ServerA：有公网ip的服务器，可以访问公网
  • ServerB：只有私网的服务器，需要通过ServerA来访问公网
  • ServerC：同ServerB

因为ServerA的内存占用已经比较高了，所以小黄的想法是在ServerB、ServerC上各部署一个RabbitMQ形成集群，因为程序也是跑在局域网中，所以不需要向外暴露5672端口，只需要在ServerA上通过反向代理暴露15672端口即可

修改hosts文件，让他们通过ServerA这种命名的方式访问各自的ip

172.16.0.130 ServerA
172.16.0.131 ServerB
172.16.0.132 ServerC

部署RabbitMQ

小黄采用的是DockerCompose方式部署，这里刚开始小黄就踩坑了

拉镜像

因为ServerB、ServerC没办法直接去docker仓库拉镜像，所以需要在ServerA上拉镜像在传到私网服务器上

# ServerA上执行
# 拉镜像，这里要注意的是，一定要拉management，只有management才有可视化管理页面的插件
docker pull rabbitmq:management# 导出镜像
docker save -o rabbitmq.tar rabbitmq:management# 发送文件到ServerB、ServerC
rsync -av /root/docker-images/rabbitmq.tar ServerB:/root# ServerB、ServerC上执行
docker load -i rabbitmq.tar

docker-compose.yml

接下来需要编写docker-compose.yml文件，以ServerB来介绍，ServerC只是需要讲ServerB修改成ServerC即可

version: "3.2"
services:rabbitmq:image: rabbitmq:managementcontainer_name: rabbitmqrestart: on-failure:5# 对应host文件hostname: ServerB# 这个是向容器内部添加hosts文件，这里需要与ServerC形成集群，所以要写ServerC的地址extra_hosts:- "ServerC:172.16.0.132"ports:- "4369:4369"- "5672:5672"- "15672:15672"- "25672:25672"volumes:- ./data:/var/lib/rabbitmq- ./erlang.cookie:/var/lib/rabbitmq/.erlang.cookieenvironment:- RABBITMQ_DEFAULT_USER=admin- RABBITMQ_DEFAULT_PASS=admin- RABBITMQ_NODENAME=rabbit@ServerB # 节点名称networks:- rabbitmq-networknetworks:rabbitmq-network:driver: bridge

接下来要解释几个关键信息

暴露端口

5672、15672就不介绍了，这里注意安全组得开放这些端口，出方向、入方向都需要

  • 4369：这是 Erlang 分布式节点之间通信的 epmd（Erlang Port Mapper Daemon）端口。epmd 是一个用于管理 Erlang 节点之间通信的守护进程，它负责维护一个节点注册表，以便其他节点可以发现和连接到正在运行的节点。在 RabbitMQ 集群中，节点之间使用 epmd 来进行通信和发现。
  • 25672：这是 RabbitMQ 节点之间的 AMQP 0-9-1 协议端口。在 RabbitMQ 集群中，节点之间使用此端口进行内部通信，包括集群节点之间的消息传递和状态同步。

.erlang.cookie

.erlang.cookie存储了一串密钥，这个可以自定义，需要加入相同的集群，就需要里面的编码一致，我这边采取挂载的方式来修改，也可以进入容器内部修改

搭建集群

在ServerB、ServerC上启动RabbitMQ，在mq中是不存在主节点、子节点的关系的，但我还是比较习惯这样称呼，目前讲ServerB作为主节点，ServerC来主动加入该集群成为子节点

# 进入ServerC上的容器
docker exec -it rabbitmq /bin/bashrabbitmqctl stop_app
rabbitmqctl reset
# 加入集群，rabbit@ServerB要对应上面设置的RABBITMQ_NODENAME
# --ram将消息存储在内存中，不加则存储在磁盘空间，这取决于个人
rabbitmqctl join_cluster --ram rabbit@ServerB
rabbitmqctl start_app

执行完之后，就可以查看集群信息

rabbitmqctl cluster_status

看到这个输出，集群就搭建成功了

image-20231214105111561

测试

在ServerB上创建队列、交换机、绑定关系并且发送信息，在ServerC上也可以获取到这些信

# 执行这些操作前，需要向创建用户、授予权限
# 创建新用户
rabbitmqctl add_user your_username your_password# 授予管理员权限
rabbitmqctl set_user_tags your_username administrator# 授予访问虚拟主机的权限
rabbitmqctl set_permissions -p / your_username ".*" ".*" ".*"# 创建队列
rabbitmqadmin declare queue name=<队列名称> --username=username --password=password# 创建交换机
rabbitmqadmin declare exchange name=<交换机名称> type=<交换机类型> --username=username --password=password# 绑定队列到交换机
rabbitmqadmin declare binding source=<交换机名称> destination=<队列名称> routing_key=<路由键> --username=username --password=password# 向交换机发送消息
rabbitmqadmin publish exchange=your_exchange_name routing_key=your_routing_key payload="Your message content" --username=username --password=password# 查看队列中的消息
rabbitmqadmin get queue=your_queue_name --username=username --password=password

在小黄的一系列测试中，发现一个问题，向ServerB中发送消息后，消息其实是存在ServerB上的，ServerC上并没有存储该消息的内容

也就是说现在的集群只能做到一部分的功能，当程序连接到某一个RabbitMQ节点时，他会自动发现集群，加入到集群中，当ServerB挂掉之后，ServerC可以继续承担消息收发的功能，当时ServerB挂掉之前假如队列中有消息没处理完，那这些消息将不复存在，也就是说会出现消息丢失的情况

镜像队列

  • 优点：镜像队列会将队列中的消息在集群中的多个节点之间进行复制。这样，无论消息最初被发送到哪个节点，它都会被复制到其他节点上，确保即使某个节点发生故障，消息仍然可以被其他节点消费，提供冗余和高可用性

  • 缺点：资源消耗

使用正则表达式"^myqueue.*"来匹配myqueue开头的队列

rabbitmqctl set_policy ha-all "^myqueue.*" '{"ha-mode":"all"}' --priority 0 --apply-to queues

如果设置所有队列都为镜像队列

rabbitmqctl set_policy ha-all ".*" '{"ha-mode":"all"}' --apply-to queues

再次测试，发现ServerB即使挂掉，还是可以从ServerC上读取数据

反向代理

我们还是用docker compose的方式来部署nginx，只暴露我们需要的端口

version: "3.2"
services:nginx:image: nginx:stable-perlcontainer_name: nginx-middlewareuser: rootprivileged: trueports:- "15672:15672"volumes:- /root/nginx-middleware/html:/usr/share/nginx- /root/nginx-middleware/conf/nginx.conf:/etc/nginx/nginx.conf- /root/nginx-middleware/log:/var/log/nginxenvironment:- TZ=Asia/Shanghai- LANG=C.UTF-8- LC_ALL=C.UTF-8networks:nginx-middleware:aliases: - nignx-warelogging:driver: "json-file"options:max-size: "30m"networks:nginx-middleware: external: true

nginx.conf

worker_processes  1;events {worker_connections  1024;
}http {server {listen 15683;server_name 外网ip;location / {proxy_pass http://私网服务器ip:15672;proxy_set_header Host $host;proxy_set_header X-Real-IP $remote_addr;}}
}

这里有一个很坑的点，记录一下，当时配的proxy_pass http://私网服务器ip:15672/，因为结尾多了一个斜杠，导致只能访问管理页面主界面，其他请求全都是404

小Tip

必须要保证安全组开放了15672端口，授权对象0.0.0.0

之前小黄只是授权了私网ip可以访问，导致telnet访问不不通

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

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

相关文章

【开源】基于JAVA的桃花峪滑雪场租赁系统

【开源】基于JAVA的桃花峪滑雪场租赁系统

项目编号&#xff1a; S 036 &#xff0c;文末获取源码。 \color{red}{项目编号&#xff1a;S036&#xff0c;文末获取源码。} 项目编号&#xff1a;S036&#xff0c;文末获取源码。 目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 游客服务2.2 雪场管理 三、数据库设…
阅读更多...
关于“Python”的核心知识点整理大全19

关于“Python”的核心知识点整理大全19

目录 ​编辑 8.6.4 使用 as 给模块指定别名 8.6.5 导入模块中的所有函数 8.7 函数编写指南 8.8 小结 第9章 类 9.1 创建和使用类 9.1.1 创建 Dog 类 dog.py 1. 方法__init__() 2. 在Python 2.7中创建类 9.1.2 根据类创建实例 1. 访问属性 2. 调用方法 3. 创建多…
阅读更多...
快速搭建知识付费平台？我有才，为你提供一站式解决方案

快速搭建知识付费平台？我有才，为你提供一站式解决方案

在当今数字化时代&#xff0c;知识付费已经成为一种趋势&#xff0c;越来越多的人愿意为有价值的知识付费。然而&#xff0c;公共知识付费平台虽然内容丰富&#xff0c;但难以满足个人或企业个性化的需求和品牌打造。同时&#xff0c;开发和维护一个属于自己的知识付费平台需要…
阅读更多...
Oracle md5

Oracle md5

SQL CREATE OR REPLACE FUNCTION MD5(passwd IN VARCHAR2) RETURN VARCHAR2 ISretval varchar2(32); BEGINretval : utl_raw.cast_to_raw(DBMS_OBFUSCATION_TOOLKIT.MD5(INPUT_STRING > passwd));RETURN retval; END; 测试 select md5(lw112190) from dual 效果
阅读更多...
70套大数据可视化大屏模板,总有一款适合你(含演示示例)

70套大数据可视化大屏模板,总有一款适合你(含演示示例)

分享70款还不错的前端数据可视化大屏源码 其中包含行业&#xff1a;智慧社区、智慧物业、政务系统、智慧交通、智慧工程、智慧医疗、智慧金融银行等&#xff0c;全网最新、最多&#xff0c;最全、最酷、最炫大数据可视化模板。 你可以点击预览获取查看该源码资源的最终展示效果…
阅读更多...
三、JS逆向

三、JS逆向

一、JS逆向 解释&#xff1a;在我们爬虫的过程中经常会遇到参数被加密的情况&#xff0c;这样只有先在前端搞清楚加密参数是怎么生成的才能继续我们的爬虫&#xff0c;而且此时我们还需要用python去执行这个加密的过程。本文主要讲怎么在浏览器调试JS&#xff0c;以及Python执…
阅读更多...
基于ssm企业人事管理系统的设计与实现论文

基于ssm企业人事管理系统的设计与实现论文

摘 要 进入信息时代以来&#xff0c;很多数据都需要配套软件协助处理&#xff0c;这样可以解决传统方式带来的管理困扰。比如耗时长&#xff0c;成本高&#xff0c;维护数据困难&#xff0c;数据易丢失等缺点。本次使用数据库工具MySQL和编程技术SSM开发的企业人事管理系统&am…
阅读更多...
后端对数据库查询的时间格式化

后端对数据库查询的时间格式化

方式一&#xff1a; 在属性上加入注解&#xff0c;对日期进行格式化&#xff0c;如&#xff1a; JsonFormat(pattern "yyyy-MM-dd HH:mm:ss") private LocalDateTime updateTime;方式二&#xff1a; 在WebMvcConfiguration 中扩展Spring MVC的消息转换器&#xf…
阅读更多...
基于ssm旅行社管理系统的设计与实现论文

基于ssm旅行社管理系统的设计与实现论文

摘 要 现代经济快节奏发展以及不断完善升级的信息化技术&#xff0c;让传统数据信息的管理升级为软件存储&#xff0c;归纳&#xff0c;集中处理数据信息的管理方式。本旅行社管理系统就是在这样的大环境下诞生&#xff0c;其可以帮助管理者在短时间内处理完毕庞大的数据信息&…
阅读更多...
RFID助力光伏硅片生产：透明溯源，质量至上

RFID助力光伏硅片生产：透明溯源，质量至上

RFID助力光伏硅片生产&#xff1a;透明溯源&#xff0c;质量至上 应用背景 光伏产业作为可再生能源的主要发展方向之一&#xff0c;在过去几十年中取得了显著的进展。为了提高光伏产业的效率和质量。在光伏硅片生产过程中&#xff0c;原材料的获取、管理和追溯对于保证硅片品…
阅读更多...
换能器信号工作原理

换能器信号工作原理

一、ANB板子发送一个周期&#xff0c;频率为40M和60M的 78V的激励脉冲信号。如下图 频率越高&#xff0c;周期越短。图像分辨率更高。原因如下&#xff1a; ①由于采用的是纵向分辨率。相邻两个点之间必须要间隔 下图的2分之兰大才能被识别。 二、当信号给到换能器后&#xf…
阅读更多...
邮政快递物流查询，分析筛选出提前签收件

邮政快递物流查询，分析筛选出提前签收件

批量查询邮政快递单号的物流信息&#xff0c;将提前签收件分析筛选出来。 所需工具&#xff1a; 一个【快递批量查询高手】软件 邮政快递单号若干 操作步骤&#xff1a; 步骤1&#xff1a;运行【快递批量查询高手】软件&#xff0c;并登录 步骤2&#xff1a;点击主界面左上角…
阅读更多...
SpringBoot核心功能-temp

SpringBoot核心功能-temp

yml&类配置 Configuration-processor
阅读更多...
nestjs守卫/全局守卫校验jwt

nestjs守卫/全局守卫校验jwt

一、守卫 目标 部分接口需要用户登录后才可以访问&#xff0c;用户登录后可以颁发 jwt_token 给前端&#xff0c;前端在调用需要鉴权的接口&#xff0c;需要在请求头添加 jwt_token&#xff0c;后端校验通过才能继续访问&#xff0c;否则返回403无权访问 创建守卫 anth 安装…
阅读更多...
mysql：不要在索引列进行数学运算和函数运算

mysql：不要在索引列进行数学运算和函数运算

不要在索引列进行数学运算和函数运算。这是因为数学运算和函数运算会改变索引列的值&#xff0c;导致索引失效。 如果需要进行计算或函数处理&#xff0c;最好将数据取出并在应用程序中进行处理。 下面举个对照的例子&#xff1a; 1&#xff09;看语句explain select * from …
阅读更多...
注塑模具ERP有哪些功能?可以帮助企业解决什么难题

注塑模具ERP有哪些功能?可以帮助企业解决什么难题

不同的注塑模具有不同的业务流程和生产环节&#xff0c;有些生产企业在订单、物料需求计划、车间、班组负荷评估、项目成本核算、边角料统计分析等方面还存在不少问题。 与此同时&#xff0c;也有部分注塑模具企业通过ERP软件科学制定注塑生产排产&#xff0c;智能核算注塑物料…
阅读更多...
用print太慢了！强烈推荐这款Python Debug工具~

用print太慢了！强烈推荐这款Python Debug工具~

作为程序员&#xff0c;我们都深知调试&#xff08;Debug&#xff09;在编程过程中的重要性。然而&#xff0c;使用传统的"print"语句进行调试可能效率较低&#xff0c;今天&#xff0c;笔者将推荐一款独具一格的Python调试工具——Reloadium。Reloadium为IDE添加了热…
阅读更多...
深入理解Spring Security授权机制原理

深入理解Spring Security授权机制原理

原创/朱季谦 在Spring Security权限框架里&#xff0c;若要对后端http接口实现权限授权控制&#xff0c;有两种实现方式。 一、一种是基于注解方法级的鉴权&#xff0c;其中&#xff0c;注解方式又有Secured和PreAuthorize两种。 Secured如&#xff1a; 1 PostMapping("…
阅读更多...
elementui select中添加新增标签

elementui select中添加新增标签

<el-select v-model"ruleForm.eventType" :placeholder"请选择事件类型&#xff0c;可手动添加" ref"template" clearable visible-change"(v) > visibleChange(v, template)"><el-option v-for"item in eventTypeOp…
阅读更多...
【论文极速读】视频检索中的模态均衡方法

【论文极速读】视频检索中的模态均衡方法

【论文极速读】视频检索中的模态均衡方法 FesianXu 20231206 at Baidu Search Team 前言 传统的视频搜索系统相关性部分主要以文本匹配为基础手段&#xff0c;在其中引入多模态向量容易收到『模态不均衡』的问题&#xff0c;论文[1]尝试对其进行解决&#xff0c;本文进行笔记。…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023