下载源码

从 https://github.com/apache/rocketmq.git 下载RocketMQ源码并上传到 Linux服务器上的 /usr/local/rocketmq目录下

从 https://github.com/apache/rocketmq-externals.git 下载rocketmq扩展的源码，下面使用到的 rocketmq-console 就在这个工程里面，并上传到 Linux服务器上的 /usr/local/rocketmq目录下

安装Maven

在/usr/local/maven-3.6.3 目录下执行命令下载Maven

wget https://mirrors.tuna.tsinghua.edu.cn/apache/maven/maven-3/3.6.3/binaries/apache-maven-3.6.3-bin.tar.gz

执行

tar -zxvf apache-maven-3.6.3-bin.tar.gz

将下载的tar包 进行解压，然后进到conf目录下编辑 settings.xml 文件

在mirrors节点下添加阿里云镜像

<mirror>

<id>aliyun-maven</id>

<mirrorOf>*</mirrorOf>

<name>aliyun maven</name>

<url>http://maven.aliyun.com/nexus/content/groups/public</url>

</mirror>

配置Maven环境变量

vim /etc/profile

添加

export M2_HOME=/usr/local/maven-3.6.3/apache-maven-3.6.3

export PATH=$PATH:$M2_HOME/bin

环境变量修完执行source /etc/profile立即生效

执行 mvn -v 显示maven版本信息说明安装成功

安装JDK8

将下载的 jdk 安装包上传到 /usr/local/java8 目录下

配置 JDK 环境变量

vim /etc/profile

添加

export JAVA_HOME="/usr/local/java8/jdk1.8.0_211"

export CLASS_PATH="$JAVA_HOME/lib"

export PATH=".$PATH:$JAVA_HOME/bin"

环境变量修完执行source /etc/profile立即生效

执行 java -version 显示java版本说明安装成功

编译RocketMQ和rocketmq-console

进到rocketmq的主目录下执行如下mvn命令进行编译

mvn -Prelease-all -DskipTests clean install -U

最后打成的包在distribution/target/apache-rocketmq目录下

然后将distribution/target/apache-rocketmq目录下的rocketmq-4.6.1文件夹拷贝到/usr/local/rocketmq目录下方便后面使用

进到 rocketmq-console 工程目录下执行如下mvn命令进行编译

mvn clean package -Dmaven.test.skip=true

最后打成的包是target/rocketmq-console-ng-1.0.1.jar，将jar拷贝到/usr/local/rocketmq目录下方便后面使用

进入到rocketmq-4.6.1/bin目录下

编辑runbroker.sh、runserver.sh脚本中的JVM堆内存大小，默认比较大根据实际情况改小一点

编辑tools.sh 脚本文件添加 export NAMESRV_ADDR=localhost:9876，后面执行测试发送消息和消费消息时会用到namesrv地址

启动nameserver

执行如下命令进行启动namesrv

./mqnamesrv

启动Borker

执行如下命令启动broker

./mqbroker -n localhost:9876

测试生产消息、消费消息

使用tool.sh脚本执行测试程序

在bin目录下执行命令测试发送消息

./tools.sh org.apache.rocketmq.example.quickstart.Producer

在bin目录下执行命令测试消费消息

./tools.sh org.apache.rocketmq.example.quickstart.Consumer

启动控制台rocketmq-console

在 /usr/local/rocketmq 目录下执行如下命令启动控制台程序

java -jar rocketmq-console-ng-1.0.1.jar --rocketmq.config.namesrvAddr=localhost:9876

显示如下图信息说明启动成功

在浏览器中输入 IP:8080 地址即可访问RocketMQ控制台页面

参考地址：

https://rocketmq.apache.org/docs/quick-start/

https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console