【RocketMQ源码学习】RocketMQ源码学习之环境搭建

RocketMQ是开源的。

git地址：https://github.com/apache/rocketmq

注意：依赖环境：

JDK1.8+；maven；idea.

从git检出源码后，源码目录结构：

将源码导入到idea后，执行下面命令：

clean install -Dmaven.test.skip =true

源码调试：

需求：我们基于源码来实现一个消息发送和消息消费。

我们知道，正常RocketMQ部署顺序：启动NameServer、启动Broker、启动生成、启动消费者、发送消息，消费消息。

在进行源码调试之前，先在源码工程创建conf配置文件夹，配置信息从distribution拷贝brokrer.conf和logback_broker.xml及logback_namesrv.xml这三个文件到conf目录。

设置rocketmq的环境变量。不然会出现以下错误：

为什么要甚至rocketmq的环境变量ROCKETMQ_HOME呢？

因为rocketmq在运行的时候，需要从conf文件夹下获取配置及打印日志。查找这些都是从ROCKETMQ_HOME开始查找的。如果没有配置就会报错。

在idea中配置ROCKETMQ_HOME步骤如下：

在Edit Configuations中配置。点击：

在Environment variables中设置环境变量：

配置完成之后，在启动nameService.

启动nameServer源码：

启动broker

消息消费