rocketmq源码调试

一，环境搭建 1 启动nameServer

1.启动存在问题

启动类

 报错

需要进行2，3

2.添加配置

在项目下创建文件conf，并拷贝配置文件到该目录下

配置文件在哪找

3.配置环境变量

为什么添加：让系统找到2步骤中配置

 

 name 上面报错中有提示：ROCKETMQ_HOME

value 源码路径

2 启动broker

1.修改broker配置文件，添加数据保存路径，不添加保存在默认位置

自定义文件生成路径

添加配置，如下图

-c D:rocketmqconfbroker.conf   -c  broker.conf路径

2.注意

namesrvAddr=127.0.0.1:9876  配置

启动成功

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

3.调试

生产者与消费者，启动可以看消息发送与消费

二，nameServer 1.架构设计

2.NameServer作用
主要作用为消息生产者和消息消费者提供关于topic路由信息，维护存储，注册，删除路由信息，管理broker节点。 3.启动

4.路由管理 

RouteInfoManager

路由元数据

路由注册，broker启动向nameServer注册

 发送心跳，通过定时任务，broker每隔30s向nameServer发送注册信息

 处理心跳

路由删除

nameServer120检查broker信息是否存在，删除

路由发现

 小结：

三，生产者

主要方法

 属性

 启动

DefaultMQProducer

 启动生产者具体实现

DefaultMQProducerImpl