调试RocketMQ源码

叁歲伎倆 2023-07-22 03:49 23阅读 0赞

1.  拷贝`namesrv`、`broker`的配置文件到指定目录，为了避免直接修改代码中的配置文件。  
    1.1 在F盘创建`rocketmq`文件夹，创建三个子文件夹`conf`、`logs`、`store`，我的代码中多了`dev data`的文件夹  
    1.2 将`distribution`源码`conf`目录下的`broker.conf`、`logback_broker.xml`、`logback_namesrv.xml`拷贝到新建的`conf`目录下  
    1.3 修改拷贝的`broker.conf`文件，如下所示，注意：一定要使用双斜杠`\\`或者使用单斜杠`/`，因为多了`dev data`文件夹，中间有空格
    
        brokerClusterName = DefaultCluster
        brokerName = broker-a
        brokerId = 0
        namesrvAddr=127.0.0.1:9876
        deleteWhen = 04
        fileReservedTime = 48
        brokerRole = ASYNC_MASTER
        flushDiskType = ASYNC_FLUSH
        storePathRootDir=F:\\dev data\\rocketmq\\store
        storePathCommitLog=F:\\dev data\\rocketmq\\store\\commitlog
        storePathConsumeQueue=F:\\dev data\\rocketmq\\store\\consumequeue
        storePathIndex=F:\\dev data\\rocketmq\\store\\index
        storeCheckpoint=F:\\dev data\\rocketmq\\store\\checkpoint
        abortFile=F:\\dev data\\rocketmq\\store\\abort
    
    1.4 修改`logback_namesrv.xml`和`logback_broker.xml`，将文件中的`${user.home}`改成你新建的`rocketmq`的目录，否则日志文件会在你`C`盘用户目录下创建  
    1.5 修改`logback_namesrv.xml`和`logback_broker.xml`中的`logger`，在`root`标签中引入`STDOUT`的`appender`，并把所有`logger`中的`additivity`改为`true`，这样所有日志才会在`idea`的`console`中打印，否则没有日志输出
    
        <root>
        	<level value="INFO"/>
        	<appender-ref ref="STDOUT"/>
        	……
        </root>
2.  启动`org.apache.rocketmq.namesrv.NamesrvStartup`，指定`Environment variables`的值：`ROCKETMQ_HOME=F:\\dev data\\rocketmq`  
    ![在这里插入图片描述][20200404151701566.png]
3.  启动`org.apache.rocketmq.broker.BrokerStartup`，指定`Program arguments`的值：`-c "F:\\dev data\\rocketmq\\conf\\broker.conf"`，指定`Environment variables`的值：`ROCKETMQ_HOME=F:\\dev data\\rocketmq`。注意：由于多了`dev data`文件夹，中间有空格，所以`Program arguments`加了双引号  
    ![在这里插入图片描述][20200404151811151.png]

[20200404151701566.png]: /images/20230528/c1d869ade54d497d83cb5077b2e24eef.png
[20200404151811151.png]: /images/20230528/b50b3a6fbfb34737b6281c9610b55bca.png