首頁 > 軟體

搭建RocketMQ在本地IDEA開發偵錯環境教學

2022-02-22 13:02:50

前言

發現公司這邊的訊息中介軟體採用了aliyun的RocketMQ服務,熟悉開源的同學都知道,RocketMQ是國內最早一批捐獻Apache併成功畢業的專案。架構設計參考了kafka的模式,所以如果你瞭解kafka的架構,對於RocketMQ就可以輕車熟路了,雖然參考了kafka,但是RocketMQ也有很多的升級,比如Broker的註冊和發現就採用了內部的NameServer,沒有引入更多的第三方依賴,而且新增了諸如訊息回溯、事務訊息、延時訊息等特色功能。由於之前沒有接觸過RocketMQ(之前一直用的kafka和RabbitMQ),準備研究一番,也為了後面整合spring boot metrics監控RocketMQ使用者端資訊做準備。研究一個開源專案,最好的方法就是Debug,所以記錄下本地搭建RocketMq的偵錯環境過程

生成安裝包

專案地址:https://github.com/apache/rocketmq ,從這個地址下載專案後,匯入到IDEA開發工具,執行mvn install,生成安裝RocketMQ包,生成成功後,在distribution模組下,會有如下目錄,這個目錄等下會用到

啟動NameServer

找到namesrv模組,執行NamesrvStartup的main方法,這個時候會提示你,需要設定ROCKETMQ_HOME,提示資訊如下:

這個時候就需要第一步生成的目錄,

拷貝/Users/kl/githubnamespace/rocketmq/distribution/target/rocketmq-4.7.1/rocketmq-4.7.1目錄

在IDEA的執行設定介面,新增如下引數:

-Drocketmq.home.dir=/Users/kl/githubnamespace/rocketmq/distribution/target/rocketmq-4.7.1/rocketmq-4.7.1

如:

然後在啟動,就可以成功啟動了

啟動broker

參照啟動NameServer的模式,找到borker模組,設定好ROCKETMQ_HOME,在用相同的方式採用-D方式,設定下NameServer的地址,如:

-Drocketmq.namesrv.addr=127.0.0.1:9876

然後啟動即可,此時一個完整的跑在IDEA中的單節點架構的RocketMQ服務就搭建好了

安裝RocketMQ Console

為了更好的觀察瞭解RocketMQ的功能,可以安裝一個web管理控制檯,這個需要用到另一個專案

專案地址:https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console

安裝成功後,就可以通過web頁面查詢producer傳送的message資訊,開啟瀏覽器,輸入:http://localhost:8080。就可以看到如下頁面:

盡情的DEBUG

一切準備就緒後,可以找到專案的example模組,裡面內建了各種特性功能的使用案例,接下來就可以一個一個案例Runing起來,盡情的Deubg

以上就是搭建RocketMQ在本地IDEA開發偵錯環境教學的詳細內容,更多關於搭建RocketMQ本地IDEA開發偵錯環境的資料請關注it145.com其它相關文章!


IT145.com E-mail:sddin#qq.com