rocketmq启动

本篇文章主要讲述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查看进程


image.png

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

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

image.png

下载完成后进入到rocketmq-console文件夹下,修改配置文件
image.png

修改内容如下,127.0.0.1为单节点nameServer的地址

image.png

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

image.png

获取jar包

image.png

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

ip:8080

image.png

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

进入到example项目中的quickstart项目中
image.png

添加nameServer地址
image.png

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

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

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容