RocketMQ学习笔记(5)----RocketMQ监控平台rocketmq-console-ng的搭建

摘要:
1.下载rocketmq控制台ng官网地址:https://github.com/apache/rocketmq-externals将其拉下来后,使用该想法打开rocketmq控制台,并修改rocketmq.config。应用程序中的namesrvAddr。属性配置文件(集群环境中名称服务器的ip:port),如下所示:ro
1. 下载rocketmq-console-ng

  官网地址:https://github.com/apache/rocketmq-externals

  RocketMQ学习笔记(5)----RocketMQ监控平台rocketmq-console-ng的搭建第1张

  拉下来之后,使用idea打开rocketmq-console,在application.properties配置文件中修改rocketmq.config.namesrvAddr(前面集群环境下的nameserver的ip:port),如下:

rocketmq.config.namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876

  然后打开终端 ,使用如下命令打包:

·  mvn clean package -Dmaven.test.skip=true,将会在target目录中生成一个.jar文件(因为这是一个springboot项目)

  将打包生成的.jar文件上传到linux服务器上。

  使用java -jar 文件名运行服务,访问http://47.105.145.123:8080/#/,出现如下控制台  RocketMQ学习笔记(5)----RocketMQ监控平台rocketmq-console-ng的搭建第2张

  可以看到有很多菜单可以用的,点到cluster,

RocketMQ学习笔记(5)----RocketMQ监控平台rocketmq-console-ng的搭建第3张

   看到我们前面搭的集群环境已经可以注册上去了,可以查看信息和修改配置了。

  可能出现的问题:

  如果报不能连接到10909端口异常:connect to 172.31.36:10909 failed,这里默认的是使用了vip通道,需要在rocketmq-console项目源码中修改配置文件,如下:

rocketmq.config.isVIPChannel=false

  然后重新打包上传,

  如果配置之后出现不能连接私有异常:connect to 172.31.36:10911 failed,这是默认的rocketmq会将broker的访问ip使用私有ip,这时只需要在broker配置文件中添加

brokerIP1=公网ip

  重启即可:nohup sh mqbroker -c /usr/local/middle/rocketmq/conf/2m-noslave/broker-a.properties >/dev/null 2>&1 &

  

免责声明:文章转载自《RocketMQ学习笔记(5)----RocketMQ监控平台rocketmq-console-ng的搭建》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇TI提供的超详细示波器各个环节设计参考指南RabbitMQ(二)核心组件介绍下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

RocketMQ 内存优化

rocketmq官方文档 RocketMQ 的默认内存占用非常高,通过更改mqbroker和mqnamesrv的配置可以调整内存。 有两个启动脚本,runbroker.sh 和runserver.sh。 找到runserver.sh和runbroker.sh,编辑,然后重新启动broker JAVA_OPT=”${JAVA_OPT} -server -Xm...

2019 多益网络java面试笔试题 (含面试题解析)

  本人5年开发经验、18年年底开始跑路找工作,在互联网寒冬下成功拿到阿里巴巴、今日头条、多益网络等公司offer,岗位是Java后端开发,因为发展原因最终选择去了多益网络,入职一年时间了,也成为了面试官,之前面试了很多家公司,感觉大部分公司考察的点都差不多,趁空闲时间,将自己的心得记下来,希望能给正在找或者准备找工作的朋友提供一点帮助。   下面提的问题...

rocketmq学习

官网地址 安装name server和broker git clone https://github.com/apache/incubator-rocketmq.git cd incubator-rocketmq mvn clean package install -Prelease-all assembly:assembly -U 然后target...

RocketMQ的消息发送及消费

RocketMQ消息支持的模式: 消息支持的模式分为三种:NormalProducer(普通同步),消息异步发送,OneWay。 消息同步发送: 普通消息的发送和接收在前面已经演示过了,在前面的案例中是基于同步消息发送模式。也就是说消息发送出去后,producer会等到broker回应后才能继续发送下一个消息. 消息异步发送: 异步发送是指发送方发出数据后...

RocketMQ源码 — 八、 RocketMQ消息重试

RocketMQ的消息重试包含了producer发送消息的重试和consumer消息消费的重试。 producer发送消息重试 producer在发送消息的时候如果发送失败了,RocketMQ会自动重试。 private SendResult sendDefaultImpl( Message msg, final Communication...

【RocketMQ】同一个项目中,同一个topic,可以存在多个消费者么?

一、问题答案 是不可以的 而且后注册的会替换前注册的,MqConsumer2会替换MqConsumer,并且只结束tag-2的消息 /** * @date 2019/05/28 */ @Component @Slf4j public class MqConsumer implementsMessageConsumer { @Overr...