本文详细说明如何在ubuntu16.04下安装rocketMQ的步骤。

首先需要打开root权限 sudo -i

下载安装jdk

wget http://download.oracle.com/otn-pub/java/jdk/8u181-b13/96a7b8442fe848ef90c96a2fad6ed6d1/jdk-8u181-linux-x64.tar.gz

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

mv jdk-8u181-linux-x64 /usr/jdk

配置JAVA_HOME

vi /etc/profile

在文件末尾追加:

JAVA_HOME=/usr/jdk
export JRE_HOME=$JAVA_HOME/jre
export CLASSPATH=.:$JAVA_HOME/lib:$JRE_HOME/lib:$CLASSPATH
export PATH=$JAVA_HOME/bin:$JRE_HOME/bin:$PATH

更新配置 source /etc/profile

通过 java -version 和 echo $JAVA_HOME 查看是否配置成功

下载安装rocketmq

wget http://mirrors.shu.edu.cn/apache/rocketmq/4.3.0/rocketmq-all-4.3.0-bin-release.zip

安装unzip工具: apt install unzip

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

mv rocketmq-all-4.3.0-bin-release /usr/rocketmq

启动mq

首先直接输入命令，启动命名服务，查看是否启动成功或报错

./bin/mqnamesrv

成功的话按Ctrl+C关闭，然后启动broker，查看是否启动成功

./bin/mqbroker -n localhost:9876

通过编写启动脚本来在后台启动服务

vi start-rocket.sh

输入:

nohup sh /usr/rocketmq/bin/mqnamesrv &
nohup sh /usr/rocketmq/bin/mqbroker -n localhost:9876 &

修改文件权限

chmod +x start-rocket.sh

执行脚本

./start-rocket.sh

验证mq是否正常工作

查看进程是否启动:

jps

设置命名服务地址:

export NAMESRV_ADDR=localhost:9876

启动生产者发送消息，然后关闭它:

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

启动消费者查看是否接收到消息:

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

其他

关闭服务的脚本

sh /usr/rocketmq/bin/mqshutdown broker
sh /usr/rocketmq/bin/mqshutdown namesrv

修改启动参数:

由于rocketmq默认设置的Java堆内存比较大，在开发时可以通过修改如下文件减少内存占用

vi runbroker.sh vi runserver.sh