RocketMQ源码分析【一】idea RocketMQ源码分析本地环境搭建调试

分手后的思念是犯贱 2022-09-12 03:57 255阅读 0赞

### 文章目录 ###

*   *  Fork RocketMQ源码到本地仓库
     *  idea拉取自己仓库RocketMQ源码
     *  启动NameServer
     *  启动 Broker
     *  启动\`Producer\`生产消息
     *  启动\`Consumer\` 消费者
     *  总结

## Fork RocketMQ源码到本地仓库 ##

[RocketMQ][]源码地址:https://github.com/apache/rocketmq  
首先我们将RocketMQ的源码fork到我们自己仓库，因为我们可能会对RocketMQ源码作一些改变，然后需要提交到我们自己仓库中，比如添加注释，但是我们不能直接推到RocketMQ官方仓库，所以先fork一份到我们自己本地仓库  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16]  
fork完就发现我们本地仓库有一份rocketmq源码了  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 1]

## idea拉取自己仓库RocketMQ源码 ##

直接在本地仓库复制git地址  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 2]

然后在idea中拉取  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 3]

这里可能会clone比较久，我们耐心等待下。下载完后整体源码结构如下：  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 4]

我们对源码的一些模块作一些简单说明吧  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 5]

## 启动NameServer ##

NameServer 的启动类入口在`NamesrvStartup`中  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 6]

如果直接启动我们会报错  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 7]  
提示我们要配置RocketMQ环境变量

我们在RocketMQ源码路径外随便建立一个文件夹(我这里名字就叫`rocketmq-nameserver`)，  
然后在其中新建三个文件夹  
![在这里插入图片描述][860aeb3cf56a4316ade0c13cc42f301f.png]

将源码中的这两个配置文件复制放入conf文件夹中  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 8]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 9]

然后在启动类`NamesrvStartup`启动参数中配置`ROCKETMQ_HOME`

`ROCKETMQ_HOME=/Users/weihubeats/Desktop/sofe/rocketmq-nameserver`

> 其中 = 后面就是你刚才创建的文件路径

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 10]

然后就可以启动成功了  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 11]

## 启动 Broker ##

Broker启动和NameServer类似  
启动入口是 `BrokerStartup.class`  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 12]  
也是在启动类中配置环境变量。我们还是使用上面的环境变量即可，然后在配置文件中复制logback\_broker.xml到我们的本地环境变量中

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 13]

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 14]  
然后启动`Broker`  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 15]  
这里就显示`Broker`启动成功了

但是没看到 `name server`地址，有点奇怪，跟源码看了一下  
![在这里插入图片描述][30e8ee0aea64484b86ded98cd437b935.png]  
都是从系统参数中获取，那么我们在启动参数中再加一个`namesrvAddr`地址,同时为了方便测试我们添加自动创建topic参数,所以启动参数就变成了  
`ROCKETMQ_HOME=/Users/weihubeats/Desktop/sofe/rocketmq-nameserver;NAMESRV_ADDR=127.0.0.1:9876;autoCreateTopicEnable=true`

## 启动`Producer`生产消息 ##

我们直接运行rocketmq给我提供的测试类`Producer`，其中要添加一行代码

producer.setNamesrvAddr("127.0.0.1:9876");

然后启动发送消息

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 16]

![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 17]  
可以看到发送消息是成功了的

## 启动`Consumer` 消费者 ##

同上面`Producer`类似  
`Consumer` 添加如下代码

consumer.setNamesrvAddr("127.0.0.1:9876");

我们接着启动`Consumer`  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 18]  
至此`RocketMQ`源码调试环境搭建完成

## 总结 ##

总的来说还是比较多的坑的，其从我就因为配置了两个jdk版本，比如jdk8个jdk11，期间换了一次jdk版本`broker`就启动不成功了，具体解决方案参考这里:  
https://blog.csdn.net/niwo\_345/article/details/113099629

总得来说源码调试并不是那么容易，还是要自己多动手

[RocketMQ]: https://github.com/apache/rocketmq
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/d6816cd4c0564917aba5c2ea33178da4.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220828/f34854a485884777a2a74ec353995029.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 2]: /images/20220828/fb2da196f21d412c976958acd41a1bf0.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 3]: /images/20220828/dc2bb42d65344cd89104a0575a9bd28e.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 4]: /images/20220828/9d2fea2bc2e14739a0f808445db48e91.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 5]: /images/20220828/92c620f8397e4da698beec359622745d.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 6]: /images/20220828/80ec428db0174fbd8b35c8f024d2cbe6.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 7]: /images/20220828/93c4b3dd34b4436cb8d099a3e10843db.png
[860aeb3cf56a4316ade0c13cc42f301f.png]: /images/20220828/078a1e73c6834972a09160f5dd9f56a9.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 8]: /images/20220828/cc14eadb7f9d4220bae19229e72f43ac.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 9]: /images/20220828/d9f4d661c06746e48a595256a328440a.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 10]: /images/20220828/807d97b20d794ac789134e71e8217735.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 11]: /images/20220828/32241fa3cf2b4fd09b9e0aef8afb16e5.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 12]: /images/20220828/b00215323ad6408eabbc1644c8ff66e8.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 13]: /images/20220828/ccdee852bbee4f8d9661a8f25cfe7851.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 14]: /images/20220828/2a7c3e21fc6c48a0b751db9601e1a04e.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 15]: /images/20220828/a497a99ae7cf4069af59f942ca04d102.png
[30e8ee0aea64484b86ded98cd437b935.png]: /images/20220828/0303c9ac5a1d4206b5d08e96cf696561.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 16]: /images/20220828/d67f277d5009415983ba159914dc908e.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 17]: /images/20220828/0fb383bde8bd4e75a18ae98c689cf0e2.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBAd2VpaHViZWF0cw_size_20_color_FFFFFF_t_70_g_se_x_16 18]: /images/20220828/62a9c68c616f4b759d919ee73dd16f19.png