搭建步骤

一、环境准备

• 服务器 Centos6.8 64位
• JDK 1.8 64位
• maven 3.5.0
• git
• rocketmq-4.0.0
• rocketmq-externals

二、配置环境变量

JAVA_HOME=/opt/jdk/
M2_HOME=/opt/maven/
PATH=$PATH:$JAVA_HOME/bin:$M2_HOME/bin
export JAVA_HOME  M2_HOME PATH
source /etc/profile

三、安装、启动RocketMQ

1.下载安装

cd /opt
wget https://codeload.github.com/apache/rocketmq/tar.gz/rocketmq-4.0.0-incubating
tar -zxvf rocketmq-rocketmq-4.0.0-incubating.tar.gz
cd rocketmq-rocketmq-4.0.0-incubating
#生成安装包
mvn -Prelease-all -DskipTests clean package install assembly:assembly -U
#拷贝包文件
cp target/apache-rocketmq-all.tar.gz  /usr/local/rocketmq
cd  /usr/local/rocketmq
#创建目录
mkdir /data/rocketmq/store/{consumequeue,commitlog} -p
#修改日志目录
sed -i 's#${user.home}#/data/rocketmq#g' *.xml

2.修改JVM参数

 -server -Xms8g -Xmx8g -Xmn4g
-XX:+UseG1GC -XX:G1HeapRegionSize=16m -XX:G1ReservePercent=25 -XX:InitiatingHeapOccupancyPercent=30 -XX:SoftRefLRUPolicyMSPerMB=0 -XX:SurvivorRatio=8 -XX:+DisableExplicitGC -verbose:gc -Xloggc:/dev/shm/mq_gc_%p.log -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+PrintGCApplicationStoppedTime -XX:+PrintAdaptiveSizePolicy -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5 -XX:GCLogFileSize=30m

3.启动nameserver

nohup sh mqnamesrv &
*--提示“The Name Server boot success. serializeType=JSON”
启动成功

4.配置broker

vim conf/broker.conf

brokerClusterName=DefaultCluster
namesrvAddr=x.x.x.x:9876;x.x.x.x:9876;
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=72
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
storePathCommitLog=/data/rocketmq/store/commitlog/
storePathConsumerQueue=/data/rocketmq/store/consumequeue/
mapedFileSizeCommitLog=1g

5.启动broker

sh bin/mqbroker -c ./conf/broker.conf &

6.查看状态

> rocketmq]# jps 
31076 Jps
18359 NamesrvStartup
12654 QuorumPeerMain
19086 BrokerStartup

>sh bin/mqadmin clusterList -n x.x.x.x:9876
有记录及可

四、安装rocketmq-console

1.下载tomcat

cd /opt
wget http://mirror.bit.edu.cn/apache/tomcat/tomcat-8/v8.5.23/bin/apache-tomcat-8.5.23.tar.gz
tar -zxf apache-tomcat-8.5.23.tar.gz

2.下载rocketmq-console.war

git clone https://github.com/apache/rocketmq-externals.git
cd /opt/rocketmq-externals/rocketmq-console
修改src/main/resources/application.properties
rocketmq.config.namesrvAddr=x.x.x.x:9876;x.x.x.x:9876;
#打包
cd /opt/rocketmq-externals/rocketmq-console
mvn clean package -Dmaven.test.skip=true

3.启动并访问

java -jar  target/rocketmq-console-ng-1.0.0.jar

http://x.x.x.x:8080