前言

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

生成安裝包

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

啟動NameServer

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

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

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

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

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

如：

然后在啟動，就可以成功啟動了

啟動broker

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

-Drocketmq.namesrv.addr=127.0.0.1:9876

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

安裝RocketMQ Console

為了更好的觀察了解RocketMQ的功能，可以安裝一個web管理控制臺，這個需要用到另一個項目

項目地址：https://github.com/apache/rocketmq-externals/tree/master/rocketmq-console

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

盡情的DEBUG

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