RocketMQ安装教程

RocketMQ安装教程 1.下载

http://mirror.bit.edu.cn/apache/rocketmq/

2.安装

tar -zxf alibaba-rocketmq-3.2..tar.gz

cd alibaba-rocketmq/bin

chmod u+x *

3.配置和启停

建个目录存放配置文件,建个目录存放日志文件

mkdir alibaba-rocketmq/conf/using

mkdir alibaba-rocketmq/logs

3.1mqnamesrv 3.1.1配置mqnamesrv

先使用-p输出当前的默认配置生成配置模板，再作修改

cd alibaba-rocketmq/bin

./mqnamesrv -p > ../conf/using/namesrv.properties

编缉生成的配置文件namesrv.properties，主要按需修改以下两项

kvConfigPath=/home/ls/namesrv/kvConfig.json

listenPort=

3.1.2启停mqnamesrv

启动：

cd alibaba-rocketmq/bin

./mqnamesrv -c ../conf/using/namesrv.properties > ../logs/namesrv.log

停止：

cd alibaba-rocketmq/bin

./mqshutdown namesrv

3.2broker 3.2.1配置broker

一样先用-p输出当前默认配置作为模板，在此基础上做修改；但是broker一般会设置主从所以在生成之后我们不对生成配置文件直接做修改而是主从各复制一份后再作修改

cd alibaba-rocketmq/bin

./mqbroker -p > ../conf/using/broker.properties

3.2.1.2配置slave

cp ../conf/using/broker.properties ../conf/using/broker-s.properties

vi ../conf/using/broker-s.properties

主要按需配置以下选项

namesrvAddr=192.168.220.128:   #namesrvAddr默认为空必须填上不然启动报错，值为上边启动的namesrv的监听地址；如果多个nameser则用“,”隔开

brokerName=broker                  #broker名称，主从关系则主从名称相同，非主从关系则名称要不同

brokerId=                         #如果为master则为0，slave则为1

listenPort=                   #习惯默认的10911端口给master用，slave用靠后端口

storePathRootDir=/usr/myapp/alibaba-rocketmq/store/store-s #数据存储路径

storePathCommitLog=/usr/myapp/alibaba-rocketmq/store/store-s/commitlog #存储日志路径

brokerRole=SLAVE                   #主从角色

flushDiskType=ASYNC_FLUSH          #主从同步方式，异步复制

3.2.1.3配置master

cp ../conf/using/broker.properties ../conf/using/broker-m.properties

vi ../conf/using/broker-m.properties

和slave一样配置以下选项

namesrvAddr=192.168.220.128:    #namesrvAddr默认为空必须填上不然启动报错，值为上边启动的namesrv的监听地址；如果多个nameser则用“,”隔开

brokerName=broker                   #broker名称，主从关系则主从名称相同，非主从关系则名称要不同

brokerId=                          #如果为master则为0，slave则为1

listenPort=                    #习惯默认的10911端口给master用，slave用靠后端口

storePathRootDir=/usr/myapp/alibaba-rocketmq/store/store-m #数据存储路径

storePathCommitLog=/usr/myapp/alibaba-rocketmq/store/store-m/commitlog #存储日志路径

brokerRole=ASYNC_MASTER             #主从角色

flushDiskType=ASYNC_FLUSH           #主从同步方式，异步复制

3.2.2启停broker

启动时要先启动slave后启动master不然启动报错，停止时本机所有broker都会补停止

启动：

cd alibaba-rocketmq/bin

./mqbroker -c ../conf/using/broker-s.properties > ../logs/broker-s.log

./mqbroker -c ../conf/using/broker-m.properties > ../logs/broker-m.log

停止：

cd alibaba-rocketmq/bin

./mqshutdown broker

4.集群搭建

对于集群（一般是两台使用2m-2s模式）一样是同样地建namesrv/slave/master，区别主要是以下两点：

一是namesrvAddr要写上所有namesrv的地址用“,”隔开

二是一对主从一般不配在同一台机器上（比如在192.168.220.128上配置了brokerName=broker-a，brokerId=0的主broker那么brokerName=broker-a，brokerId=1会配到192.168.220.129上）