15分鐘搭建RocketMQ源碼調試環境

時間 2020-12-13

標籤 git github apache maven ide 測試 idea 插件日誌欄目 Git 简体版

原文原文鏈接

下載源碼

下載源碼，github頁面選擇(rocketmq-all-4.7.1)版本壓縮包，https://github.com/apache/rocketmq/tagsgit

導入IDEA

1. 使用IDEA打開工程後，修改pom.xml文件中無關內容
1. 去除maven-gpg-plugin、maven-failsafe-plugin插件
3. 使用IDEA的maven編譯整個項目，(clean compile install)，記得Skip Testsgithub

新建文件夾，存放配置、日誌、消息體等內容

1. 新建一個文件夾，如1local_ROCKETMQ_HOME
2. 1local_ROCKETMQ_HOME路徑下建立3個文件夾(conf,logs,store)
3. 將工程中distribution/conf目錄下的3個文件(logback_namesrv.xml,logback_broker.xml,broker.conf)，複製到前面建立的conf目錄下
4. 修改broker.conf，增長【附錄1】中的配置，注意替換路徑
5. 修改logback_namesrv.xml和logback_broker.xml中的${user.home}參數，替換爲1local_ROCKETMQ_HOME絕對路徑
6. 修改org.apache.rocketmq.common.namesrv.NamesrvConfig，rocketmqHome變量，緣由是動態獲取配置，現改成1local_ROCKETMQ_HOME絕對路徑
7. 修改org.apache.rocketmq.common.BrokerConfig變量，緣由是動態獲取配置，現改成1local_ROCKETMQ_HOME絕對路徑apache

應用啓動

1. NameServer啓動
    1. NamesrvStartup main方法啓動便可
    2. 控制檯打印以下日誌表明啓動成功(The Name Server boot success. serializeType=JSON)
    3. 1local_ROCKETMQ_HOME/logs/rocketmqlogs可看到詳細日誌
2. BrokerStartup啓動
    1. BrokerStartup main方法啓動便可(啓動時需指定conf文件  -c D:\opensource_code\rocketmq\1local_ROCKETMQ_HOME\conf\broker.conf)
    2. 控制檯打印以下日誌表明啓動成功(The broker[broker-a, 你的ip:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876)
    3. 1local_ROCKETMQ_HOME/logs/rocketmqlogs可看到詳細日誌maven

測試消息的生產和消費

1. 消息發送，找到類org.apache.rocketmq.example.quickstart.Producer
    1. 增長代碼，指定NameSrv地址，  producer.setNamesrvAddr("127.0.0.1:9876");
    2. 啓動main方法，可見日誌輸出SendResult
    3. 在store路徑下，可見已生成TopicTest相關的物理文件
2. 消息消費，找到類org.apache.rocketmq.example.quickstart.Consumer
    1. 增長代碼，指定NameSrv地址，  consumer.setNamesrvAddr("127.0.0.1:9876");
    2. 啓動main方法，可見日誌輸出消費日誌，如 ConsumeMessageThread_19 Receive New Messages: xxx....ide

附錄1

#nameServer 地址 分號分割
namesrvAddr=127.0.0.1:9876
# 存儲路徑
storePathRootDir=D:\\opensource_code\\rocketmq\\1local_ROCKETMQ_HOME\\store
#commitLog 存儲路徑
storePathCommitLog=D:\\opensource_code\\rocketmq\\1local_ROCKETMQ_HOME\\store\\commitlog
# 消費隊列存儲路徑
storePathConsumeQueue=D:\\opensource_code\\rocketmq\\1local_ROCKETMQ_HOME\\store\\consumequeue
# 消息索引｜存儲路徑
storePathindex=D:\\opensource_code\\rocketmq\\1local_ROCKETMQ_HOME\\store\\index
#checkpoint 文件存儲路徑
storeCheckpoint=D:\\opensource_code\\rocketmq\\1local_ROCKETMQ_HOME\\store\\checkpoint
#abort 文件存儲路徑
abortFile=D:\\opensource_code\\rocketmq\\1local_ROCKETMQ_HOME\\store\\abort