docker安装rocketMq5x以上的版本
1.背景
安装RocketMQ 5.x以上的版本主要是因为新版本引入了许多性能优化、新功能以及对已有特性的增强,这些改进可以帮助提升消息队列系统的稳定性和效率。
1.性能提升:RocketMQ 5.x版本通常包括了对消息处理速度、吞吐量和延迟的优化,使得系统能更好地应对大规模、高并发场景。
2.新特性:
- Pop与Ack机制改进:RocketMQ 5.x对Pop(拉取消息)和Ack(确认消息)机制进行了优化,增强了消息处理的可靠性和灵活性。
- 消息追踪与诊断:提供了更强大的消息轨迹功能,便于追踪消息流转全链路,有助于问题排查和性能分析。
- HTTP协议支持:5.x版本可能进一步完善了HTTP协议的支持,使得集成更加便捷,特别是在云原生和微服务架构中。
- 定时/延时消息改进:新版本可能简化了定时消息和延时消息的管理,比如提供更灵活的创建方式,不再局限于手动使用mqadmin工具。
3.安全性与稳定性:每个大版本的迭代都会修复已知的安全漏洞,并增加新的安全特性,确保数据传输的安全性和系统的稳定性。
4.云原生支持:随着Kubernetes等容器编排技术的普及,RocketMQ 5.x版本可能增强了对云原生环境的支持,包括更好的Docker和K8s集成,便于在云环境中部署和管理。
5.易用性与兼容性:新版本通常会改进用户界面和管理工具,使得操作更为直观。同时,也会提高与其他技术和框架的兼容性,减少集成难度。
6.社区与生态:随着版本的更新,社区支持和第三方插件、工具也会随之跟进,使用最新版本能更好地利用这些资源。
2.拉取镜像
2.1 拉取RocketMQ镜像
docker pull apache/rocketmq:latest
2.2 拉取RocketMQ Dashboard镜像
docker pull apacherocketmq/rocketmq-dashboard:latest
3.创建网络(如果需要多个容器互联)
docker network create rocketmq-net
4.创建相关映射目录
mkdir -p /Users/hb24795/soft/docker/rocketMq5.0/mnt/rocketmq/namesrv/logs /Users/hb24795/soft/docker/rocketMq5.0/mnt/rocketmq/namesrv/store mkdir -p /Users/hb24795/soft/docker/rocketMq5.0/mnt/rocketmq/broker/logs /Users/hb24795/soft/docker/rocketMq5.0/mnt/rocketmq/broker/store mkdir -p /Users/hb24795/soft/docker/rocketMq5.0/mnt/rocketmq/broker/logs /Users/hb24795/soft/docker/rocketMq5.0/mnt/rocketmq/broker/store
注意你需要将/Users/hb24795/soft/这个地址修改为你自己系统的地址
5.添加boker的配置文件
地址:/Users/hb24795/soft/docker/rocketMq5.0/conf
注意:你需要将/Users/hb24795/soft/docker这个地址修改为你自己系统的地址
添加配置文件:broker.conf
# Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE file distributed with # this work for additional information regarding copyright ownership. # The ASF licenses this file to You under the Apache License, Version 2.0 # (the "License"); you may not use this file except in compliance with # the License. You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. # 所属集群名字 brokerClusterName=DefaultCluster # broker 名字,注意此处不同的配置文件填写的不一样,如果在 broker-a.properties 使用: broker-a, # 在 broker-b.properties 使用: broker-b brokerName=broker-a # 0 表示 Master,> 0 表示 Slave brokerId=0 # 启动IP,如果 docker 报 com.alibaba.rocketmq.remoting.exception.RemotingConnectException: connect to <192.168.0.120:10909> failed # 解决方式1 加上一句 producer.setVipChannelEnabled(false);,解决方式2 brokerIP1 设置宿主机IP,不要使用docker 内部IP brokerIP1=192.168.31.169 # nameServer地址,分号分割 namesrvAddr=192.168.31.169:9876 # 在发送消息时,自动创建服务器不存在的topic,默认创建的队列数 defaultTopicQueueNums=4 # 是否允许 Broker 自动创建 Topic,建议线下开启,线上关闭 !!!这里仔细看是 false,false,false autoCreateTopicEnable=true # 是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭 autoCreateSubscriptionGroup=true # Broker 对外服务的监听端口 listenPort=10911 # 删除文件时间点,默认凌晨4点 deleteWhen=04 # 文件保留时间,默认48小时 fileReservedTime=120 # commitLog 每个文件的大小默认1G mapedFileSizeCommitLog=1073741824 # ConsumeQueue 每个文件默认存 30W 条,根据业务情况调整 mapedFileSizeConsumeQueue=300000 # destroyMapedFileIntervalForcibly=120000 # redeleteHangedFileInterval=120000 # 检测物理文件磁盘空间 diskMaxUsedSpaceRatio=88 # 存储路径 # storePathRootDir=/home/ztztdata/rocketmq-all-4.1.0-incubating/store # commitLog 存储路径 # storePathCommitLog=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/commitlog # 消费队列存储 # storePathConsumeQueue=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/consumequeue # 消息索引存储路径 # storePathIndex=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/index # checkpoint 文件存储路径 # storeCheckpoint=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/checkpoint # abort 文件存储路径 # abortFile=/home/ztztdata/rocketmq-all-4.1.0-incubating/store/abort # 限制的消息大小 maxMessageSize=65536 # flushCommitLogLeastPages=4 # flushConsumeQueueLeastPages=2 # flushCommitLogThoroughInterval=10000 # flushConsumeQueueThoroughInterval=60000 # Broker 的角色 # - ASYNC_MASTER 异步复制Master # - SYNC_MASTER 同步双写Master # - SLAVE brokerRole=ASYNC_MASTER # 刷盘方式 # - ASYNC_FLUSH 异步刷盘 # - SYNC_FLUSH 同步刷盘 flushDiskType=ASYNC_FLUSH # 发消息线程池数量 # sendMessageThreadPoolNums=128 # 拉消息线程池数量 # pullMessageThreadPoolNums=128
注意:你要将
- brokerIP1=192.168.31.169
- namesrvAddr=192.168.31.169:9876
这两个ip地址修改为你本机或公网的ip地址
6.启动服务
1.mq
docker run -d --name rmqnamesrv \
-p 9876:9876 \
--network rocketmq-net \
-v /Users/hb24795/soft/docker/rocketMq5.0/mnt/rocketmq/namesrv/logs:/root/logs \
-v /Users/hb24795/soft/docker/rocketMq5.0/mnt/rocketmq/namesrv/store:/root/store \
apache/rocketmq:latest sh mqnamesrv
2.broker
docker run -d --name rmqnamesrv \
-p 9876:9876 \
--network rocketmq-net \
-v /Users/hb24795/soft/docker/rocketMq5.0/mnt/rocketmq/namesrv/logs:/root/logs \
-v /Users/hb24795/soft/docker/rocketMq5.0/mnt/rocketmq/namesrv/store:/root/store \
apache/rocketmq:latest sh mqnamesrv
3.dashboard
docker run -d --name rmqdashboard \
--network rocketmq-net \
-p 8080:8080 \
-e "JAVA_OPTS=-Drocketmq.namesrv.addr=192.168.31.169:9876" \
apacherocketmq/rocketmq-dashboard:latest
启动完成之后,可以先docker ps确保自己的服务都全部成功,在访问:ip:8080

出现改页面说明你配置成功
到此这篇关于docker安装rocketMq5x以上的版本的文章就介绍到这了,更多相关docker安装rocketMq内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
相关文章
k3s容器中使用docker、ctr、crictl命令的方法
本文介绍k3s中ctr和crictl命令的区别,重点解析命名空间管理、国内镜像源加速及镜像导出操作,对比其功能差异并提供使用技巧,对docker ctr crictl命令相关知识感兴趣的朋友一起看看吧2025-07-07
Docker安装部署rocketmq-console工具教程
这篇文章主要介绍了Docker安装部署rocketmq-console工具教程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-04-04
Docker下MySQL配置文件不生效的解决方法(超全面!)
在Docker中运行MySQL并遇到需要调整配置的情况时,比如想要关闭ONLY_FULL_GROUP_BY的严格模式,我们可以通过以下步骤来实现sql_mode的修改:以下是解决此类问题的步骤和思路,需要的朋友可以参考下2024-09-09
docker自定义网桥docker0及docker的开启,关闭,重启命令操作
这篇文章主要介绍了docker自定义网桥docker0及docker的开启,关闭,重启命令操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧2021-03-03


最新评论