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内容如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
[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文件内容如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
[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配置文件

1
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内容如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
[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文件内容如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
[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配置文件

1
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目录下

1
2
3
4
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目录下

1
2
3
4
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报错,端口已占用。

文章目录
  1. 1. 环境
  2. 2. rocketmq版本
  3. 3. 操作步骤
    1. 3.1. 配置hosts
    2. 3.2. 修改181的配置文件
    3. 3.3. 修改182的配置文件
    4. 3.4. 创建目录
  4. 4. 启动rocketmq服务
    1. 4.1. 启动namserver
  5. 5. 启动web-console服务
  6. 6. 注意点