docker-compose方式部署单机版RocketMQ

1、准备工作目录和配置文件

rocketmq\_ conf/broker.conf\_ docker-compose.yml

rocketmq/conf/ 目录下面,创建broker.conf文件:

# Broker所属的集群名称,默认是DefaultCluster
brokerClusterName=DefaultCluster# Broker的名称
brokerName=broker-a# Broker的ID,默认为0表示主节点,大于0表示从节点
brokerId=0  # 是否允许Broker 自动创建Topic,建议线下开启,线上关闭
autoCreateTopicEnable=true# 是否允许Broker自动创建订阅组,建议线下开启,线上关闭
autoCreateSubscriptionGroup=true# 删除文件时间点,默认凌晨4点
deleteWhen=04# 文件保留时间,默认48小时
fileReservedTime=48# Broker的角色,ASYNC_MASTER(异步主节点),SYNC_MASTER(同步主节点),SLAVE(从节点)
brokerRole=ASYNC_MASTER# 刷盘类型:同步刷新(SYNC_FLUSH)、ASYNC_FLUSH 异步刷盘
flushDiskType=ASYNC_FLUSH# Broker服务地址,局域网使用填宿主机ip,如果需要给外部使用填公网ip
brokerIP1 = 192.168.0.117  

在外层rocketmq/目录下面,创建docker-compose.yml文件:(服务编排:nameserver、broker、console)

version: '3.5'  # Docker Compose 文件版本,确保兼容性services:# Name Server 服务配置rocketmq_server:image: foxiswho/rocketmq:server  # 镜像container_name: rocketmq_server  # 容器名称ports:- 9876:9876  # 端口映射volumes:- ~/docker_install/rocketmq/rocketmq_server/logs:/opt/logs  # 挂载日志目录到容器内- ~/docker_install/rocketmq/rocketmq_server/store:/opt/store  # 挂载数据存储目录到容器内networks:rocketmq:aliases:- rocketmq_server  # 在自定义网络中为容器设置别名,方便其他容器通过该别名访问# Broker 服务配置rocketmq_broker:image: foxiswho/rocketmq:broker  # 镜像container_name: rocketmq_broker  # 定义容器名称ports:- 10909:10909  # 映射Broker HTTP监听端口到主机,通常用于管理接口- 10911:10911  # 映射Broker监听端口到主机,用于客户端连接volumes:- ~/docker_install/rocketmq/rocketmq_broker/logs:/opt/logs  # 挂载日志目录到容器内- ~/docker_install/rocketmq/rocketmq_broker/store:/opt/store  # 挂载数据存储目录到容器内- ~/docker_install/rocketmq/conf/broker.conf:/etc/rocketmq/broker.conf  # 挂载自定义的Broker配置文件到容器内environment:NAMESRV_ADDR: "rocketmq_server:9876"  # 设置环境变量,指定NameServer地址JAVA_OPTS: " -Duser.home=/opt"  # Java运行参数,设置用户主目录JAVA_OPT_EXT: "-server -Xms128m -Xmx128m -Xmn128m"  # 扩展Java运行参数,设置JVM内存选项command: mqbroker -c /etc/rocketmq/broker.conf  # 启动命令,使用挂载的配置文件启动Brokerdepends_on:- rocketmq_server  # 依赖rocketmq_server服务,先启动NameServer再启动Brokernetworks:rocketmq:aliases:- rocketmq_broker  # 在自定义网络中为容器设置别名,方便其他容器通过该别名访问# RocketMQ可视化控制台配置rocketmq_console_ng:image: styletang/rocketmq-console-ng  # 镜像container_name: rocketmq_console_ng  # 定义容器名称ports:- 9002:8080  # 端口映射environment:JAVA_OPTS: "-Drocketmq.namesrv.addr=rocketmq_server:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false"  # 设置控制台使用的NameServer地址和其他必要的JVM参数depends_on:- rocketmq_server  # 依赖rocketmq_server服务networks:rocketmq:aliases:- rocketmq_console_ng  # 在自定义网络中为容器设置别名,方便其他容器通过该别名访问networks:rocketmq:  # 自定义网络配置,所有相关服务都连接到这个网络上name: rocketmq  # 网络名称driver: bridge  # 使用桥接网络驱动,这是默认的网络类型,允许容器之间相互通信

