rocketmq安装记录

rocketmq3.5.8集群安装记录.

环境

3台机器，分别是：
192.168.1.180 web console
192.168.1.181 master-slave
192.168.1.182 master-slave

181、182互为主从。

配置文件为/opt/rocketmq-3.5.8/devenv/conf/2m-2s-async

broker:
192.168.1.182中通过broker-a.properties、broker-b-s.properties启动rocketmq-broker
192.168.1.181中通过broker-b.properties、broker-a-s.properties启动rocketmq-broker

nameserver:
192.168.1.181:9876;192.168.1.182:9876

rocketmq-web-console.war 下载地址

解压完后配置WEB-INF/classes/config.properties中nameserver的地址即可。

rocketmq版本

rocketmq-3.5.8版本

rocketmq3.5.8下载地址

操作步骤

配置hosts

修改181、182的/etc/hosts文件，加入：
192.168.1.182 rocketmq-master
192.168.1.181 rocketmq-slave

修改181的配置文件

修改181的配置文件，目录为/opt/rocketmq-3.5.8/devenv/conf/2m-2s-async
1、broker-a.properties内容如下：

[root@lehoon 2m-2s-async]# cat broker-a.properties 
brokerClusterName=LehoonCluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH

namesrvAddr=rocketmq-master:9876;rocketmq-slave:9876

storePathRootDir=/opt/rocketmq-3.5.8/store
storePathCommitLog=/opt/rocketmq-3.5.8/store/commitlog

2、broker-b-s.properties文件内容如下：

[root@lehoon 2m-2s-async]# cat broker-b-s.properties

brokerClusterName=LehoonCluster
brokerName=broker-b
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH

listenPort=10919

storePathRootDir=/opt/rocketmq-3.5.8/store
storePathCommitLog=/opt/rocketmq-3.5.8/store/commitlog

namesrvAddr=rocketmq-master:9876;rocketmq-slave:9876

3、修改logback的文件目录
修改/opt/rocketmq-3.5.8/devenv/conf/目录下的logback配置文件

sed -i 's#${user.home}#/opt#g' *.xml

把{user.home}替换为/opt

修改182的配置文件

修改182的配置文件，目录为/opt/rocketmq-3.5.8/devenv/conf/2m-2s-async
1、broker-b.properties内容如下：

[root@lehoon 2m-2s-async]# cat broker-b.properties 
brokerClusterName=LehoonCluster
brokerName=broker-b
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH

namesrvAddr=rocketmq-master:9876;rocketmq-slave:9876

storePathRootDir=/opt/rocketmq-3.5.8/store
storePathCommitLog=/opt/rocketmq-3.5.8/store/commitlog

2、broker-a-s.properties文件内容如下：

[root@lehoon 2m-2s-async]# cat broker-a-s.properties

brokerClusterName=LehoonCluster
brokerName=broker-a
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH

listenPort=10919

storePathRootDir=/opt/rocketmq-3.5.8/store
storePathCommitLog=/opt/rocketmq-3.5.8/store/commitlog

namesrvAddr=rocketmq-master:9876;rocketmq-slave:9876

3、修改logback的文件目录
修改/opt/rocketmq-3.5.8/devenv/conf/目录下的logback配置文件

sed -i 's#${user.home}#/opt#g' *.xml

把{user.home}替换为/opt

创建目录

在181、182分别创建以下目录
在rocketmq目录下撞见store、store/commitlog目录
创建/opt/log/rocketmqlogs/otherdays目录

启动rocketmq服务

启动namserver

1、在182上启动nameserver、broker,进入rocketmq的bin目录下

cd /opt/rocketmq-3.5.8/deven/bin
[root@lehoon bin]# nohup ./mqnamesrv >/var/log/mqnamesrv.log 2>&1 &
[root@lehoon bin]# nohup ./mqbroker -c ../conf/2m-2s-async/broker-a.properties > /var/log/mqbrokera.log 2>&1 &
[root@lehoon bin]# nohup ./mqbroker -c ../conf/2m-2s-async/broker-b-s.properties > /var/log/mqbrokerbs.log 2>&1 &

2、在181上启动nameserver、broker,进入rocketmq的bin目录下

cd /opt/rocketmq-3.5.8/deven/bin
[root@lehoon bin]# nohup ./mqnamesrv >/var/log/mqnamesrv.log 2>&1 &
[root@lehoon bin]# nohup ./mqbroker -c ../conf/2m-2s-async/broker-b.properties > /var/log/mqbrokerb.log 2>&1 &
[root@lehoon bin]# nohup ./mqbroker -c ../conf/2m-2s-async/broker-a-s.properties > /var/log/mqbrokeras.log 2>&1

启动web-console服务

下载tomcat，把rocketmq-web-console.war放入webapps目录
进入bin目录启动tomcat
然后通过http://hostname:port/rocketmq-web-console访问管理页面

注意点

在同一台机器启动多个broker的时候，需要注意配置文件中的listenPort配置的和上一个broket要间隔4以上。
因为broker启动会占用3个端口，listenPort、listenPort + 1、listenPort - 2。
例如：
broker1配置的listenPort=10911，那么再配置一个broker的时候，listenPort应该在10915之后或者10905之前。
否则会导致broker启动不起来，netty的bind0报错，端口已占用。