RocketMQ源碼本地搭建調試方法
1 GitHub源碼
git clone https://github.com/apache/rocketmq.git
導入IDEA，可在命令行執(zhí)行mvn compile一下，保證源碼能夠正確編譯。本次我使用的master分支的版本-4.8.0。下面我們開始準備啟動Namesrv。
2 啟動Namesrv
到namesrv模塊找到NamesrvStartup，啟動main方法，報錯如下：
Please set the ROCKETMQ_HOME variable in your environment to match the location of the RocketMQ installation
需設置環(huán)境變量ROCKETMQ_HOME。怎么設置呢？看看報錯位置：
// org.apache.rocketmq.namesrv.NamesrvStartup#createNamesrvController
if (null == namesrvConfig.getRocketmqHome()) {
System.out.printf("Please set the %s variable in your environment to match the location of the RocketMQ installation%n", MixAll.ROCKETMQ_HOME_ENV);
System.exit(-2);
}
從namesrvConfig.getRocketmqHome中獲取的ROCKETMQ_HOME，進一步發(fā)現(xiàn)是NamesrvConfig里面的一個屬性
// org.apache.rocketmq.common.namesrv.NamesrvConfig // ROCKETMQ_HOME_PROPERTY = "rocketmq.home.dir"; // ROCKETMQ_HOME_ENV = "ROCKETMQ_HOME"; private String rocketmqHome = System.getProperty(MixAll.ROCKETMQ_HOME_PROPERTY, System.getenv(MixAll.ROCKETMQ_HOME_ENV));
- 為方便，可直接在源碼NamesrvStartup的main方法第一行
- 也可設置環(huán)境變量ROCKETMQ_HOME
- 或啟動時加入命令行參數(shù) -Drocketmq.home.dir=/path
public static void main(String[] args) {
System.setProperty(MixAll.ROCKETMQ_HOME_PROPERTY, "/Users/apple/doc/IDEAProjects/rocketmq");
main0(args);
}再次啟動Namesrv，報錯如下：
提示在我們配置的ROCKETMQ_HOME 目錄下，沒找到conf\logback_namesrv.xml 配置文件。
在項目中搜索logback_namesrv.xml 文件，找到在distribution\conf 目錄下存在很多配置，可直接使用這些配置文件。直接把distribution\conf 目錄copy到配置的ROCKETMQ_HOME 目錄下即可。
然后在來啟動一下，控制臺打?。?/p>
說明NameSrv啟動成功
3 啟動Broker
找到BrokerStartup，直接啟動：
Please set the ROCKETMQ_HOME variable in your environment to match the location of the RocketMQ installationDisconnected from the target VM, address: '127.0.0.1:51797', transport: 'socket'
知道咋辦了吧。
broker需要連接namrsrv，所以在BrokerStartup 的main方法第一行添加如下兩行代碼：
public static void main(String[] args) {
System.setProperty(MixAll.ROCKETMQ_HOME_PROPERTY, "/Users/apple/doc/IDEAProjects/rocketmq");
System.setProperty(MixAll.NAMESRV_ADDR_PROPERTY, "127.0.0.1:9876");
start(createBrokerController(args));
}再啟動：
雖然打印啟動成功，再驗證是否能成功發(fā)送和接收消息。
4 啟動Producer
Producer的demo代碼：
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
public class ProducerTest {
public static void main(String[] args) throws Exception {
String namesrvAddr = "127.0.0.1:9876";
String group = "test_group";
String topic = "test_hello_rocketmq";
// 構建Producer實例
DefaultMQProducer producer = new DefaultMQProducer();
producer.setNamesrvAddr(namesrvAddr);
producer.setProducerGroup(group);
// 啟動producer
producer.start();
// 發(fā)送消息
SendResult result = producer.send(new Message(topic, "hello rocketmq".getBytes()));
System.out.println(result.getSendStatus());
// 關閉producer
producer.shutdown();
}
}
啟動ProducerTest，控制臺打印SEND_OK，我們的producer發(fā)送消息也OK。
5 啟動Consumer
上代碼：
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerOrderly;
import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
import org.apache.rocketmq.common.message.MessageExt;
import java.util.List;
import java.util.concurrent.TimeUnit;
public class ConsumerTest {
public static void main(String[] args) throws Exception {
String namesrvAddr = "127.0.0.1:9876";
String group = "test_consumer_group";
String topic = "test_hello_rocketmq";
// 初始化consumer
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer();
consumer.setNamesrvAddr(namesrvAddr);
consumer.setConsumerGroup(group);
// 訂閱topic
consumer.subscribe(topic, (String) null);
// 設置消費的位置，由于producer已經發(fā)送了消息，所以我們設置從第一個開始消費
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
// 添加消息監(jiān)聽器
consumer.registerMessageListener(new MessageListenerOrderly() {
@Override
public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs, ConsumeOrderlyContext context) {
msgs.forEach(msg -> {
System.out.println(new String(msg.getBody()));
});
return ConsumeOrderlyStatus.SUCCESS;
}
});
// 啟動consumer
consumer.start();
// 由于是異步消費，所以不能立即關閉，防止消息還未消費到
TimeUnit.SECONDS.sleep(2);
consumer.shutdown();
}
}啟動消費者，能夠成功消費到消息，控制臺打印hello rocketmq。
6 總結
中間出一些問題，都能根據(jù)提示信息在源碼中找到相應解決方案，多看源碼，是成長捷徑。
到此這篇關于RocketMQ源碼本地搭建調試的文章就介紹到這了,更多相關RocketMQ源碼本地搭建調試內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
在Java中,字符串拼接是開發(fā)過程中非常常見的操作,根據(jù)不同的需求和性能考慮,有多種方式可以實現(xiàn)字符串的拼接,本文給大家介紹了五種拼接方式,并通過代碼講解的非常詳細,需要的朋友可以參考下2024-10-10
這篇文章主要介紹了springboot項目啟動,但是訪問報404錯誤的問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-12-12
這篇文章主要介紹了mybatis-plus 如何操作json字段，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-10-10
這篇文章主要為大家介紹了教你正確的Java擴展方法示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-03-03
這篇文章主要為大家介紹了java操作時間方式demo基礎教程示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪2023-10-10
這篇文章主要為大家介紹了Groovy動態(tài)語言使用教程簡介，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-09-09
計算機的最基本用途之一就是執(zhí)行數(shù)學運算，作為一門計算機語言，Java也提供了一套豐富的運算符來操縱變量，本篇對大家的學習或工作具有一定的價值，緊接上篇，需要的朋友可以參考下2021-09-09
這篇文章主要為大家詳細介紹了Java微信公眾平臺之素材管理，具有一定的參考價值，感興趣的小伙伴們可以參考一下2018-05-05
springboot跨域如何設置SameSite的實現(xiàn)
這篇文章主要介紹了springboot跨域如何設置SameSite的實現(xiàn),文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2021-05-05
基于多網(wǎng)卡環(huán)境下Eureka服務注冊IP的選擇問題
這篇文章主要介紹了基于多網(wǎng)卡環(huán)境下Eureka服務注冊IP的選擇問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2022-03-03