前言

發(fā)現(xiàn)公司這邊的消息中間件采用了aliyun的RocketMQ服務(wù)，熟悉開源的同學(xué)都知道，RocketMQ是國(guó)內(nèi)最早一批捐獻(xiàn)Apache并成功畢業(yè)的項(xiàng)目。架構(gòu)設(shè)計(jì)參考了kafka的模式，所以如果你了解kafka的架構(gòu)，對(duì)于RocketMQ就可以輕車熟路了，雖然參考了kafka，但是RocketMQ也有很多的升級(jí)，比如Broker的注冊(cè)和發(fā)現(xiàn)就采用了內(nèi)部的NameServer，沒有引入更多的第三方依賴，而且添加了諸如消息回溯、事務(wù)消息、延時(shí)消息等特色功能。由于之前沒有接觸過RocketMQ（之前一直用的kafka和RabbitMQ），準(zhǔn)備研究一番，也為了后面集成spring boot metrics監(jiān)控RocketMQ客戶端信息做準(zhǔn)備。研究一個(gè)開源項(xiàng)目，最好的方法就是Debug，所以記錄下本地搭建RocketMq的調(diào)試環(huán)境過程

生成安裝包

項(xiàng)目地址：https://github.com/apache/rocketmq ，從這個(gè)地址下載項(xiàng)目后，導(dǎo)入到IDEA開發(fā)工具，執(zhí)行mvn install，生成安裝RocketMQ包，生成成功后，在distribution模塊下，會(huì)有如下目錄，這個(gè)目錄等下會(huì)用到

啟動(dòng)NameServer

找到namesrv模塊，運(yùn)行NamesrvStartup的main方法，這個(gè)時(shí)候會(huì)提示你，需要設(shè)置ROCKETMQ_HOME，提示信息如下：

這個(gè)時(shí)候就需要第一步生成的目錄，

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

在IDEA的運(yùn)行設(shè)置界面，添加如下參數(shù)：

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

如：

然后在啟動(dòng)，就可以成功啟動(dòng)了

啟動(dòng)broker

參照啟動(dòng)NameServer的模式，找到borker模塊，設(shè)置好ROCKETMQ_HOME，在用相同的方式采用-D方式，配置下NameServer的地址，如：

-Drocketmq.namesrv.addr=127.0.0.1:9876

然后啟動(dòng)即可，此時(shí)一個(gè)完整的跑在IDEA中的單節(jié)點(diǎn)架構(gòu)的RocketMQ服務(wù)就搭建好了

安裝RocketMQ Console

為了更好的觀察了解RocketMQ的功能，可以安裝一個(gè)web管理控制臺(tái)，這個(gè)需要用到另一個(gè)項(xiàng)目

項(xiàng)目地址：https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console

安裝成功后，就可以通過web頁面查詢producer發(fā)送的message信息，打開瀏覽器，輸入：http://localhost:8080。就可以看到如下頁面：

盡情的DEBUG

一切準(zhǔn)備就緒后，可以找到項(xiàng)目的example模塊，里面內(nèi)置了各種特性功能的使用案例，接下來就可以一個(gè)一個(gè)案例Runing起來，盡情的Deubg

以上就是搭建RocketMQ在本地IDEA開發(fā)調(diào)試環(huán)境教程的詳細(xì)內(nèi)容，更多關(guān)于搭建RocketMQ本地IDEA開發(fā)調(diào)試環(huán)境的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！