前言

發現公司這邊的消息中間件采用了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