本篇文章主要讲述rocketmq的控制台安装、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查看进程

二、安装控制台
在github上下载源码
https://github.com/apache/rocketmq-externals

下载完成后进入到
rocketmq-console
文件夹下,修改配置文件
修改内容如下,127.0.0.1为单节点nameServer的地址

打开README.md可以看到mvn clean package -Dmaven.test.skip=true
在地址栏中输入cmd,快速进入DOS页面,输入mvn clean package -Dmaven.test.skip=true
进行编译打包

获取jar包

后台启动
java -jar jar_package_name &
访问( 8080为server.port的地址)
ip:8080

三、源码测试
github地址:https://github.com/apache/rocketmq

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

添加nameServer地址

一般报错情况
org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException: sendDefaultImpl call timeout
按照上面的方式启动没有问题
另外有些云主机的资源较小,而rocketmq默认的资源占用较多,所以会出现一些别的问题,此时可以先关闭其他进程,或者修改rocketmq占用资源的情况,详细修方法请百度!
网友评论