皮皮网

1.搭建源码调试环境—RocketMQ源码分析（一）
2.win平台RocketMQ基于JDK17安装
3.RocketMQ-Broker模块解析之Broker初始化以及启动

搭建源码调试环境—RocketMQ源码分析（一）

       搭建源码调试环境，启动n启深入分析 RocketMQ 的源码内部运行机制。理解 RocketMQ 的动失目录结构是搭建调试环境的第一步，有助于我们快速定位代码功能和问题。启动n启

       目录结构主要包括：

       acl：权限控制模块，源码用于指定话题权限，动失松下蓝光机源码确保只有拥有权限的启动n启消费者可以进行消费。

       broker：RocketMQ 的源码核心组件，负责接收客户端发送的动失消息、存储消息并传递给消费端。启动n启

       client：包含 Producer、源码Consumer 的动失lifecycle源码代码，用于消息的启动n启生产和消费。

       common：公共模块，源码提供基础功能和服务。动失

       distribution：部署 RocketMQ 的工具，包含 bin、conf 等目录。

       example：提供 RocketMQ 的示例代码。

       filter：消息过滤器。

       namesvr：NameServer，所有 Broker 的注册中心。

       remoting：远程网络通信模块。shopro 源码

       srvutil：工具类。

       store：消息的存储机制。

       style：代码检查工具。

       tools：命令行监控工具。

       获取 RocketMQ 源码：从 Github 下载最新版本或选择其他版本。遇到下载困难时，可留言或私信寻求帮助。

       导入源码到 IDE 中，确保 Maven 目录正确，刷新并等待依赖下载完成。

       启动 RocketMQ 的drgs 源码 NameServer 和 Broker，配置相关参数，如环境变量、配置文件等。确保正确启动后，通过查看启动日志检查运行状态。

       进行消息生产与消费测试，使用源码自带的示例代码进行操作。设置 NameServer 地址后，启动 Producer 和 Consumer，验证消息成功发送与消费。

       使用 RocketMQ Dashboard 监控 RocketMQ 运行情况，knime源码持续优化和调试。

win平台RocketMQ基于JDK安装

       RocketMQ基于jdk的win安装。

        1、修改runbroker.cmd、runserver.cmd、tools.cmd三个启动脚本，如下：

        runbroker.cmd

        runserver.cmd

        tools.cmd

        2、设置win的环境变量 ROCKETMQ_HOME、NAMESRV_ADDR，因为jdk删除了jre模块，使用classpath方式进行加载。将rocketMQ的lib依赖，一个一个怼进去。因为包很多，win的环境变量值长度限制，分了两个变量进行拼接。RCTMQ_LIB、RCTMQ_LIB_EXT，然后将这两变量，放到CLASSPATH后。

        ROCKETMQ_HOME

        NAMESRV_ADDR

        RCTMQ_LIB

        RCTMQ_LIB_EXT

        最后将RCTMQ_LIB、RCTMQ_LIB_EXT放到CLASSPATH后面

        3、启动rocketMQ。先启动bin目录下的mqnamesrv.cmd，再启动mqbroker.cmd

        mqbroker.cmd启动命令：

RocketMQ-Broker模块解析之Broker初始化以及启动

       RocketMQ物理架构中，Broker服务器扮演关键角色，负责消息的存储、投递、查询，并保障服务高可用性。其核心功能基于几个重要子模块实现。

       消息存储(MessageStore)是Broker服务器的核心功能，旨在确保消息存储的可靠性与高效性，支持读写操作。

       请求处理器(Processor)封装了Broker对外提供的能力，包括消息发送、拉取、查询、事务消息处理等。

       定时调度服务(scheduleAtFixedRate)用于方便地统计和维护Broker服务状态。

       HA高可用服务(HAservice)通过主从同步实现，确保从Broker能同步主Broker的消息。

       文章聚焦于Broker服务的初始化与启动，通过源码解析，清晰展示初始化流程及加载资源的方式。

       BrokerStartup作为启动脚本调用入口，通过调用createBrokerController方法创建BrokerController对象，执行初始化。

       createBrokerController方法执行多个步骤，包括加载配置文件、初始化依赖对象、设置主从节点及HA监听端口等。

       初始化工作主要涉及命令行参数解析、校验NamesrvAddr、创建BrokerController、加载队列信息、设置资源及配置文件、初始化默认存储模块和Netty服务、注册请求处理器、开启定时任务、初始化事务消息服务及权限管理。

       在创建完毕BrokerController后，调用initialize方法进行初始化工作，完成Broker服务器持久化存储资源的加载、配置默认存储模块、初始化Netty服务、启动线程池并关联处理器、开启定时任务、初始化事务消息服务等。

       随后，通过调用start方法启动Broker服务，开启接收客户端请求。

       至此，Broker初始化及启动过程解析完毕，涉及内容广泛，文章仅对重要模块进行了简要解释，后续文章将进一步拆解各个子模块，共同深入学习。