返回

搭建RocketMQ可视化管理控制台

一、RocketMQ简介

最近一直在做消息通知方面的项目,其中用的是阿里公司的RocketMq(简称RMQ)作为消息服务,RMQ是阿里开发的一个很不错的消息开源组件,支持亿级消息堆积能力,它也为淘宝天猫双十一提供了稳定的消息传递平台,现在在阿里云也推出了ONS服务,也是基于RMQ组件,RMQ在应用范围还是很广的,今天先简单介绍一下如何搭建服务。 RMQ的结构分为四个部分:生产者、消费者、nameserver、brokerserver nameserver:nameserver接收broker的请求注册broker路由信息。收client的请求根据某个topic获取所有到broker的路由信息。 brokerserver:消息的接收和推送, 生产者:发送消息,将消息推送给brokerserver。 消费者:接收消息,从brokerserver上获取消息。

二、服务环境

window7系统 1、Java jdk1.8 2、maven_3.3.9 这些安装下载,网上都有教程就不一一列举;

三、下载RocketMQ

rocketmq-console

2、rocketmq下载地址:https://github.com/apache/rocketmq-externals 如果下载的是源码,则需要在根目录执行

mvn clean package -Dmaven.test.skip=true 或mvn -Preplease-all -DskipTests clean install -U

问题报错

根目录下执行mvn clean package -Dmaven.test.skip=true命令时,出现上面错误:

解决办法:

在pom.xml中配置下jdk的路径加载


            maven-compiler-plugin
            3.1
            
                true
                   
                   E:\JDK\bin\javac.exe
                  
            
        
复制

问题1

配置好后,再执行命令,会生成target文件夹并在target目录下找到文件rocketmq-console-ng-1.0.0.jar

执行成功

rocketmq-console-ng-1.0.0.jar

四、启动

1、rocketmq的启动 windows环境下,新建一个rocketmq-console-ng.bat文件(与上面生成的rocketmq-console-ng-1.0.0.jar在同一个目录),内容如下:

@echo off java -jar rocketmq-console-ng-1.0.0.jar --server.port=19876 --rocketmq.config.namesrvAddr=127.0.0.1:9876 @pause

这里注意需要设置两个参数:--server.port为运行的这个web应用的端口,如果不设置的话默认为8080;--rocketmq.config.namesrvAddr为RocketMQ命名服务地址,如果不设置的话默认为“”。 设置好后就可以直接双击运行rocketmq-console-ng.bat即可启动,如下图:

启动成功

启动成功后,我们就可以通过浏览器访问http://localhost:19876进入控制台界面了,如下图:

成功

相关知识