RocketMQ系列-搭建Namesrv源码调试环境

在学习任何一个技术框架的时候，我们通常都是先了解是什么，有什么作用、解决什么问题、设计亮点和设计思想是什么；当然对于技术学习上来说，这只是纸上谈兵，一开始比较基础的学习，当我们想要深入的时候，我们必不可少的就是希望能够去调试源码，能够在本地运行一下这个技术框架，能够断点调试一下这个框架最核心的功能或者看一下内部的数据结构。所以我们学习一个技术框架，特别核心的一点就是，要在本地搭建我们的源码调试环境。

笔者在这里，就把RocketMQ的整个源码调试环境搭建的过程给梳理出来，不过因为笔者的开发环境是Windows的，所以以下所有内容都是基于Windows环境实践得出来的。

PS：笔者在这里说一下，可能对于不了解RocketMQ或者说是零基础的读者来说，会有一些很陌生的词汇，例如Namesrv，Broker之类的，也不用怕，因为这个RocketMQ系列的诞生，正是因为笔者完完全全体验到了学习RocketMQ的痛苦，不想对RocketMQ感兴趣想要深入研究的读者也体验一遍，所以才总结自己这次学习RocketMQ的方式，让读者能够完全从使用角度去了解，研究RocketMQ的功能以及深入源码，而不是一个模块一个模块的单体化了解。

Namesrv源码调试环境搭建

导入项目到IDEA

因为笔者用的IDEA开发工具，所以以下的教程演示都是基于IDEA的。

克隆项目到本地

https://github.com/apache/rocketmq

读者需要先将RocketMQ的源码给下载到本地来。

导入项目到IDEA

按照maven的方式open RocketMQ目录，因为笔者已经open过了，所以不会出现maven的提示，如果读者的出现了，点击trust project即可，然后就等待下载对应的依赖即可

创建所需目录

我们使用任何一个中间件，都知道在部署启动的时候，肯定是会有存放配置文件的目录，还会有保存中间件本身产生对应日志和数据的目录，我们这里就是需要创建这样的目录。

在RocketMQ源码根目录下创建存放配置文件的目录-conf

在RocketMQ源码根目录下创建存放RocketMQ本身存放数据的目录-data

在RocketMQ源码根目录下创建存放RocketMQ运行日志的目录-logs

环境配置

将Namesrv的日志配置拷贝到我们上面创建的conf目录下

读者可能会疑惑，我怎么知道Namesrv的日志配置是怎么样的，这些问题RocketMQ都已经给我们想好了，在RocketMQ源码目录下，有一个distribution的目录，下面有不同模式部署RocketMQ对应的配置文件，目前我们本地跑，暂时只需要使用外面最基础的配置文件就可

配置环境变量

我们需要配置对应的环境变量，让RocketMQ启动的时候，把我们当前的源码目录作为根目录，这样它才能找到运行所需的配置文件在哪

ROCKETMQ_HOME=E:\study\source_code_learn\rocketmq

修改${user.home}属性

读者可以打开刚才准备好的日志文件看一下，发现里面会有一堆${user.home}

我们想把RocketMQ运行产生的日志指定放在我们之前准备好的logs目录下的话，放任不管肯定是不行，当然读者也可以选择直接将${user.home}直接全量替换成我们日志目录的绝对路径，不过在这里，笔者喜欢用另一种方式，通过增加一句代码的方式来实现。

我们打开Namesrv的启动类，也就是org.apache.rocketmq.namesrv.NamesrvStartup。在里面加上一句代码

public static NamesrvController main0(String[] args) {

        try {
            // 添加此行代码指定user.home
            System.setProperty("user.home", "E:/study/source_code_learn/rocketmq");
            NamesrvController controller = createNamesrvController(args);
            start(controller);
            String tip = "The Name Server boot success. serializeType=" + RemotingCommand.getSerializeTypeConfigInThisServer();
            log.info(tip);
            System.out.printf("%s%n", tip);
            return controller;
        } catch (Throwable e) {
            e.printStackTrace();
            System.exit(-1);
        }

        return null;
    }