搭建RocketMQ可視化管理控制臺

                        小編:管理員 159閱讀 2022.07.29

                        一、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的路徑加載

                        <plugin>
                                    <artifactId>maven-compiler-plugin</artifactId>
                                    <version>3.1</version>
                                    <configuration>
                                        <fork>true</fork>
                                           <executable>
                                           E:\JDK\bin\javac.exe
                                          </executable>
                                    </configuration>
                                </plugin>
                        復制

                        問題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進入控制臺界面了,如下圖:

                        成功

                        關聯標簽:
                        少妇各种各样BBBⅩXX