【RocketMQ源码】一、源码下载和安装

淩亂°似流年 2023-02-26 04:19 25阅读 0赞

**目录**

一、项目搭建和测试

1.1 代码拉取

1.2 源码结构目录

1.3 下载 Maven 依赖

1.4 调试

1.4.1 新建conf文件夹

1.4.2 NameSrv 启动

1.4.3 BrokerSrv 启动

1.4.4 快速测试

--------------------

# 一、项目搭建和测试 #

## 1.1 代码拉取 ##

从官方仓库拉取： [https://github.com/apache/rocketmq][https_github.com_apache_rocketmq]

百度网盘：链接：[https://pan.baidu.com/s/11gDiQ41LFRdpl03q\_l8\_xw ][https_pan.baidu.com_s_11gDiQ41LFRdpl03q_l8_xw]  提取码：pjd8

## 1.2 源码结构目录 ##

<table style="width:500px;"> 
 <tbody> 
 <tr> 
 <td>目录名称</td> 
 <td>作用</td> 
 </tr> 
 <tr> 
 <td>broker</td> 
 <td>broker 模块（broke 启动进程）</td> 
 </tr> 
 <tr> 
 <td>client </td> 
 <td>消息客户端，包含消息生产者、消息消费者相关类</td> 
 </tr> 
 <tr> 
 <td>common </td> 
 <td>公共包</td> 
 </tr> 
 <tr> 
 <td>dev </td> 
 <td>开发者信息（非源代码）</td> 
 </tr> 
 <tr> 
 <td>distribution</td> 
 <td>部署实例文件夹（非源代码）</td> 
 </tr> 
 <tr> 
 <td>example</td> 
 <td>RocketMQ 例代码</td> 
 </tr> 
 <tr> 
 <td>filter </td> 
 <td>消息过滤相关基础类</td> 
 </tr> 
 <tr> 
 <td>filtersrv</td> 
 <td>消息过滤服务器实现相关类（Filter启动进程）</td> 
 </tr> 
 <tr> 
 <td>logappender</td> 
 <td>日志实现相关类</td> 
 </tr> 
 <tr> 
 <td>namesrv</td> 
 <td>NameServer实现相关类（NameServer启动进程）</td> 
 </tr> 
 <tr> 
 <td>openmessageing</td> 
 <td>消息开放标准</td> 
 </tr> 
 <tr> 
 <td>remoting</td> 
 <td>远程通信模块，给予Netty</td> 
 </tr> 
 <tr> 
 <td>srcutil</td> 
 <td>服务工具类</td> 
 </tr> 
 <tr> 
 <td>store</td> 
 <td>消息存储实现相关类</td> 
 </tr> 
 <tr> 
 <td>style</td> 
 <td>checkstyle相关实现</td> 
 </tr> 
 <tr> 
 <td>test</td> 
 <td>测试相关类</td> 
 </tr> 
 <tr> 
 <td>tools</td> 
 <td> 工具类，监控命令相关实现类 </td> 
 </tr> 
 </tbody> 
</table>

# #

## 1.3 下载 Maven 依赖 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70][]

# 填入命令，并回车
    mvn clean install -Dmaven.test.skip=true

## 1.4 调试 ##

### 1.4.1 新建conf文件夹 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 1][]

### 1.4.2 NameSrv 启动 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 2][]

此时提示：

![20200714093656632.png][]

即需要为 RocketMQ 配置环境变量

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 3][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 4][]

![20200714093818938.png][]

### 1.4.3 BrokerSrv 启动 ###

新建 data 文件夹，位置自定义，用于存储 broker 数据

修改 config 文件夹下的 broker.conf 文件

brokerClusterName = DefaultCluster
    brokerName = broker-a
    brokerId = 0
    # namesrvAddr地址
    namesrvAddr=127.0.0.1:9876
    deleteWhen = 04
    fileReservedTime = 48
    brokerRole = ASYNC_MASTER
    flushDiskType = ASYNC_FLUSH
    autoCreateTopicEnable=true
    
    #### 配置为上面设置的文件夹路径
    # 存储路径
    storePathRootDir=E:\\project\\rocketmq\\rocketmq-master\\data\\dataDir
    # commitLog路径
    storePathCommitLog=E:\\project\\rocketmq\\rocketmq-master\\data\\dataDir\\commitlog
    # 消息队列存储路径
    storePathConsumeQueue=E:\\project\\rocketmq\\rocketmq-master\\data\\dataDir\\consumequeue
    # 消息索引存储路径
    storePathIndex=E:\\project\\rocketmq\\rocketmq-master\\data\\dataDir\\index
    # checkpoint文件路径
    storeCheckpoint=E:\\project\\rocketmq\\rocketmq-master\\data\\dataDir\\checkpoint
    # abort文件存储路径
    abortFile=E:\\project\\rocketmq\\rocketmq-master\\data\\dataDir\\abort

**找到 broker 项目，启动项目**

![20200714094445776.png][]

发现又要配置环境变量，配置方式与 1.4.2 相同

![20200714094506111.png][]

设置引用的配置文件：

-c E:\project\rocketmq\rocketmq-master\conf\broker.conf

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 5][]

**启动项目**

![20200714094936735.png][]

### 1.4.4 快速测试 ###

找到 example 项目下的 quickstart

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 6][]

修改启动文件，配置 namesrv 服务地址

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 7][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 8][]

先启动 Producer

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 9][]

再启动 Consumer 消费

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 10][]

[https_github.com_apache_rocketmq]: https://github.com/apache/rocketmq
[https_pan.baidu.com_s_11gDiQ41LFRdpl03q_l8_xw]: https://pan.baidu.com/s/11gDiQ41LFRdpl03q_l8_xw%C2%A0
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70]: /images/20230209/4f9eeb11c7a24332ab30569979269106.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 1]: /images/20230209/0f0b8feab4764b0f9ab6503f7c6c112e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 2]: /images/20230209/822a8e91b3ed4fc799c62760e1a02d9f.png
[20200714093656632.png]: /images/20230209/47b718e177b94d5f9abe283c40a33e26.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 3]: /images/20230209/d06bcd0360a1408293d28a0f6a91b642.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 4]: /images/20230209/6a5b26dd5e374c8f885dafeacd28cb4f.png
[20200714093818938.png]: /images/20230209/783f71c7a0f843a3a51374bc3f1370b0.png
[20200714094445776.png]: /images/20230209/ed15bb05376848bea775d54b2f37f583.png
[20200714094506111.png]: /images/20230209/647cbc7d083b48988bcdb142fab62d01.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 5]: /images/20230209/ce18e66905884e02b242b15249e9da86.png
[20200714094936735.png]: /images/20230209/9929e4d152b6450085e624ec288f4435.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 6]: /images/20230209/7950c41053b4468a90745a6d3ba859e8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 7]: /images/20230209/a69e449228f74b9d9d0f7689d7bf29eb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 8]: /images/20230209/a360549d804c47359c270def95d6e950.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 9]: /images/20230209/cfc835eb6ec44e89888ccfd5f0d5bb57.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0NDE2MzMx_size_16_color_FFFFFF_t_70 10]: /images/20230209/66f970a5a56341a6a5169912e6b78589.png