RocketMq集群部署
本帖最后由 Ceanie 于 2021-7-1 00:01 编辑本人在安装RocketMq集群，并整合进入springboot 的时候 ，一直度娘搜索了不知多少条安装教程，他们的教程总是零零散散的,太乱了，这里整合成一片文章，方便大家查看！
部署集群多Master模式（无Slave节点）安装教程(同比，可以多master,多slave)提示，注意端口防火墙(放开9876端口)
部署步骤：[多台服务器步骤相同]环境准备jdk1.8
maven
docker一、（安装rocketmq）
[*]下载： rocketmq-all-4.7.0-source-release.zip
[*]创建文件夹: mkdir -p /usr/local/rocketmq/
[*]解压： unzip rocketmq-all-4.7.0-source-release.zip
[*]移动文件 mv rocketmq-all-4.7.0-source-release/usr/local/rocketmq/
[*]安装（这里需要安装maven）： mvn -Prelease-all -DskipTests clean install -U
[*]
二、修改环境变量（在”/etc/profile”末尾添加）：
[*]vim /etc/profile
[*]export ROCKETMQ_HOME=/usr/local/rocketmq/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0
[*]export PATH=$ROCKETMQ_HOME/bin:$PATH
[*]:wq!
[*]
[*] source /etc/profile
[*]
三、修改 conf/2m-noslave 文件中配置文件内容如下{ip填写内网的}：
#文件组brokerClusterName=DefaultCluster
# 集群名，主从rocketmq的名称是一致的brokerName={broker-a,broker-b}
# 0表示master, 非0表示slavebrokerId=0
#集群的地址namesrvAddr={ip1}:9876;{ip2}:9876
#强制指定本机IP，需要根据每台机器进行修改。官方介绍可为空，系统默认自动识别，但多网卡时IP地址可能读取错误brokerIP1={本机IP不需要端口}
#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口listenPort=10911
#删除文件时间点，默认凌晨 4点deleteWhen=04
#文件保留时间，默认 48 小时fileReservedTime=18
#commitLog每个文件的大小默认1GmapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间diskMaxUsedSpaceRatio=88
#存储路径storePathRootDir=/usr/local/rocketmq/store
#commitLog 存储路径storePathCommitLog=/usr/local/rocketmq/store/commitlog
#消费队列存储路径存储路径storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue
#消息索引存储路径storePathIndex=/usr/local/rocketmq/store/index
#checkpoint 文件存储路径storeCheckpoint=/usr/local/rocketmq/store/checkpoint
#abort 文件存储路径abortFile=/usr/local/rocketmq/store/abort
#限制的消息大小maxMessageSize=65536
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVEbrokerRole=SYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘flushDiskType=ASYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量sendMessageThreadPoolNums=128
#拉消息线程池数量pullMessageThreadPoolNums=128
#打开锁
#useReentrantLockWhenPutMessage=truewaitTimeMillsInSendQueue=3000
#从节点是否可读
# slaveReadEnable=true
四、修改默认的启动文件1、修改runserver.sh
[*]vim /usr/local/rocketmq/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0/bin/runserver.sh
[*]修改内存大小
[*] JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
[*]这里是重点，需要删除这两句，不然无法启动
[*]export CLASSPATH=.:${BASE_DIR}/conf:${CLASSPATH}
[*]JAVA_OPT="${JAVA_OPT} -cp ${CLASSPATH}"
[*]:wq!
2、修改runbroker.sh
[*]vim /usr/local/rocketmq/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0/bin/runbroker.sh
[*]修改内存大小
[*] JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"
[*]:wq!
3、修改tool.sh
[*]vim /usr/local/rocketmq/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0/bin/tool.sh
[*]修改内存大小
[*] JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:PermSize=128m -XX:MaxPermSize=128m"
[*]
五、启动命令服务器a启动命令
[*]启动mqnamesrv
[*] nohup sh /usr/local/rocketmq/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0/bin/mqnamesrv &
[*]启动broker
[*] nohup sh /usr/local/rocketmq/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0/bin/mqbroker -c /usr/local/rocketmq/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0/conf/2m-noslave/broker-a.properties &
服务器b启动命令
[*]启动mqnamesrv
[*] nohup sh /usr/local/rocketmq/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0/bin/mqnamesrv &
[*]启动broker
[*] nohup sh /usr/local/rocketmq/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0/bin/mqbroker -c /usr/local/rocketmq/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0/conf/2m-noslave/broker-b.properties &
[*]
六、发送测试消息
[*] 发消息
[*] sh /usr/local/rocketmq/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0/bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
[*] 收消息
[*] sh /usr/local/rocketmq/rocketmq-all-4.7.0-source-release/distribution/target/rocketmq-4.7.0/rocketmq-4.7.0/bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
[*]
七、控制台查看
[*] docker run -dit --name rocketmq-console-ng -e "JAVA_OPTS=-Drocketmq.namesrv.addr=ip1:9876;ip2:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" -p 9875:8080 styletang/rocketmq-console-ng
[*]
谢谢分享，收藏一下备用
页:
[1]