RocketMQ源码本地搭建调试方法

更新时间：2023年01月28日 09:49:32 作者：JavaEdge.

这篇文章主要介绍了RocketMQ源码本地搭建调试,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下

1 GitHub源码

git clone https://github.com/apache/rocketmq.git

导入IDEA，可在命令行执行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

需设置环境变量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，进一步发现是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方法第一行
也可设置环境变量ROCKETMQ_HOME
或启动时加入命令行参数 -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 目录下即可。
然后在来启动一下，控制台打印：

说明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));
}

再启动：

虽然打印启动成功，再验证是否能成功发送和接收消息。

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();
        // 发送消息
        SendResult result = producer.send(new Message(topic, "hello rocketmq".getBytes()));
        System.out.println(result.getSendStatus());
        // 关闭producer
        producer.shutdown();
    }
}

启动ProducerTest，控制台打印SEND_OK，我们的producer发送消息也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已经发送了消息，所以我们设置从第一个开始消费
        consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
        // 添加消息监听器
        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 总结

中间出一些问题，都能根据提示信息在源码中找到相应解决方案，多看源码，是成长捷径。

到此这篇关于RocketMQ源码本地搭建调试的文章就介绍到这了,更多相关RocketMQ源码本地搭建调试内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Java中字符串常见的拼接方式小结
在Java中,字符串拼接是开发过程中非常常见的操作,根据不同的需求和性能考虑,有多种方式可以实现字符串的拼接,本文给大家介绍了五种拼接方式,并通过代码讲解的非常详细,需要的朋友可以参考下
2024-10-10
springboot项目启动,但是访问报404错误的问题
这篇文章主要介绍了springboot项目启动,但是访问报404错误的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-12-12
mybatis-plus 如何操作json字段
这篇文章主要介绍了mybatis-plus 如何操作json字段，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-10-10
教你正确的Java扩展方法示例详解
这篇文章主要为大家介绍了教你正确的Java扩展方法示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-03-03
java操作时间方式基础教程demo
这篇文章主要为大家介绍了java操作时间方式demo基础教程示例,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
2023-10-10
Groovy动态语言使用教程简介
这篇文章主要为大家介绍了Groovy动态语言使用教程简介，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-09-09
Java运算符从见过到掌握下
计算机的最基本用途之一就是执行数学运算，作为一门计算机语言，Java也提供了一套丰富的运算符来操纵变量，本篇对大家的学习或工作具有一定的价值，紧接上篇，需要的朋友可以参考下
2021-09-09
Java微信公众平台之素材管理
这篇文章主要为大家详细介绍了Java微信公众平台之素材管理，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2018-05-05
springboot跨域如何设置SameSite的实现
这篇文章主要介绍了springboot跨域如何设置SameSite的实现,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-05-05
基于多网卡环境下Eureka服务注册IP的选择问题
这篇文章主要介绍了基于多网卡环境下Eureka服务注册IP的选择问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-03-03