1.从 Github 拉取源码

这里下载的是 4.9.1 的源码,目前最新的版本,地址是 https://github.com/apache/rocketmq/releases
image.png
点击下 Source code 就可以直接下载了

2.将源码导入 IDEA

将下载下来的源码解压,然后在 IDEA 里点击 Open,选择要导入的 RocketMQ 源码项目,直接打开就行
image.png
选择我们本地的 maven 配置
image.png
等待下载依赖
image.png

3.源码目录结构

image.png

  1. acl
  2. broker:顾名思义,存放的是 RocketMQ 的 Broker 相关的代码,可以启动 Broker 进程
  3. client:顾名思义,就是存放 RocketMQ 的 Producer、Consumer 这些客户端相关的代码,生产消息、消费消息的代码都在里面
  4. common:公共的代码
  5. dev:存放的是开发相关的一些信息
  6. distribution:存放的就是用来部署 RocketMQ 的一些东西,如 bin 目录、conf 目录等等
  7. doc
  8. example:存放的是 RocketMQ 的例子
  9. filter:存放的是 RocketMQ 过滤器相关的
  10. logappender、logging:存放的是 RocketMQ 日志打印相关的
  11. namesrv:存放的是 NameServer 的源码
  12. openmessaging:开放消息标准
  13. remoting:重要,存放的是 RocketMQ 远程网络通信模块的代码,基于 netty 实现的
  14. srvutil:工具类
  15. store:重要,存放的是消息在 Broker 上进行存储的一些源码
  16. style、test、tools:存放的是 CheckStyle 代码检查的东西,一些测试相关的类,还有就是 tools 里放的一些命令行监控工具类