1.从 Github 拉取源码
这里下载的是 4.9.1 的源码,目前最新的版本,地址是 https://github.com/apache/rocketmq/releases
点击下 Source code 就可以直接下载了
2.将源码导入 IDEA
将下载下来的源码解压,然后在 IDEA 里点击 Open,选择要导入的 RocketMQ 源码项目,直接打开就行
选择我们本地的 maven 配置
等待下载依赖
3.源码目录结构
- acl
- broker:顾名思义,存放的是 RocketMQ 的 Broker 相关的代码,可以启动 Broker 进程
- client:顾名思义,就是存放 RocketMQ 的 Producer、Consumer 这些客户端相关的代码,生产消息、消费消息的代码都在里面
- common:公共的代码
- dev:存放的是开发相关的一些信息
- distribution:存放的就是用来部署 RocketMQ 的一些东西,如 bin 目录、conf 目录等等
- doc
- example:存放的是 RocketMQ 的例子
- filter:存放的是 RocketMQ 过滤器相关的
- logappender、logging:存放的是 RocketMQ 日志打印相关的
- namesrv:存放的是 NameServer 的源码
- openmessaging:开放消息标准
- remoting:重要,存放的是 RocketMQ 远程网络通信模块的代码,基于 netty 实现的
- srvutil:工具类
- store:重要,存放的是消息在 Broker 上进行存储的一些源码
- style、test、tools:存放的是 CheckStyle 代码检查的东西,一些测试相关的类,还有就是 tools 里放的一些命令行监控工具类