南昌做网站开发的公司理发培训专业学校

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

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