侧边栏壁纸
博主头像
DJ's Blog博主等级

行动起来，活在当下

  • 累计撰写 133 篇文章
  • 累计创建 51 个标签
  • 累计收到 0 条评论

目 录CONTENT

文章目录
消息中间件

【RocketMQ】集群安装和配置

Administrator
Administrator
2022-03-08 / 0 评论 / 0 点赞 / 83 阅读 / 10145 字

【RocketMQ】集群安装和配置

集群规划

机器IP NameServer Broker
172.16.238.43 NameServer1（9876） BrokerA-master（10910）BrokerB-slave（10921）
172.16.238.42 NameServer2（9876） BrokerB-master（10920）BrokerA-slave（10911）

RocketMQ集群节点规划

下载二进制包

cd /usr/local

unzip rocketmq-all-4.8.0-bin-release.zip

mv rocketmq-all-4.8.0-bin-release rocketmq

安装和配置

172.16.238.43

  • 创建数据存储目录
mkdir -p /usr/local/rocketmq/store/broker-a /usr/local/rocketmq/store/broker-a/consumequeue /usr/local/rocketmq/store/broker-a/commitlog /usr/local/rocketmq/store/broker-a/index /usr/local/rocketmq/logs /usr/local/rocketmq/store/broker-b-s /usr/local/rocketmq/store/broker-b-s/consumequeue /usr/local/rocketmq/store/broker-b-s/commitlog /usr/local/rocketmq/store/broker-b-s/index
  • 修改broker-a.properties配置文件
cd /usr/local/rocketmq/conf/2m-2s-async

vim  broker-a.properties

# Broker 对外服务的监听端口
listenPort=10910
# 是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=false
# 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=false
# nameServer地址，分号分割
namesrvAddr=172.16.238.43:9876;172.16.238.42:9876
# Broker 对外服务的IP地址
brokerIP1=172.16.238.43
# 存储路径
storePathRootDir=/usr/local/rocketmq/store/broker-a
# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/broker-a/commitlog
# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/broker-a/consumequeue
# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/broker-a/index
# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint
# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort
  • 修改broker-b-s.properties配置文件
cd /usr/local/rocketmq/conf/2m-2s-async

vim  broker-b-s.properties

# Broker 对外服务的监听端口
listenPort=10921
# 是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=false
# 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=false
# nameServer地址，分号分割
namesrvAddr=172.16.238.43:9876;172.16.238.42:9876
# Broker 对外服务的IP地址
brokerIP1=172.16.238.43
# 存储路径
storePathRootDir=/usr/local/rocketmq/store/broker-b-s
# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/broker-b-s/commitlog
# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/broker-b-s/consumequeue
# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/broker-b-s/index
# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint
# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort
  • 修改bin目录下的runbroker.sh文件，把8g 4g 改成2g 1g
cd /usr/local/rocketmq/bin

vim runbroker.sh

JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g"
  • 修改bin目录下的runserver.sh 文件，把8g 4g 改成2g 1g
cd /usr/local/rocketmq/bin

vim runserver.sh

JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
  • 启动nameserver
nohup sh /usr/local/rocketmq/bin/mqnamesrv >/usr/local/rocketmq/logs/mqnamesrv.log 2>&1 &
  • 启动broker-a-master
nohup sh /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/2m-2s-async/broker-a.properties > /usr/local/rocketmq/logs/broker-a.log 2>&1 &
  • 启动broker-b-slave
nohup sh /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/2m-2s-async/broker-b-s.properties > /usr/local/rocketmq/logs/broker-b-s.log 2>&1 &
  • 查看启动日志
cd /usr/local/rocketmq/logs

tail -f mqnamesrv.log

tail -f broker-a.log

tail -f broker-b-s.log

停止broker

cd /usr/local/rocketmq/bin

sh mqshutdown broker
  • 停止nameserver
cd /usr/local/rocketmq/bin

sh mqshutdown namesrv

停止服务的时候需要注意，要先停止broker，其次停止nameserver。

172.16.238.42

  • 创建数据存储目录
mkdir -p /usr/local/rocketmq/store/broker-a-s /usr/local/rocketmq/store/broker-a-s/consumequeue /usr/local/rocketmq/store/broker-a-s/commitlog /usr/local/rocketmq/store/broker-a-s/index /usr/local/rocketmq/logs /usr/local/rocketmq/store/broker-b /usr/local/rocketmq/store/broker-b/consumequeue /usr/local/rocketmq/store/broker-b/commitlog /usr/local/rocketmq/store/broker-b/index
  • 修改broker-b.properties配置文件
cd /usr/local/rocketmq/conf/2m-2s-async

vim  broker-b.properties

# Broker 对外服务的监听端口
listenPort=10920
# 是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=false
# 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=false
# nameServer地址，分号分割
namesrvAddr=172.16.238.43:9876;172.16.238.42:9876
# Broker 对外服务的IP地址
brokerIP1=172.16.238.42
# 存储路径
storePathRootDir=/usr/local/rocketmq/store/broker-b
# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/broker-b/commitlog
# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/broker-b/consumequeue
# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/broker-b/index
# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint
# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort
  • 修改broker-a-s.properties配置文件
cd /usr/local/rocketmq/conf/2m-2s-async

vim  broker-a-s.properties

# Broker 对外服务的监听端口
listenPort=10911
# 是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=false
# 是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=false
# nameServer地址，分号分割
namesrvAddr=172.16.238.43:9876;172.16.238.42:9876
# Broker 对外服务的IP地址
brokerIP1=172.16.238.42
# 存储路径
storePathRootDir=/usr/local/rocketmq/store/broker-a-s
# commitLog 存储路径
storePathCommitLog=/usr/local/rocketmq/store/broker-a-s/commitlog
# 消费队列存储路径存储路径
storePathConsumeQueue=/usr/local/rocketmq/store/broker-a-s/consumequeue
# 消息索引存储路径
storePathIndex=/usr/local/rocketmq/store/broker-a-s/index
# checkpoint 文件存储路径
storeCheckpoint=/usr/local/rocketmq/store/checkpoint
# abort 文件存储路径
abortFile=/usr/local/rocketmq/store/abort
  • 修改bin目录下的runbroker.sh文件，把8g 4g 改成2g 1g
cd /usr/local/rocketmq/bin

vim runbroker.sh

JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g"
  • 修改bin目录下的runserver.sh文件，把8g 4g 改成2g 1g
cd /usr/local/rocketmq/bin

vim runserver.sh

JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
  • 启动nameserver
nohup sh /usr/local/rocketmq/bin/mqnamesrv >/usr/local/rocketmq/logs/mqnamesrv.log 2>&1 &
  • 启动broker-a-slave
nohup sh /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/2m-2s-async/broker-a-s.properties > /usr/local/rocketmq/logs/broker-a-s.log 2>&1 &
  • 启动broker-b-master
nohup sh /usr/local/rocketmq/bin/mqbroker -c /usr/local/rocketmq/conf/2m-2s-async/broker-b.properties > /usr/local/rocketmq/logs/broker-b.log 2>&1 &
  • 查看启动日志
cd /usr/local/rocketmq/logs

tail -f mqnamesrv.log

tail -f broker-a-s.log

tail -f broker-b.log
0
rocketmq
版权归属： Administrator
本文链接： http://43.137.6.247:8090/archives/rocketmq-cluster-installation
许可协议： 本文使用《署名-非商业性使用-相同方式共享 4.0 国际 (CC BY-NC-SA 4.0)》协议授权

评论区