RocketMQ部署--双master方式

拼搏现实的明天。 2022-05-21 02:25 151阅读 0赞

\#1、服务器环境  
序号 IP 用户名 角色 模式  
1 192.168.100.24 root nameServer1,brokerServer1 Master1  
2 192.168.100.25 root nameServer2,brokerServer2 Master2  
\#2、Hosts添加信息  
vi /etc/hosts  
IP NAME  
192.168.100.24 rocketmq-nameserver1  
192.168.100.24 rocketmq-master1  
192.168.100.25 rocketmq-nameserver2  
192.168.100.25 rocketmq-master2  
\#3、上传解压  
两台机器都要做如下操作：  
上传alibaba-rocketmq-3.2.6.tar.gz文件至/usr/local  
tar -zxvf alibaba-rocketmq-3.2.6.tar.gz -C /usr/local  
mv alibaba-rocketmq alibaba-rocketmq-3.2.6  
ln -s alibaba-rocketmq-3.2.6 rocketmq  
ll /usr/local  
\#4、创建存储路径  
两台机器都要做如下操作：  
mkdir /usr/local/rocketmq/store  
mkdir /usr/local/rocketmq/store/commitlog  
mkdir /usr/local/rocketmq/store/consumequeue  
mkdir /usr/local/rocketmq/store/index  
\#5、RocketMQ配置文件  
两台机器都要做如下操作：  
vim /usr/local/rocketmq/conf/2m-noslave/broker-a.properties  
修改完broker-a.properties之后再修改broker-b.properties  
vim /usr/local/rocketmq/conf/2m-noslave/broker-b.properties  
配置文件内容如下：

#所属集群名字
    brokerClusterName=rocketmq-cluster
    #broker名字，注意此处不同的配置文件填写的不一样
    brokerName=broker-a|broker-b
    #0 表示 Master，>0 表示 Slave
    brokerId=0
    #nameServer地址，分号分割
    namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876
    #在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
    defaultTopicQueueNums=4
    #是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
    autoCreateTopicEnable=true
    #是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
    autoCreateSubscriptionGroup=true
    #Broker 对外服务的监听端口
    listenPort=10911
    #删除文件时间点，默认凌晨 4点
    deleteWhen=04
    #文件保留时间，默认 48 小时
    fileReservedTime=120
    #commitLog每个文件的大小默认1G
    mapedFileSizeCommitLog=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
    #- SLAVE
    brokerRole=ASYNC_MASTER
    #刷盘方式
    #- ASYNC_FLUSH 异步刷盘
    #- SYNC_FLUSH 同步刷盘
    flushDiskType=ASYNC_FLUSH
    #checkTransactionMessageEnable=false
    #发消息线程池数量
    #sendMessageThreadPoolNums=128
    #拉消息线程池数量
    #pullMessageThreadPoolNums=128

\#6、修改日志配置文件  
两台机器都要做如下操作：  
mkdir -p /usr/local/rocketmq/logs  
cd /usr/local/rocketmq/conf && sed -i ‘s$\{user.home\}/usr/local/rocketmqg’ \*.xml  
\#7、修改启动脚本参数  
两台机器都要做如下操作：  
vim /usr/local/rocketmq/bin/runbroker.sh

============================================================
     开发环境JVM Configuration
    ============================================================
    JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -
    XX:PermSize=128m -XX:MaxPermSize=320m"
     vim /usr/local/rocketmq/bin/runserver.sh
    JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn512m -
    XX:PermSize=128m -XX:MaxPermSize=320m"

\#8、启动NameServer  
两台机器都要做如下操作：  
cd /usr/local/rocketmq/bin  
nohup sh mqnamesrv &  
\#9、启动BrokerServer A【192.168.100.24】  
cd /usr/local/rocketmq/bin  
nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-a.properties >/dev/null 2>&1 &  
netstat -ntlp  
jps  
tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/broker.log  
tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/namesrv.log  
\#10、启动BrokerServer B【192.168.100.25】  
cd /usr/local/rocketmq/bin  
nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-noslave/broker-b.properties >/dev/null 2>&1 &  
netstat -ntlp  
jps  
tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/broker.log  
tail -f -n 500 /usr/local/rocketmq/logs/rocketmqlogs/namesrv.log  
\#11、RocketMQ Console  
rocketmq-console是RocketMQ的控制台web程序，修改rocketmq-console/WEB-INF/classes/config.properties文件中的rocketmq.namesrv.addr属性，其值为你实际部署的RocketMQ的namesrv地址和端口，有多个时用英文分号";"隔开，然后在tomcat中部署rocketmq-console.war后即可在浏览器中输入localhost:8080/rocketmq-console进入控制台。  
\#12、数据清理  
cd /usr/local/rocketmq/bin  
sh mqshutdown broker  
sh mqshutdown namesrv  
–等待停止  
rm -rf /usr/local/rocketmq/store  
mkdir /usr/local/rocketmq/store  
mkdir /usr/local/rocketmq/store/commitlog  
mkdir /usr/local/rocketmq/store/consumequeue  
mkdir /usr/local/rocketmq/store/index  
–按照上面步骤重启NameServer与BrokerServer