2019-06-28 / MQ

RocketMQ--单机

配置

准备一台服务器：192.168.1.201，修改hosts文件（vim /etc/hosts），加入映射关系：

192.168.1.201 rocketmq-nameserver1
192.168.1.201 rocketmq-master1

重启网卡：

systemctl restart network

防火墙命令：

# 查看防火墙
systemctl status firewalld.service
# 关闭防火墙（方便测试）
systemctl stop firewalld.service

解压安装包，解压文件到/usr/local/目录下：

unzip rocketmq-all-4.4.0-bin-release.zip -d /usr/local

更改解压后的文件名：

mv rocketmq-all-4.4.0-bin-release rocketmq

创建RocketMQ存储文件的目录,执行如下命令：

mkdir logs
mkdir store
cd store/
mkdir commitlog
mkdir consumequeue
mkdir index

文件夹	说明
logs	存储RocketMQ日志目录
store	存储RocketMQ数据文件目录
commitlog	存储RocketMQ消息信息
consumequeue	存储消息的索引数据
index	存储消息的索引数据

配置环境变量（vim /etc/profile），在文件的末尾添加：

ROCKETMQ_HOME=/usr/local/rocketmq
PATH=$PATH:$ROCKETMQ_HOME/bin
export ROCKETMQ_HOME PATH

使环境变量生效：

source /etc/profile

修改2m-2s-async目录下的broker-a.properties：

vim /usr/local/rocketmq/conf/2m-2s-async/broker-a.properties

用以下内容覆盖：

#集群名字
brokerClusterName=rocketmq-cluster
#broker名字
brokerName=broker-a
#0 表示Master, > 0 表示slave
brokerId=0
#nameServer 地址，分号分割
namesrvAddr=rocketmq-nameserver1: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
#发消息线程池数量
#sendMessageTreadPoolNums=128
#拉消息线程池数量
#pullMessageTreadPoolNums=128

启动

启动namesrv前，若要修改启动参数：

vim /usr/local/rocketmq/bin/runserver.sh

启动namesrv

nohup sh mqnamesrv &

启动broker前，若要修改启动参数：

vim /usr/local/rocketmq/bin/runbroker.sh

启动broker：

nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-2s-async/broker-a.properties  > /dev/null 2>&1 &

输入jps查看进程

[root@rocketmq-nameserver1 ~]# jps
7206 BrokerStartup
7213 Jps
7183 NamesrvStartup

配置控制台：

rocketmq.config.namesrvAddr=192.168.1.201:9876

查看控制台（http://localhost:8080/#/cluster）：

关闭

关闭broker命令：

sh mqshutdown broker

关闭namesrv命令：

sh mqshutdown namesrv