你好，我是程序员Alan,很快乐遇见你。
一、RocketMQ目录构造
在正式开始搭建调试环境之前，咱们先理解一下RockeMQ源码的整体架构。
这是因为把握了整体架构，能够让咱们迅速理解各个方面的个性，并且能够不便咱们后续疾速定位功能模块对应的代码文件。话不多说，咱们开始看RocketMQ目录构造。
acl: 权限管制。能够给话题指定权限，只有领有权限的消费者才能够进行生产。
broker: RocketMQ 的 Broker 相干代码，用来启动 Broker 过程。Broker 就是用来收客户端发的音讯、存储音讯传、递音讯给生产端的组件。
client：RocketMQ 的 Producer、Consumer 这些客户端的代码，用来生产音讯、生产音讯。
common：公共模块。
distribution：用来部署 RocketMQ 的，比方 bin 目录 ，conf 目录。
example： RocketMQ 的用例。
filter：RocketMQ 过滤器。
namesvr：NameServer 的源码。NameServer 就是所有 Broker 都须要注册的中央，注册核心。
remoting：RocketMQ 的近程网络通信模块。
srvutil：工具类。
store：音讯存储。
style：代码查看。
tools：命令行监控工具相干。
二、获取RocketMQ源码
源码地址：https://github.com/apache/roc...
我下载的是5.0.0版本，你也能够在github下载其余版本。
如果下载遇到困难，能够留言或者私信我。
三、导入源码
代码下载解压之后，应用IDEA工具导入。
四、下载依赖
先确认Maven目录地址，再刷新，期待依赖下载实现。
五、启动RocketMQ的NameServer
5.1 配置NameServer启动参数
5.1.1 Edit Configurations，配置 ROCKETMQ_HOME 环境变量
5.2 拷贝配置文件
Value 的文件夹是用来部署 RocketMQ 的，外面包含 bin 目录 ，conf 目录，store目录。
咱们首先创立一个文件夹，并创立三个子文件夹，别离是 bin ，conf ，store。
文件夹都创立好之后，咱们把RocketMQ自带的配置文件拷贝过去。
须要拷贝的文件夹是源码目录 distribution 目录中的 broker.conf、logback_namesrv.xml、logback_broker.xml。
5.3 批改 logback 日志配置文件
关上 logback_namesrv.xml、logback_broker.xml， ${user.home} 全局替换为之前配置的 ROCKETMQ_HOME 目录
5.4 批改broker配置文件
关上 broker.conf 文件，把上面的配置拷贝进去。
namesrvAddr=127.0.0.1:9876brokerIP1=127.0.0.1storePathRootDir=D:/Project/ROCKETMQ_HOME/storestorePathCommitLog=D:/Project/ROCKETMQ_HOME/store/commitlogstorePathConsumeQueue=D:/Project/ROCKETMQ_HOME/store/consumequeuestorePathIndex=D:/Project/ROCKETMQ_HOME/store/indexstoreCheckpoint=D:/Project/ROCKETMQ_HOME/store/checkpointabortFile=D:/Project/ROCKETMQ_HOME/store/abort5.5 启动NameServer
六、启动RocketMQ的Broker
6.1 配置Broker的启动参数
6.2 启动Broker
6.3 查看启动日志
关上 ROCKETMQ_HOME /logs/rocketmqlogs 目录下的 broker.log 或者 namesrv.log 文件看启动的具体日志。
七、测试生产音讯
7.1 咱们能够间接应用源码自带的示例来做测试。
7.2 关上 Producer.java, 设置 name server addresses
7.3 启动 Producer
7.4 胜利发送音讯
八、测试生产音讯
咱们持续应用自带的测试用例。
8.2 关上 Consumer.java, 设置 name server addresses
8.3 启动消费者
8.4 胜利生产音讯
九、应用RocketMQ Dashboard 查看 RocketMQ运行状况
站在伟人的肩膀上
- 悟空聊架构