【RocketMQ源码学习】RocketMQ源码学习之环境搭建
- RocketMQ
- 时间:2022-10-20 13:07
- 5113人已阅读
简介
本文介绍rocket源码学习之环境搭建
🔔🔔🔔好消息!好消息!🔔🔔🔔
有需要的朋友👉:联系凯哥
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
消息消费