rocketMQ部署

 

rocketMQ部署(单机)

1、          环境：

CentOS7 64  &  JDK1.8+ 64  & 用户:www

2、          下载binary文件包：

wget http://mirror.rise.ph/apache/rocketmq/4.3.0/rocketmq-all-4.3.0-bin-relerel.zip

unzip  rocketmq-all-4.3.0-bin-release.zip

mv rocketmq-all-4.3.0-bin-release rocketmq

cd rocketmq/conf

vim logback_namesrv.xml

vim logback_broker.xml

...

###将.xml文件内的${user.home}替换成现实指定路径###

:%s/${user.home}/.../g

###将jdk安装路径添加到运行文件中（否则会找不到环境）###

vim rocketmq/bin/runserver.sh

vim rocketmq/bin/runbroker.sh

...

JAVA_HOME=/data/soft/jdk

...

3、          安装java环境：

下载jdk1.8版本

tar zxvf jdk-8u181-linux-x64.tar.gz

mv jdk1.8.0_181/ jdk

vim ~/.bash_profile

...添加环境变量...

JAVA_HOME=/data/soft/jdk

CLASSPATH=$JAVA_HOME/lib/

PATH=$PATH:$JAVA_HOME/bin/:$JAVA_HOME/jre/bin/

export PATH

4、          配置文件参考：

双主模式：rocketmq/conf/2m-noslave/中

vim broker-a.properties

===========================================================

brokerClusterName=DefaultCluster

brokerIP1=192.168.27.111

brokerName=broker-a

brokerId=0

#nameServer地址，分号分割

namesrvAddr=192.168.27.111:9876;192.168.27.2:9876

#Broker 对外服务的监听端口

listenPort=10911

#Broker 的角色

#- ASYNC_MASTER 异步复制Master

#- SYNC_MASTER 同步双写Master

#- SLAVE

brokerRole=ASYNC_MASTER

#刷盘方式

#- ASYNC_FLUSH 异步刷盘

#- SYNC_FLUSH 同步刷盘

flushDiskType=ASYNC_FLUSH

#==================================================================

#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数

defaultTopicQueueNums=50

#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭

autoCreateTopicEnable=true

#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭

autoCreateSubscriptionGroup=true

#删除文件时间点，默认凌晨 4点

deleteWhen=04

#文件保留时间，默认 48 小时

fileReservedTime=48

#commitLog每个文件的大小默认1G

mapedFileSizeCommitLog=1073741824

#ConsumeQueue每个文件默认存30W条，根据业务情况调整

mapedFileSizeConsumeQueue=300000

#destroyMapedFileIntervalForcibly=120000

#redeleteHangedFileInterval=120000

#检测物理文件磁盘空间

diskMaxUsedSpaceRatio=88

#存储路径

storePathRootDir=/data/soft/rocketmq/loga/rocketmq/store

#commitLog 存储路径

storePathCommitLog=/data/soft/rocketmq/loga/rocketmq/store/commitlog

#消费队列存储路径存储路径

storePathConsumeQueue=/data/soft/rocketmq/loga/rocketmq/store/consumequeue

#消息索引存储路径

storePathIndex=/data/soft/rocketmq/loga/rocketmq/store/index

#checkpoint 文件存储路径

storeCheckpoint=/data/soft/rocketmq/loga/rocketmq/store/checkpoint

#abort 文件存储路径

abortFile=/data/soft/rocketmq/loga/rocketmq/store/abort

#限制的消息大小

maxMessageSize=65536

#flushCommitLogLeastPages=4

#flushConsumeQueueLeastPages=2

#flushCommitLogThoroughInterval=10000

#flushConsumeQueueThoroughInterval=60000

#checkTransactionMessageEnable=false

#发消息线程池数量

#sendMessageThreadPoolNums=128

#拉消息线程池数量

#pullMessageThreadPoolNums=128

messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h

vim broker-b.properties

#==========================================================

brokerClusterName=DefaultCluster

brokerIP1=192.168.27.2

brokerName=broker-b

brokerId=0

#nameServer地址，分号分割

namesrvAddr=192.168.27.111:9876;192.168.27.2:9876

#Broker 对外服务的监听端口

listenPort=10911

#Broker 的角色

#- ASYNC_MASTER 异步复制Master

#- SYNC_MASTER 同步双写Master

#- SLAVE

brokerRole=ASYNC_MASTER

#刷盘方式

#- ASYNC_FLUSH 异步刷盘

#- SYNC_FLUSH 同步刷盘

flushDiskType=ASYNC_FLUSH

#==================================================================

#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数

defaultTopicQueueNums=50

#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭

autoCreateTopicEnable=true

#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭

autoCreateSubscriptionGroup=true

#删除文件时间点，默认凌晨 4点

deleteWhen=04

#文件保留时间，默认 48 小时

fileReservedTime=48

#commitLog每个文件的大小默认1G

mapedFileSizeCommitLog=1073741824

#ConsumeQueue每个文件默认存30W条，根据业务情况调整

mapedFileSizeConsumeQueue=300000

#destroyMapedFileIntervalForcibly=120000

#redeleteHangedFileInterval=120000

#检测物理文件磁盘空间

diskMaxUsedSpaceRatio=88

#存储路径

storePathRootDir=/data/www/rocketmq/store

#commitLog 存储路径

storePathCommitLog=/data/www/rocketmq/store/commitlog

#消费队列存储路径存储路径

storePathConsumeQueue=/data/www/rocketmq/store/consumequeue

#消息索引存储路径

storePathIndex=/data/www/rocketmq/store/index

#checkpoint 文件存储路径

storeCheckpoint=/data/www/rocketmq/store/checkpoint

#abort 文件存储路径

abortFile=/data/www/rocketmq/store/abort

#限制的消息大小

maxMessageSize=65536

#flushCommitLogLeastPages=4

#flushConsumeQueueLeastPages=2

#flushCommitLogThoroughInterval=10000

#flushConsumeQueueThoroughInterval=60000

#checkTransactionMessageEnable=false

#发消息线程池数量

#sendMessageThreadPoolNums=128

#拉消息线程池数量

#pullMessageThreadPoolNums=128

messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h

5、          启动namesrv和broker：

ln –s /data/soft/rocketmq/bin/mqnamesrv /data/bin/mqnamesrv

ln –s /data/soft/rocketmq/bin/mqbroker /data/bin/mqbroker

# mqnamesrv -n “192.168.27.111:9876” &

//-n参数根据”namesrvAddr”配置的地址，多主机用;分割。

#mqbroker -n 192.168.27.111:9876 -c /data/soft/rocketmq/conf/2m-noslave/broker-a.properties > /dev/null 2>&1 &

6、          其他：

若是2m，则两台机器都启动namesrv，一台broker指向broker-a.properties，另一台执行broker-b.properties。

###若部署集群模式，至少两台主机（IP）。