2、使用docker-compose命令启动容器

# 后台启动
docker compose up -d# 查看容器是否启动成功
docker compose ps

在这里插入图片描述


3、访问web控制台

访问地址: http://ip:9002

在这里插入图片描述

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

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

相关文章

有收到腾讯委托律师事务所向AppStore投诉带有【水印相机】主标题名称App的开发者吗

近期,有多名开发者反馈,收到来自腾讯科技 (深圳) 有限公司委托北京的一家**诚律师事务所卞,写给AppStore的投诉邮件。 邮件内容主要说的是,腾讯注册了【水印相机】这四个字的商标,所以你们这些在AppStore上的app&…

爬虫基础之爬取歌曲宝歌曲批量下载

声明:本案列仅供学习交流使用 任何用于非法用途均与本作者无关 需求分析: 网站:邓紫棋-mp3在线免费下载-歌曲宝-找歌就用歌曲宝-MP3音乐高品质在线免费下载 (gequbao.com) 爬取 歌曲名 歌曲 实现歌手名称下载所有歌曲 本案列所使用的模块 requests (发送…

Java 如何传参xml调用接口获取数据

传参和返参的效果图如下: 传参: 返参: 代码实现: 1、最外层类 /*** 外层DATA类*/ XmlRootElement(name "DATA") public class PointsXmlData {private int rltFlag;private int failType;private String failMemo;p…

java项目之在线文档管理系统源码(springboot+mysql+vue+文档)

大家好我是风歌,曾担任某大厂java架构师,如今专注java毕设领域。今天要和大家聊的是一款基于springboot的在线文档管理系统。项目源码以及部署相关请联系风歌,文末附上联系信息 。 项目简介: 在线文档管理系统的主要使用者分为管…

学技术步骤,(tomcat举例)jar包api手写tomcat静态资源基础服务器

1.看有哪些包,能用本地离线的包就使用离线包 2.尽量不要使用配置文件(先不用),能用api就用api, 因为配置文件只是文本,其实要的只是配置文件里的参数, 这些参数最后肯定还是要给到这些api去处…

React中createRoot函数原理解读——Element对象与Fiber对象、FiberRootNode与HostRootNode

【2024最新版】React18 核心源码分析教程(全61集) Element对象与Fiber对象 在 React 中,Element 对象 和 Fiber 对象 是核心概念,用于实现 React 的高效渲染和更新机制。以下是它们的详细解读: 1. Element 对象 定…

如何用SQL语句来查询表或索引的行存/列存存储方式|OceanBase 用户问题集锦

一、问题背景 自OceanBase 4.3.0版本起,支持了列存引擎,允许表和索引以行存、纯列存或行列冗余的形式创建,且这些存储方式可以自由组合。除了使用 show create table命令来查看表和索引的存储类型外,也有用户询问如何通过SQL语句…

超完整Docker学习记录,Docker常用命令详解

前言 关于国内拉取不到docker镜像的问题,可以利用Github Action将需要的镜像转存到阿里云私有仓库,然后再通过阿里云私有仓库去拉取就可以了。 参考项目地址:使用Github Action将国外的Docker镜像转存到阿里云私有仓库 一、Docker简介 Do…

数据结构-排序课后题

今天我们来简单的说说关于排序的一些课后练习题. 对应的知识点博客: LINK. 目录 1. 每一单趟都能确定一个数字的最终位置的排序2. 根据序列变化确定排序方式3. 排序顺序对哪些排序效率影响不大?4. 对有序序列排序最费力的排序方式是什么?5. 对接近有序序列排序最快的排序方式…

MySQL 架构

MySQL架构 MySQL8.0服务器是由连接池、服务管理⼯具和公共组件、NoSQL接⼝、SQL接⼝、解析器、优化 器、缓存、存储引擎、⽂件系统组成。MySQL还为各种编程语⾔提供了⼀套⽤于外部程序访问服务器的连接器。整体架构图如下所⽰: MySQL Connectors:为使⽤…

【数据结构】二叉搜索树

目录 1. 二叉搜索树的概念 2. 二叉搜索树的性能分析 3.二叉搜索树的实现 3. 1.二叉搜索树的插入 3.2. 二叉搜索树的查找 3.3. 二叉搜索树的删除 3.4. 二叉搜索树的实现代码 4. 二叉搜索树key和key/value两种使用场景 4.1 key搜索场景: 4.2 key/value搜索场…

【C++】string的关系运算与比较分析

博客主页: [小ᶻ☡꙳ᵃⁱᵍᶜ꙳] 本文专栏: C 文章目录 💯前言💯基础知识:C 中的 string 关系运算器1. 关系运算器概述2. 字符串比较的本质 💯代码解析与扩展代码例一:相等比较代码解析输出 代码例二&a…

高性能网络模式:Reactor 和 Proactor

Reactor Reactor 采用I/O多路复用监听事件,收到事件后,根据事件类型分配给某个进程/线程。 实际应用中用到的模型: 单 Reactor 单进程 单 Reactor 多线程 优点:能充分利用多核CPU性能。 缺点:存在多线程竞争共享资源…

有限元分析学习——Anasys Workbanch第一阶段笔记(10)桌子载荷案例分析_实际载荷与均布载荷的对比

目录 0 序言 1 桌子案例 2 模型简化 3 方案A 前处理 1)分析类型选择 2)材料加载 3)约束、载荷及接触 4)控制网格(网格大小需要根据结果不断调整) 初始计算结果 加密后计算结果 4 方案B、C 前处理 1)分析…

