在前面第一篇中已经将源代码下载到本地了，本篇主要是介绍代码中相关模块到作用。036.Rocket-MQ-Source-code-cover.png

一、源码结构

RocketMQ源码组织方式基于Maven按照模块组织，如下图所示：

RocketMQ-SouceCode-package

二、包说明

RocketMQ 核心目录说明如下：

• [1].broker: broker模块(broker启动进程)
• [2].client: 消息客户端，包含消息生产者、消息消费者相关类
• [3].common: 公共包
• [4].dev: 开发者信息(非源代码)
• [5].distribution: 部署实例文件夹(非源代码)
• [6].example: RocketMQ 示例代码
• [7].filter: 消息过滤相关基础类
• [8].filtersrv: 消息过滤服务器实现相关类(Filter启动进程)
• [9].logappender: 日志实现相关类
• [10].namesrv: NameServer实现相关类(NameServer启动进程)
• [11].openmessaging: 消息开放标准，正在制定中
• [12].remoting: 远程通信模块，基于Netty.
• [13].srvutil: 服务器工具类
• [14].store: 消息存储实现相关类
• [15].style: checkstyle相关实现
• [16].test: 测试相关类
• [17].tools: 工具类，监控命令相关实现类

三、IDEA 调试代码

3.1 启动NameServer

• step1: 展开namesrv模块，选择NameSrvStartup的main函数进行启动，如下图所示

NameSrvStartup

出现如下错误提示: Please Set ROCKETMQ_HOME..., 如下图所示

Error--没有设置RocketHome环境变量

• step2: 设置环境变量ROCKETMQ_HOME，如下图所示：

环境配置：EnvSet-01

环境配置：EnvSet-02

环境配置：EnvSet-03

环境配置：EnvSet-04

• step3: 在RocketMQ运行主目录下创建conf、logs、cus_store三个文件夹，如下图所示

创建文件夹

• step4: 从RocketMQ distribution 部署目录中的conf下将broker.conf, logback_broker.mxl, logback_namesrv.xml文件复制到conf目录下，同时修改broker.conf内容:

brokerClusterName = DefaultClusterbrokerName = broker-abrokerId = 0#nameServer地址，分号分割namesrvAddr=127.0.0.1:9876deleteWhen = 04fileReservedTime = 48brokerRole = ASYNC_MASTERflushDiskType = ASYNC_FLUSH#存储路径storePathRootDir=/Users/rain/Documents/IdealWorkspace/rocketmq430/cus_store#commitLog 存储路径storePathCommitLog=/Users/rain/Documents/IdealWorkspace/rocketmq430/cus_store/commitLog# 消费队列存储路径storePathConsumeQueue=/Users/rain/Documents/IdealWorkspace/rocketmq430/cus_store/consumequeue# 消息索引存储路径storePathIndex=/Users/rain/Documents/IdealWorkspace/rocketmq430/cus_store/index# checkpoint 文件存储路径storeCheckPoint=/Users/rain/Documents/IdealWorkspace/rocketmq430/cus_store/checkpoint# abort 文件存储路径abortFile=/Users/rain/Documents/IdealWorkspace/rocketmq430/cus_store/abort

具体的配置截图，如下图所示：

Modified-broker_conf

• step5: 启动NameSrvStartup，

启动失败(由于文件复制位置错误导致的)，如下图所示：

Start_up_error

启动成功，如下图所示：

Start_up_success

3.2 启动Broker

• step1: 展开broker模块，找到启动类BrokerStartup，并启动，如下图所示:

Broker-Startup_error

• step2: 配置环境变量，如下图所示：

Broker_Start_EnvSet

• step3: 启动Broker,如下图所示:

Broker_start_success

3.3 测试案例

• 3.1 step1: 展开example模块，找到quickstart包，指定生产者和消费者的NamesrvAddr,如下图所示：

Modified-quick-start-example

• 3.2 step2: 通过后台管理控制台查看集群中的Topic,Cluster,Consumer,Producer信息，

• 集群Cluster查询,如下图所示

RocketMQ-Cluster-Query

• 主题查询,如下图所示

RocketMQ-Topic-Query

• 消息查询,如下图所示

RocketMQ-Message-Query

• 消息消费详情,如下图所示

RocketMQ-Consumer-Detail

• 消费者组查询,如下图所示

RocketMQ-Consumergroups

结束语

本篇主要是源代码包结构分析，并且本地将RocketMQ的相关组件在本地启动并配合Console来进行消息的管理。相信通过本篇的学习，小伙伴们都能够在本地将RocketMQ源码运行的环境给跑起来了。

欢迎关注 @IT码农职场圈 ，你的认可将会是我持续的动力，希望和大家一起迈向架构师的彼岸，共同成长！