rocketmq源码阅读笔记(2)-源码调试

素颜马尾好姑娘i 2022-10-21 13:55 218阅读 0赞

### 文章目录 ###

*  参考文章
 *  视频
 *  调试

# 参考文章 #

RocketMq系列之Producer启动源码分析（一）

https://shared-code.com/article/130

RocketMq系列之Producer启动（一）

# 视频 #

https://www.bilibili.com/video/BV1RE411r75d?p=25&spm\_id\_from=pageDriver

# 调试 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70]  
安装跳过测试  
mvn clean install -Dmaven.test.skip=true  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 1]

启动nameserver  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 3]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 4]

启动broker

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

brocker.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=D:\\rocketMqTestData\\store
    #commitLog 存储路径
    storePathCommitLog=D:\\rocketMqTestData\\store\\commitlog
    #消费队列存储路径存储路径
    storePathConsumeQueue=D:\\rocketMqTestData\\store\\consumequeue
    #消息索引存储路径
    storePathIndex=D:\\rocketMqTestData\\store\\index
    #checkpoint 文件存储路径
    storeCheckpoint=D:\\rocketMqTestData\\store\\checkpoint
    #abort 文件存储路径
    abortFile=D:\\rocketMqTestData\\store\\abort

addr=“127.0.0.1:9876”;  
final Channel channel = this.getAndCreateChannel(addr);  
if (channel != null && channel.isActive()) \{

nameserver的地址： 172.30.36.123:9876

broker的地址： 172.30.36.123:10911

源码调试选择4.5.1，不要选择4.8.0等最新版本，这些版本的调试总会报些奇怪的错误

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 6]  
if (null == nsList || nsList.isEmpty()) \{  
nsList.add(“127.0.0.1:9876”);  
\}  
if (null == nsList || nsList.isEmpty()) \{  
throw new MQClientException(  
“No name server address, please set it.” + FAQUrl.suggestTodo(FAQUrl.NAME\_SERVER\_ADDR\_NOT\_EXIST\_URL), null).setResponseCode(ClientErrorCode.NO\_NAME\_SERVER\_EXCEPTION);  
\}

因为使用的是虚拟机，设置内存也只有1G，所以从 Windows 上开发连接 虚拟机中的 nameServer 时要经过 Linux 系统的防火墙，而防火墙一般都会有超时的机制，在网络连接长时间不传输数据时，会关闭这个 TCP 的会话，关闭后再读写，就有可能导致这个异常。

RemotingTooMuchRequestException: sendDefaultImpl call timeout

关闭window放火墙之后，错误变成  
Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to 172.30.36.123:9876 failed

消息队列采取的是发布订阅者模式  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 7]  
namesrv想到于注册中心的角色，它有心跳检测机制  
![在这里插入图片描述][20210506145108969.png]  
nameserver是接受请求并做出响应

我要消费信息，我需要到哪个broker中找，它会询问nameserve

心跳包，初始化

![在这里插入图片描述][20210506152038636.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 8]  
producer主动去拉，而不是nameserve主动推

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70]: /images/20221021/8a4045a948474581910a6633568e9d01.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 1]: /images/20221021/fef8540b958e48dea2030e2423f9b7c6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 2]: /images/20221021/24c3e1a10a4d40e5b833b7f2ffa8e950.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 3]: /images/20221021/8b040d5bd2de427b8b75e9f38cac8760.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 4]: /images/20221021/6b084e68699a4d0ebc2300a51098f8bf.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 5]: /images/20221021/8887ada268fd4de0a7f6e17402990d06.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 6]: /images/20221021/8d5ebbf62dcc4600bb0552247f513bb0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 7]: /images/20221021/de5f1e9705c64979956a6ddd3698df66.png
[20210506145108969.png]: /images/20221021/7c0a63dcbd6d405ab5b1b9806d14041b.png
[20210506152038636.png]: /images/20221021/8b3a7b6fe4d54f11bf6ca7a2209bc0e2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDYzMTQx_size_16_color_FFFFFF_t_70 8]: /images/20221021/8064ab03865341d08aa17225472ca56e.png