中间件-RocketMQ-启动

一、启动rocketmq
参考https://blog.csdn.net/lw5885799/article/details/88646051
1，启动name server
进入bin目录下
nohup mqnamesrv -n 你的公网IP:9876 &

2，修改配置文件
在conf/broker.conf 中 加入 brokerIP1=你的公网IP

3，起送broker
nohup sh bin/mqbroker -n 你的公网IP:9876 -c conf/broker.conf autoCreateTopicEnable=true &

使用上述启动方式，可以避免在使用源码进行测试的时候出现以下错误
org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout

jps查看进程

二、安装控制台
1.在github上下载源码

git clone https://github.com/apache/rocketmq-externals.git

2.下载完成后进入到rocketmq-console文件夹下，修改配置文件

rocketmq-externals/rocketmq-console/src/main/resources/application.properties

server.port=自定义端口
rocketmq.config.namesrvAddr=公网IP

 

3.打开README.md可以看到mvn clean package -Dmaven.test.skip=true在地址栏中输入cmd，

快速进入DOS页面,输入mvn clean package -Dmaven.test.skip=true进行编译打包

获取target/rocketmq-console-ng-1.0.1.jar

 

4.后台启动
java -jar jar_package_name &

 

5.浏览器输入：http://公网IP:自定义端口

 三、源码测试

github地址：https://github.com/apache/rocketmq

进入到example项目中的quickstart项目中

添加nameServer地址

一般报错情况
org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout
按照上面的方式启动没有问题

另外有些云主机的资源较小，而rocketmq默认的资源占用较多，所以会出现一些别的问题，此时可以先关闭其他进程，或者修改rocketmq占用资源的情况