docker安装rocketMq5x以上的版本

发布于:2024-07-01 ⋅ 阅读:(12) ⋅ 点赞:(0)

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
在这里插入图片描述

出现改页面说明你配置成功