- 下载
运行版下载地址：https://www./dyn/closer.cgi?path=rocketmq/4.7.1/rocketmq-all-4.7.1-bin-release.zip
源码版本下载地址：https://www./dyn/closer.cgi?path=rocketmq/4.7.1/rocketmq-all-4.7.1-source-release.zip - 环境准备：jdk8(提前配置环境变量)，maven(源码版需要/或者将源码编译好放到服务器也可以)
- 将编译好的源码上传到服务器指定目录下
 - 修改conf/broker.conf，配置brokerIP1=当前的主机ip
 - 修改runserver.sh和runbroker.sh启动参数，主要设置启动的jvm内存大小
cd rocketmq-all-4.7.1-bin-release/bin
vi runserver.sh
vi runbroker.sh
6 启动服务，先启动namesrv，在启动broker
启动mqnamesrv 在bin目录下执行
sh mqnamesrv -n localhost:9876
出现如下则表示mqnamesrv启动成功
启动mqbroker
sh mqbroker -c ../conf/broker.conf -n localhost:9876
出现如下则表示mqbroker启动成功
7. 测试
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
下图为消费正常
8. RocketMQ驾驶舱使用
下载好的项目源码，找到rocket-console子模块，修改它下面的application.properties配置文件，增加：rocketmq.config.namesrvAddr=之前启动的主机ip:9876
9. 在rocket-console执行cmd命令
mvn clean package -DskipTests=true
会生成target目录在当前目录下，找到jar包部署到服务器，直接运行
java -jar rocketmq-console-ng-1.0.1.jar
10 浏览器访问：http://IP:8080
|
