我是靠谱客的博主 标致小蚂蚁,最近开发中收集的这篇文章主要介绍Linux下rocketmq异步主从搭建1. 创建目录2.修改运行内存限制3.修改配置文件启动主节点启动从节点,觉得挺不错的,现在分享给大家,希望可以做个参考。
概述
主节点 192.168.0.1 从节点 192.168.0.2
1. 创建目录
mkdir -p /data/rocketmq
cd /data/rocketmq
1.1master
cd /data/rocketmq
unzip rocketmq-all-4.8.0-bin-release
mv rocketmq-all-4.8.0-bin-release master
1.2slave
cd /data/rocketmq
unzip rocketmq-all-4.8.0-bin-release
mv rocketmq-all-4.8.0-bin-release slave
2.修改运行内存限制
编辑rocketmq文件夹下bin目录下的runserver.sh和runbroker.sh脚本
runserver.sh脚本修改内容:
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
runbroker.sh脚本修改内容:
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn128m"
JAVA_OPT="${JAVA_OPT} -XX:MaxDirectMemorySize=512m"
3.修改配置文件
3.1主节点
cd /data/rocketmq/master/conf/2m-2s-async
vim broker-a.properties
#集群名称,主从要一样
brokerClusterName=DefaultCluster
#broker名称,主从要一样,根据BrokerRole来确定谁是主谁是从
brokerName=broker-a
#brokerID 0是主,>0是从
brokerId=0
#删除日志时间为凌晨4点
deleteWhen=04
#文件保留时间48小时
fileReservedTime=48
#主从关系,异步复制
brokerRole=ASYNC_MASTER
#刷盘模式,异步刷盘
flushDiskType=ASYNC_FLUSH
是否允许Broker自动创建topic
autoCreateTopicEnable=true
是否允许Broker自动创建订阅组
autoCreateSubscriptionGroup=true
namesrvAddr地址,分号分割
namesrvAddr=192.168.0.1:9876;192.168.0.2:9876
当前 broker 监听的 IP
brokerIP1=192.168.0.1
存储 commit log 的路径
storePathCommitLog=/data/rocketmq/master/store/commitlog/
存储 consume queue 的路径
storePathConsumerQueue=/data/rocketmq/master/store/consumequeue/
消息索引存储路径
storePathIndex=/data/rocketmq/master/store/index
checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/master/store/checkpoint
abort 文件存储路径
abortFile=/data/rocketmq/master/store/abort
存储根路径
storePathRootDir=/data/rocketmq/master/store
commit log 的映射文件大小,默认1G
mappedFileSizeCommitLog=1024 * 1024 * 1024
3.2从节点
cd /data/rocketmq/slave/conf/2m-2s-async/
vim broker-a-s.properties
#集群名称,主从要一样
brokerClusterName=DefaultCluster
#broker名称,主从要一样,根据BrokerRole来确定谁是主谁是从
brokerName=broker-a
#brokerID 0是主,>0是从
brokerId=1
#删除日志时间为凌晨4点
deleteWhen=04
#文件保留时间48小时
fileReservedTime=48
#角色是从节点
brokerRole=SLAVE
#刷盘模式,异步刷盘
flushDiskType=ASYNC_FLUSH
是否允许Broker自动创建topic
autoCreateTopicEnable=true
是否允许Broker自动创建订阅组
autoCreateSubscriptionGroup=true
namesrvAddr地址,分号分割
namesrvAddr=192.168.0.1:9876;192.168.0.2:9876
当前 broker 监听的 IP
brokerIP1=192.168.0.2
存储 commit log 的路径
storePathCommitLog=/data/rocketmq/slave/store/commitlog/
存储 consume queue 的路径
storePathConsumerQueue=/data/rocketmq/slave/store/consumequeue/
消息索引存储路径
storePathIndex=/data/rocketmq/slave/store/index
checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq/slave/store/checkpoint
abort 文件存储路径
abortFile=/data/rocketmq/slave/store/abort
存储根路径
storePathRootDir=/data/rocketmq/slave/store
commit log 的映射文件大小,默认1G
mappedFileSizeCommitLog=1024 * 1024 * 1024
启动主节点
cd /data/rocketmq/master/bin/
#启动NameServer
nohup sh ./mqnamesrv
>/dev/null 2>&1 &
#启动主Broker
nohup sh
./mqbroker
-c
../conf/2m-2s-async/broker-a.properties
>/dev/null
2>&1
&
启动从节点
cd /data/rocketmq/slave/bin/
#启动NameServer
nohup sh ./mqnamesrv
>/dev/null 2>&1 &
#启动主Broker
nohup sh
./mqbroker
-c
../conf/2m-2s-async/broker-a-s.properties
>/dev/null
2>&1
&
最后
以上就是标致小蚂蚁为你收集整理的Linux下rocketmq异步主从搭建1. 创建目录2.修改运行内存限制3.修改配置文件启动主节点启动从节点的全部内容,希望文章能够帮你解决Linux下rocketmq异步主从搭建1. 创建目录2.修改运行内存限制3.修改配置文件启动主节点启动从节点所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复