rocketmq 安装

一、rocketmq

1.1、文档

官网Quick Start

github中文文档

1.2、下载

apache官网下载地址yi

github源码下载地址

本次使用github下载的源码包进行安装

解压：tar -zxf rocketmq-rocketmq-all-4.8.0.tar.gz

1.3、编译

进入解压后的主目录，使用maven编译项目：mvn -Prelease-all -DskipTests clean install -U

进入分布式目录：cd distribution可以看到编译后的target目录

进入target目录下：cd target/rocketmq-4.8.0/rocketmq-4.8.0/bin 可以看到可执行文件

1.4、启动

1.4.1、启动nameServer

​ 前台启动：./mqnamesrv

​ 后台启动：nohup sh mqnamesrv &

​ 通过日志查看执行结果：tail -f ~/logs/rocketmqlogs/namesrv.log

​ 端口：9876

1.4.2启动Broker

启动的同时指定连接的nameServer地址

​ 前台启动：./mqbroker -n localhost:9876

​ 出现错误提示

vim mqbroker可以看到其执行的sh脚本

#修改脚本
vim runbroker.sh
#将原堆大小-Xms8g -Xmx8g -Xmn4g进行修改
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"

再次启动

​ 后台启动：nohup sh mqbroker -n localhost:9876 &

​ 通过日志查看执行结果：tail -f ~/logs/rocketmqlogs/broker.log

​ 端口：10911

1.5、测试

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

1.5.1、测试发送

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

失败-connect to null failed

原因：不知道nameserver在哪儿

在tools脚本中添加export NAMESRV_ADDR=localhost:9876

再次执行

1.5.2、测试接收

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

二、rocketmq-console（控制台）

2.1、下载

2.2、中文文档

2.3、编译

解压unzip rocketmq-externals-master.zip

进入主目录cd /usr/local/rocketmq-externals-master/rocketmq-console

使用maven进行编译：mvn clean package -Dmaven.test.skip=true

2.4、启动

编译成功后在rocketmq-console/target目录下执行rocketmq-console-ng-2.0.0.jar

启动时，直接动态添加nameserver地址或编辑application.properties添加属性

java -jar rocketmq-console-ng-2.0.0.jar --rocketmq.config.namesrvAddr=127.0.0.1:9876

启动成功后访问服务器8080端口即可