RocketMQ——部署(一)双Master方式

青旅半醒 2021-09-26 21:44 323阅读 0赞

### 一.上传RocketMQ对应的压缩包（官网可下） ###

1.上传 alibaba-rocketmq-3.2.6.tar.gz至两台服务器的/usr/local，我这边用的是虚拟机，两台服务器的内网IP分别为：192.168.140.128，192.168.140.129；

2.解压对应的包

执行如下命令：

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

### 二.分别在两台服务器上创建对应的存储路径 ###

1.创建存储路径命令如下：

\# mkdir /usr/local/rocketmq/store  
    \# mkdir /usr/local/rocketmq/store/commitlog  
    \# mkdir /usr/local/rocketmq/store/consumequeue

\# mkdir /usr/local/rocketmq/store/index

### 三.修改RocketMQ配置文件（双Master方式） ###

#### 1.修改配置文件命令如下： ####

\# vim /usr/local/rocketmq/conf/2m-noslave/broker-a.properties

\# vim /usr/local/rocketmq/conf/2m-noslave/broker-b.properties

#### 2.修改内容如下： ####

注意brokerName这边的值，不同的配置文件填写的内容是不一样的

#所属集群名字
    brokerClusterName=rocketmq-cluster
    #broker名字，注意此处不同的配置文件填写的不一样
    brokerName=broker-a|broker-b
    #0 表示 Master，>0 表示 Slave
    brokerId=0
    #nameServer地址，分号分割
    namesrvAddr=192.168.140.128:9876;192.168.140.129: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

### 3.修改日志配置文件 ###

\# mkdir -p /usr/local/rocketmq/logs

\# cd /usr/local/rocketmq/conf && sed -i 's\#$\{user.home\}\#/usr/local/rocketmq\#g' \*.xml

#### 4.修改启动脚本参数 ####

\# 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"

## 四.启动RocketMQ ##

#### 1.启动NameServer ####

# cd /usr/local/rocketmq/bin
    # nohup sh mqnamesrv &

#### 2.启动BrokerServer A(192.168.140.128) ####

# 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

#### 3.启动BrokerServer B(192.168.140.129) ####

# 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

## 五.关闭RocketMQ ##

# 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