rocketmq 2m-2s-sync部署
1、下载
jdk-8u361-linux-x64.tar.gz
rocketmq-all-5.1.0-bin-release.zip
#/etc/profile 环境变量:
export JAVA_HOME=/usr/local/jdk1.8.0_361 export CLASSPATH=.:$JAVA_HOME/lib/tools.jar:$JAVA_HOME/lib/dt.jar export PATH=$JAVA_HOME/bin:$PATH
2、规划
名称 | IP |
---|---|
nameserver | 11.0.1.141:9876,11.0.1.142:9876,11.0.1.143:9876 |
master | 11.0.1.142,11.0.1.143 |
slave | 11.0.1.142,11.0.1.143 |
3、nameserver配置文件修改
#JAVA_OPT参数修改
/usr/local/rocketmq/bin/runserver.sh
/usr/local/rocketmq/bin/runbroker.sh
#启动nameserver
nohup /usr/local/rocketmq/bin/mqnamesrv >/usr/local/rocketmq/logs/rocketmq-namesrv.log 2>&1 &
nohup sh mqnamesrv &
4、broker-m配置
mkdir /data/rocketmq-m/commitlog -p
#/usr/local/rocketmq/conf/broker-a.properties
#所属集群名字 brokerClusterName=rocketmq_cluster #通过配置文件指定机器的集群和broker归属,比如brokerName一样的属于同一个broker,一个broker只能有一个master,可以有多个slave,brokerId为0的为master,其他的为slave。 brokerName=broker-a #0表示Master,>0表示Slave brokerId=0 #删除文件时间点,默认凌晨 4点 deleteWhen=04 #文件保留时间,默认 48 小时 fileReservedTime=48 #Broker 的角色 brokerRole=SYNC_MASTER #异步刷新ASYNC_FLUSH /同步刷新SYNC_FLUSH flushDiskType=ASYNC_FLUSH
#nameServer地址,分号分割 namesrvAddr=11.0.1.141:9876;11.0.1.142:9876;11.0.1.143:9876 #在发送消息时,自动创建服务器不存在的topic,默认创建的队列数 defaultTopicQueueNums=4 #是否允许 Broker 自动创建Topic,建议线下开启,线上关闭 autoCreateTopicEnable=true #是否允许 Broker 自动创建订阅组,建议线下开启,线上关闭 autoCreateSubscriptionGroup=true #Broker 对外服务的监听端口 listenPort=6888 #ConsumeQueue每个文件默认存30W条,根据业务情况调整 #检测物理文件磁盘空间 diskMaxUsedSpaceRatio=88 #存储路径 storePathRootDir=/data/rocketmq-m #commitLog 存储路径 storePathCommitLog=/data/rocketmq-m/commitlog
nohup /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/broker-a.properties >/usr/local/rocketmq/logs/rocketmq-broker-m.log 2>&1 &
5、broker-s配置
mkdir /data/rocketmq-s/commitlog -p
#Broker 的角色 brokerRole=SLAVE
brokerId=1
nohup /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/broker-as.properties >/usr/local/rocketmq/logs/rocketmq-broker-s.log 2>&1 &
6、mqadmin
/usr/local/rocketmq/bin/mqadmin clusterList -n 11.0.1.141:9876
标签:bin,配置,11.0,broker,集群,usr,local,rocketmq From: https://www.cnblogs.com/52shaidan/p/17156606.html