用HTML + CSS实现太极图

目录 一、效果图 二、实现思路 三、完整代码 四、总结 一、效果图 如图所示,太极图一半为黑色(代表阴),另一半为白色(代表阳)。这两部分相互环绕,形成一种流动的、旋转的感觉。 二、实现思…

【Rust自学】11.7. 按测试的名称运行测试

喜欢的话别忘了点赞、收藏加关注哦,对接下来的教程有兴趣的可以关注专栏。谢谢喵!(・ω・) 11.7.1. 按名称运行测试的子集 如果想要选择运行的测试,就将测试的名称(一个或多个)作为cargo test的…

标准应用 | 2025年网络安全服务成本度量实施参考

01 网络安全服务成本度量依据相关新变化 为了解决我国网络安全服务产业发展中面临的服务供需两方对于服务成本组成认知偏差较大、网络安全服务成本度量缺乏依据的问题,中国网络安全产业联盟(CCIA)组织北京赛西科技发展有限责任公司、北京安…

HAMi + prometheus-k8s + grafana实现vgpu虚拟化监控

最近长沙跑了半个多月,跟甲方客户对了下项目指标,许久没更新 回来后继续研究如何实现 grafana实现HAMi vgpu虚拟化监控,毕竟合同里写了需要体现gpu资源限制和算力共享以及体现算力卡资源共享监控 先说下为啥要用HAMi吧, 一个重要原…

某地武警海警总队建筑物自动化监测

1. 项目概述 该项目分布于三个不同的地级市,都是位于临海港口的码头,由中国武警海警总队驻扎,守卫人民安全。 1号建筑物自动化监测系统项目由一道伸缩缝划分为两个监测单元,建筑物为三层混合结构,采用350mm厚石墙、2…

负载均衡原理及算法

什么是负载均衡? 负载均衡 指的是将用户请求分摊到不同的服务器上处理,以提高系统整体的并发处理能力以及可靠性。负载均衡服务可以有由专门的软件或者硬件来完成,一般情况下,硬件的性能更好,软件的价格更便宜&#x…