docker安装rockerMQ
参考Docker部署RocketMQ5.x (单机部署+配置参数详解+不使用docker-compose直接部署)_rocketmq不推荐用docker部署-CSDN博客
镜像拉取
镜像地址: https://hub.docker.com/r/apache/rocketmq/tags
我在部署的时候最新发行版是5.1.0可以根据需求自行选择一个5.x的版本,部署流程不会有太大改变。
docker pull apache/rocketmq:5.1.0
部署NameServer
NameServer是一个简单的 Topic 路由注册中心,支持 Topic、Broker 的动态注册与发现,几乎无状态节点,因此可集群部署,节点之间无任何信息同步,所谓的集群部署和单机部署其实是一样的,需要多个NameServer保持高可用只需独立部署即可。
创建挂载文件夹
或者
mkdir -p ./nameserver/logs
mkdir -p ./nameserver/bin
设置权限:如果不设置会导致NameServer容器内部无法写日志文件
chmod 777 -R /opt/service/slhy-hywl-rocketmq-docker/nameserver/*
参考:
创建挂载文件
NameServer启动脚本中有一个自动计算最大堆内存和新生代内存的函数会导致在不同硬件环境下设置最大堆内存和新生代内存环境变量不被应用,,这里先提前copy一份容器内部启动脚本做挂载,如果想自定义内存可以自己调整。
1、启动容器
docker run -d \
--privileged=true \
--name rmqnamesrv \
apache/rocketmq:5.1.0 sh mqnamesrv
2、复制容器内启动脚本到挂载目录
docker cp rmqnamesrv:/home/rocketmq/rocketmq-5.1.0/bin/runserver.sh /opt/service/slhy-hywl-rocketmq-docker/nameserver/bin/runserver.sh
3、修改runserver.sh
vi /opt/service/slhy-hywl-rocketmq-docker/nameserver/bin/runserver.sh
找到调用calculate_heap_sizes函数的位置注释掉保存即可,拉到脚本最底部就能找到
4、停止&删除容器
docker stop rmqnamesrv
docker rm rmqnamesrv
5、启动NameServer
sudo docker run -d \
--privileged=true \
--restart=always \
--name rmqnamesrv \
-p 9876:9876 \
-v /opt/service/slhy-hywl-rocketmq-docker/nameserver/logs:/home/rocketmq/logs \
-v /opt/service/slhy-hywl-rocketmq-docker/nameserver/bin/runserver.sh:/home/rocketmq/rocketmq-5.1.0/bin/runserver.sh \
-e "MAX_HEAP_SIZE=256M" \
-e "HEAP_NEWSIZE=128M" \
apache/rocketmq:5.1.0 sh mqnamesrv
docker ps -a | grep rmqnamesrv
部署Broker
创建的挂载文件夹
提前创建挂载目录用于挂载容器内部数据、配置文件、以及日志。
mkdir /opt/service/slhy-hywl-rocketmq-docker/broker/logs -p
mkdir /opt/service/slhy-hywl-rocketmq-docker/broker/store -p
mkdir /opt/service/slhy-hywl-rocketmq-docker/broker/conf -p
mkdir /opt/service/slhy-hywl-rocketmq-docker/broker/bin -p
设置权限
chmod 777 -R /opt/service/slhy-hywl-rocketmq-docker/broker/*
创建broker.conf文件
在/usr/local/rocketmq/broker/conf文件夹下创建broker.conf文件
vi /opt/service/slhy-hywl-rocketmq-docker/broker/conf/broker.conf
添加以下配置信息到broker.conf
# NameServer 地址,外部访问配置为宿主机 IP 和映射端口
namesrvAddr = 37.121.124.108:9876# 集群名称
brokerClusterName = DefaultCluster# Broker 名称
brokerName = broker-a# Broker ID,0 表示 Master,其他正整数表示 Slave
brokerId = 0# Broker 服务地址,内外都配置为宿主机 IP
brokerIP1 = 37.121.124.108# HA 地址,一般和 brokerIP1 相同
brokerIP2 = 37.121.124.108# Broker 角色
brokerRole = ASYNC_MASTER# 刷盘方式
flushDiskType = ASYNC_FLUSH# 删除过期文件时间点(默认凌晨 4 点)
deleteWhen = 04# 文件保留时间(小时)
fileReservedTime = 72# 是否允许自动创建 Topic(生产环境建议关闭)
autoCreateTopicEnable=true# 是否允许自动创建订阅组(生产环境建议关闭)
autoCreateSubscriptionGroup=true
说明:建立broker.conf文件,通过这个文件把RocketMQ的broker管理起来
当你在 另一个容器(Broker 容器) 中启动 Broker 时,
namesrvAddr
指向 宿主机的 IP 地址 37.121.124.108
:9876
,那么:
Broker 容器会尝试通过 宿主机网络访问 3
7.121.124.108
:9876
。如果宿主机上的
9876
端口确实被 NameServer 容器监听并正确映射,Broker 就能访问到 NameServer。
参考:
外部使用 指的是 外部网络中的服务需要访问这个 Broker。
公网 IP: 是指可以通过互联网访问的 IP 地址。例如:3
7.121.124.108
。假设你的 Broker 在服务器上运行,这个服务器有一个公网 IP,那么你希望外部服务(例如其他系统、客户端)也能访问这个 Broker:
配置:
brokerIP1 = 37.121.124.108
RocketMq部署windos服务器,本地怎么访问!!!RocketMQ连接报错RemotingConnectException: connect to 解决-CSDN博客
Docker安装RocketMQ教程-CSDN博客
拷贝容器内Broker启动脚本到宿主机(如果不需要自定义堆内存可以跳过)
Broker启动脚本中有一个自动计算最大堆内存和新生代内存的函数会导致在不同硬件环境下设置最大堆内存和新生代内存环境变量不被应用,,这里先提前copy一份容器内部启动脚本做挂载,如果想自定义内存可以自己调整。
1、启动容器
docker run -d \
--name rmqbroker \
--privileged=true \
apache/rocketmq:5.1.0 \
sh mqbroker
2、复制容器内启动脚本到挂载目录
docker cp rmqbroker:/home/rocketmq/rocketmq-5.1.0/bin/runbroker.sh /opt/service/slhy-hywl-rocketmq-docker/broker/bin/runbroker.sh
vi /opt/service/slhy-hywl-rocketmq-docker/broker/bin/runbroker.sh
找到调用calculate_heap_sizes函数的位置注释掉保存即可,拉到脚本最底部就能找到
docker stop rmqbroker
docker rm rmqbroker
docker run -d \
--restart=always \
--name rmqbroker \
-p 10911:10911 -p 10909:10909 \
--privileged=true \
-v /opt/service/slhy-hywl-rocketmq-docker/broker/logs:/root/logs \
-v /opt/service/slhy-hywl-rocketmq-docker/broker/store:/root/store \
-v /opt/service/slhy-hywl-rocketmq-docker/broker/conf/broker.conf:/home/rocketmq/broker.conf \
-v /opt/service/slhy-hywl-rocketmq-docker/broker/bin/runbroker.sh:/home/rocketmq/rocketmq-5.1.0/bin/runbroker.sh \
-e "MAX_HEAP_SIZE=512M" \
-e "HEAP_NEWSIZE=256M" \
apache/rocketmq:5.1.0 \
sh mqbroker -c /opt/service/slhy-hywl-rocketmq-docker/broker/conf/broker.conf
部署RocketMQ控制台
镜像拉取
拉取最新版即可
docker pull apacherocketmq/rocketmq-dashboard:latest
docker run -d \
--restart=always \
--name rmqdashboard \
-e "JAVA_OPTS=-Xmx256M -Xms256M -Xmn128M -Drocketmq.namesrv.addr=37.121.124.108:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" \
-p 8083:8080 \
apacherocketmq/rocketmq-dashboard
参考:
然后访问
8083端口
停止容器:
docker stop rmqdashboard
相关文章:

docker安装rockerMQ
参考Docker部署RocketMQ5.x (单机部署配置参数详解不使用docker-compose直接部署)_rocketmq不推荐用docker部署-CSDN博客 镜像拉取 镜像地址: https://hub.docker.com/r/apache/rocketmq/tags 我在部署的时候最新发行版是5.1.0可以根据需求自行选择一个5.x的版本&a…...

交叉引用、多个参考文献插入、跨文献插入word/wps中之【插入[1-3]、连续文献】
我们在写论文时,需要插入大量参考文献。 有时,一句话需要引用多个文献,如:[1-3]或者[1,3,4]这种形式多个文献插入、跨文献插入。 在上一篇文章中,我们提到可以直接打“-”或者“,”,但是word导出…...

PLC双人舞:profinet转ethernet ip网关奏响施耐德与AB的协奏曲
PLC双人舞:ethernet ip转profinet网关奏响施耐德与AB的协奏曲 案例分析:施耐德PLC与AB PLC的互联互通 在现代工业自动化中,设备之间的互联互通至关重要。本案例旨在展示如何通过北京倍讯科技的EtherNet/IP转Modbus网关,将施耐德P…...
Image and depth from a conventional camera with a coded aperture论文阅读
Image and depth from a conventional camera with a coded aperture 1. 研究目标与实际意义1.1 研究目标1.2 实际问题与产业意义2. 创新方法:编码光圈设计与统计模型2.1 核心思路2.2 关键公式与模型架构2.2.1 图像形成模型2.2.2 深度可区分性准则2.2.3 统计模型与优化框架2.2…...

缺乏团队建设活动,如何增强凝聚力?
当一个团队缺乏系统性的建设活动时,成员之间容易产生疏离感、误解与信任缺失,最终影响整体执行力和目标达成。要有效增强团队凝聚力,应从设计高参与感的团队活动、结合业务与人文目标、营造持续共创的文化机制、推动跨层级协作互动等层面着手…...
特征筛选方法总结
非模型方法 一.FILTER过滤法: 1.缺失值比例(80%以上缺失则删除)/方差 注意: 连续变量只删方差为0的,因为变量取值范围会影响方差大小。 离散类的看各类取值占比,如果是三分类变量可以视作连续变量。 函数:V…...

力扣HOT100之二叉树:230. 二叉搜索树中第 K 小的元素
这道题直接用最笨的办法来做的,用递归来做,我们定义一个全局变量vector<int> element,然后使用中序遍历,每当碰到一个非空节点就将其加入到向量中,这样依赖当向量中的元素小于k时,就返回0,…...
pinia.defineStore is not a function
错误信息表明 pinia.defineStore 不是一个函数,这通常意味着 pinia 没有被正确导入或初始化。 解决方案 检查 Pinia 的导入 确保你从 pinia 中正确导入了 defineStore。正确的导入方式应该是: javascript import { defineStore } from ‘pinia’; 如果你使用的是 createPin…...
入职软件开发与实施工程师了后........
时隔几个月没有创作的我又回来了,这几个月很忙,我一直在找工作,在自考(顺便还处理了一下分手的事),到处奔波,心力交瘁。可能我骨子里比较傲吧。我不愿意着急谋生,做我不愿意做的普通…...
PCL点云库点云数据处理入门系列教材目录(2025年5月更新....)
PCL点云库点云数据处理入门系列教材目录 基础阶段 第 1 讲:PCL库简介和安装(Win10/11VS2019PCL 1.12.0)第 2 讲:PCL库中点云基本知识和数据类型结构第 3 讲:PCL库中点云数据格式PCD和PLY及其输入输出(IO&…...

Linux面试题集合(5)
把文件1的内容追加到文件2 cat 文件1>>文件2 把文件1和文件2合并成文件3 cat 文件1 文件2>文件3 使用less查看文件时,搜寻ab字符 /ab 用more和less如何查看文件 more: CtrlF -- 向下滚动一屏 CtrlB -- 返回上一屏 f -- 向下翻屏 b -- 向上翻屏 …...

python动漫论坛管理系统
目录 技术栈介绍具体实现截图系统设计研究方法:设计步骤设计流程核心代码部分展示研究方法详细视频演示试验方案论文大纲源码获取/详细视频演示 技术栈介绍 Django-SpringBoot-php-Node.js-flask 本课题的研究方法和研究步骤基本合理,难度适中…...
【ubuntu24.04】pycharm 死机结束进程
windows 远程pycharm到ubuntu执行程序 pycharm 在调试过程中,内存耗尽,然后死机了 pycharm 进程 (base) rootk8s-master-pfsrv:/home/zhangbin/下载# ps -ef | grep pycharm root 121245 3230568 0 5月14 pts/8 00:00:00 /bin/bash --rcfile …...
Java 中Supplier延迟生成值的原因
在编程中,延迟生成值(Lazy Value Generation) 是指将值的计算或生成过程推迟到真正需要使用该值时才执行。这一机制的核心是避免不必要的计算,提升程序的性能和资源利用率。结合 Supplier 和 Optional 的使用场景,我们…...
设置windows10同时多用户登录方法
RDP wrapper 的版本更新停止在2017年, 找到网上其它大神更新的软件, 参考:RDPWrap v1.8.9.9 (Windows家庭版开启远程桌面、Server解除远程数量限制) - 吾爱破解 - 52pojie.cn 我的需求是在离线环境中布置,方法是&…...

Web 技术与 Nginx 网站环境部署
这里写目录标题 一. Web基础域名和DNS域名的概念域名的结构域名结构类型 Hosts文件Hosts文件的作用修改Hosts文件 DNS域名注册 网页与HTML网页概述HTML概述HTML基本标签HTML语法规则HTML文件结构 网站和主页Web1.0 与 Web2.0 静态网页与动态网页静态网页动态网页动态网页语言 H…...
分组背包问题:如何最大化背包价值?
有 N 组物品和一个容量是 V 的背包。 每组物品有若干个,同一组内的物品最多只能选一个。 每件物品的体积是 vij ,价值是 wij ,其中 i 是组号,j 是组内编号。 求解将哪些物品装入背包,可使物品总体积不超过背包容量&…...
nodejs快速入门到精通1
参考 nodejs快速入门到精通 菜鸟教程-nodejs nodejs官方文档 原因 视频免费 资料收费 笔记还是自己写吧 安装 nodejs官网 windows下: #查看nodejs版本 node -v #查看npm版本 npm -v #设置npm为淘宝镜像源 npm config set registry https://registry.npmmirror.…...

FP8精度革命:Hopper架构下大模型训练的误差传播控制方法
点击 “AladdinEdu,同学们用得起的【H卡】算力平台”,H卡级别算力,按量计费,灵活弹性,顶级配置,学生专属优惠。 一、FP8为何成为大模型训练的新范式? 1.1 算力需求与精度演进的矛盾 当前大语言…...

手动制做一个Transformer
本文来自I made a transformer by hand . 一直以来,笔者对 transformer 的注意力机制、qkv的理解都浮于表面,当然也不是说我看完 I made a transformer by hand 后理解有多深入,但确实加深了我对相关概念的理解,故搬运此文章&…...

已解决——如何让网站实现HTTPS访问?
一、申请SSL证书 SSL证书是HTTPS实现的关键,它由受信任的证书颁发机构(CA)签发,用于验证网站的身份并加密数据传输。以下是申请SSL证书的常见步骤: 选择证书类型 根据网站的需求和预算,选择合适的SSL证书…...

WebRTC技术EasyRTC嵌入式音视频通信SDK助力智能电视搭建沉浸式实时音视频交互
一、方案概述 EasyRTC是一款基于WebRTC技术的开源实时音视频通信解决方案,具备低延迟、高画质、跨平台等优势。将EasyRTC功能应用于智能电视,能够为用户带来全新的交互体验,满足智能电视在家庭娱乐、远程教育、远程办公、远程医疗等多种场…...
Unreal Engine: Windows 下打包 AirSim项目 为 Linux 平台项目
环境: Windows: win10, UE4.27, Visual Studio 2022 Community.Linux: 22.04 windows环境安装教程: 链接遇到的问题(问题:解决方案) 点击Linux打包按钮,跳转至网页而不是执行打包流程:用VS打开项…...
Spring MVC HttpMessageConverter 的作用是什么?
HttpMessageConverter (HTTP 消息转换器) 是 Spring MVC 框架中一个非常核心的组件,它的主要作用是在 HTTP 请求、响应体与 Java 对象之间进行双向转换。 核心作用: 读取请求体 (Request Body) 到 Java 对象: 当 Controller 方法的参数使用 …...

小乌龟git中的推送账户、作者账户信息修改
文章目录 修改git文档作者信息修改git推送用户信息参考文献 修改git文档作者信息 小乌龟中的用户信息为:作者信息,并非推送用户。 上边用户信息,修改的是文件的作者信息。如果想要修改git服务中记录的推送用户信息需要修改推送用户信息。 …...

Kubernetes MCP服务器(K8s MCP):如何使用?
#作者:曹付江 文章目录 1、什么是 Kubernetes MCP 服务器?1.1、K8s MCP 服务器 2、开始前的准备工作2.1. Kubernetes集群2.2. 安装并运行 kubectl2.3. Node.js 和 Bun2.4. (可选)Helm v3 3、如何设置 K8s MCP 服务器3.1. 克隆存储…...
Node.js聊天室开发:从零到上线的完整指南
为让你全面了解Node.js聊天室开发,我会先介绍开发背景与技术栈,再按搭建项目、实现核心功能、部署上线的流程展开,还会分享优化思路。 Node.js聊天室开发实战:从入门到上线 在即时通讯日益普及的今天,基于Node.js搭建…...

R²AIN SUITE 亮相第九届智能工厂高峰论坛
2025年5月16日,在圆满落幕的第九届智能工厂高峰论坛上,上海比孚信息科技有限公司携自主研发的 RAIN SUITE 企业AI应用中台解决方案亮相展会。本次论坛以"从互联工厂到智慧工厂"为主题,吸引了400余位行业专家、制造企业代表及产业链…...

深入理解仿函数(Functors):从概念到实践
文章目录 1. 什么是仿函数?2. 仿函数与普通函数的区别3. 标准库中的仿函数4. 仿函数的优势4.1 状态保持4.2 可定制性4.3 性能优势 5. 现代C中的仿函数5.1 Lambda表达式5.2 通用仿函数 6. 仿函数的高级应用(使用C2020标准库及以上版本)6.1 函数…...

InternLM 论文分类微调实践(XTuner 版)
1.环境安装 我创建开发机选择镜像为Cuda12.2-conda,选择GPU为100%A100的资源配置 Conda 管理环境 conda create -n xtuner_101 python3.10 -y conda activate xtuner_101 pip install torch2.4.0cu121 torchvision torchaudio --extra-index-url https://downloa…...