凡客网站的域名怎么做,看广告挣钱一天300元,网站服务器租用开票应该,wordpress 图片外链1.背景
安装RocketMQ 5.x以上的版本主要是因为新版本引入了许多性能优化、新功能以及对已有特性的增强#xff0c;这些改进可以帮助提升消息队列系统的稳定性和效率。 1.性能提升#xff1a;RocketMQ 5.x版本通常包括了对消息处理速度、吞吐量和延迟的优化#xff0c;使得系…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:latest2.2 拉取RocketMQ Dashboard镜像
docker pull apacherocketmq/rocketmq-dashboard:latest3.创建网络如果需要多个容器互联
docker network create rocketmq-net4.创建相关映射目录
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.# 所属集群名字
brokerClusterNameDefaultCluster# broker 名字注意此处不同的配置文件填写的不一样如果在 broker-a.properties 使用: broker-a,
# 在 broker-b.properties 使用: broker-b
brokerNamebroker-a# 0 表示 Master 0 表示 Slave
brokerId0# 启动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
brokerIP1192.168.31.169
# nameServer地址分号分割
namesrvAddr192.168.31.169:9876# 在发送消息时自动创建服务器不存在的topic默认创建的队列数
defaultTopicQueueNums4# 是否允许 Broker 自动创建 Topic建议线下开启线上关闭 这里仔细看是 falsefalsefalse
autoCreateTopicEnabletrue# 是否允许 Broker 自动创建订阅组建议线下开启线上关闭
autoCreateSubscriptionGrouptrue# Broker 对外服务的监听端口
listenPort10911# 删除文件时间点默认凌晨4点
deleteWhen04# 文件保留时间默认48小时
fileReservedTime120# commitLog 每个文件的大小默认1G
mapedFileSizeCommitLog1073741824# ConsumeQueue 每个文件默认存 30W 条根据业务情况调整
mapedFileSizeConsumeQueue300000# destroyMapedFileIntervalForcibly120000
# redeleteHangedFileInterval120000
# 检测物理文件磁盘空间
diskMaxUsedSpaceRatio88
# 存储路径
# 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
# 限制的消息大小
maxMessageSize65536# flushCommitLogLeastPages4
# flushConsumeQueueLeastPages2
# flushCommitLogThoroughInterval10000
# flushConsumeQueueThoroughInterval60000# Broker 的角色
# - ASYNC_MASTER 异步复制Master
# - SYNC_MASTER 同步双写Master
# - SLAVE
brokerRoleASYNC_MASTER# 刷盘方式
# - ASYNC_FLUSH 异步刷盘
# - SYNC_FLUSH 同步刷盘
flushDiskTypeASYNC_FLUSH# 发消息线程池数量
# sendMessageThreadPoolNums128
# 拉消息线程池数量
# pullMessageThreadPoolNums128注意你要将
brokerIP1192.168.31.169namesrvAddr192.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 mqnamesrv2.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 mqnamesrv3.dashboard docker run -d --name rmqdashboard \--network rocketmq-net \-p 8080:8080 \-e JAVA_OPTS-Drocketmq.namesrv.addr192.168.31.169:9876 \apacherocketmq/rocketmq-dashboard:latest启动完成之后可以先docker ps确保自己的服务都全部成功在访问ip:8080
出现改页面说明你配置成功
