RocketMQ有一个可视化的的dashboard,通过该控制台可以直观的看到很多数据
1.下载
下载地址:https://github.com/apache/rocketmq-externals/releases
image.png
2.修改配置
修改其src/main/resources中的application.properties配置文件。
- 原来的端口号为 8080 ,修改为一个不常用的
- 指定RocketMQ的name server地址
image.png
3.添加依赖
在解压目录rocketmq-console的pom.xml中添加如下JAXB依赖。
JAXB,Java Architechture for Xml Binding,用于XML绑定的Java技术,是一个业界标准,是一项可以根据XML Schema生产Java类的技术。
<dependency>
<groupId>javax.xml.bind</groupId>
<artifactId>jaxb-api</artifactId>
<version>2.3.0</version>
</dependency>
<dependency>
<groupId>com.sun.xml.bind</groupId>
<artifactId>jaxb-impl</artifactId>
<version>2.3.0</version>
</dependency>
<dependency>
<groupId>com.sun.xml.bind</groupId>
<artifactId>jaxb-core</artifactId>
<version>2.3.0</version>
</dependency>
<dependency>
<groupId>javax.activation</groupId>
<artifactId>activation</artifactId>
<version>1.1.1</version>
</dependency>
4.打包
在rocketmq-console目录下执行打包命令
mvn clean package -Dmaven.test.skip=true
打好包后在target目录下会生成可执行的jar包
image.png
5.启动
直接java-jar启动
java -jar rocketmq-console-ng-1.0.0.jar
image.png
在Message里,Topic选择Topic Test就可以看到我们刚刚发送的消息了。