(一)调试RocketMq源码

﹏ヽ暗。殇╰゛Y 2023-07-21 06:25 8阅读 0赞

### 文章目录 ###

*   *   *   *  一.启动NameServer
             *  1.1namesrv模块找到NamesrvStartup.java
             *  1.2修改配置文件目录
             *  1.3启动NamesrvStartup.java
         *  二.配置Broker
         *   *  2.1配置BrokerStartup.java
             *  2.2启动BrokerStartup.java
         *  三.启动producer和consumer

#### 一.启动NameServer ####

#### 1.1namesrv模块找到NamesrvStartup.java ####

修改Environment variables 新增ROCKETMQ\_HOME  
![在这里插入2图片描述][2]

#### 1.2修改配置文件目录 ####

Rocketmq主目录新建conf logs storedata三个文件夹,将distribution的broker.conf logback\_broker.xml,logback\_namesrv.xml复制到conf,修改日志目录,和增加broker.conf

brokerClusterName = DefaultCluster
    brokerName = broker-a
    brokerId = 0
    deleteWhen = 04
    fileReservedTime = 48
    brokerRole = ASYNC_MASTER
    flushDiskType = ASYNC_FLUSH
    
    namesrvAddr=127.0.0.1:9876
    storePathRootDir=/Library/Java/MySpace/rocketmq/storedata
    storePathCommitLog=/Library/Java/MySpace/rocketmq/storedata/commitLog
    storePathConsumeQueue=/Library/Java/MySpace/rocketmq/storedata/consumequeue
    storePathIndex=/Library/Java/MySpace/rocketmq/storedata/index
    storeCheckpoint=/Library/Java/MySpace/rocketmq/storedata/checkpoint
    abortFile=/Library/Java/MySpace/rocketmq/storedata/abort

#### 1.3启动NamesrvStartup.java ####

正确输出

The Name Server boot success. serializeType=JSON

### 二.配置Broker ###

#### 2.1配置BrokerStartup.java ####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RyZG9uZ3NoaXll_size_16_color_FFFFFF_t_70]

#### 2.2启动BrokerStartup.java ####

The broker[broker-a, 10.253.16.161:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876

broker.log的日志信息  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RyZG9uZ3NoaXll_size_16_color_FFFFFF_t_70 1]

### 三.启动producer和consumer ###

org.apache.rocketmq.example.quickstart.Producer  
org.apache.rocketmq.example.quickstart.Consumer  
先修改NameServer地址 然后启动观察日志  
如果出现以下问题,需要在broker.conf配置brokerIP1=外网ip  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RyZG9uZ3NoaXll_size_16_color_FFFFFF_t_70 2]

[2]: /images/20230528/3f23b222079749cbbe96f5c7db8419e5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RyZG9uZ3NoaXll_size_16_color_FFFFFF_t_70]: /images/20230528/5cac270dbe24436395496be9f06d57ce.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RyZG9uZ3NoaXll_size_16_color_FFFFFF_t_70 1]: /images/20230528/1f40722a51d4464eb04adb05ae9df98c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2RyZG9uZ3NoaXll_size_16_color_FFFFFF_t_70 2]: /images/20230528/c60301cde0bd4d6ea7cab9e121cd7439.png