概述
很久之前就想写一篇关于rocketmq的源码解析了，那从哪一点开始写呢？思考了很久还是打算从快速启动rocketmq开始写起，原因是后续所有rocketmq源码系列解读和结论，都需要启动rocketmq去实际验证阅读源码所得结论的正确性的
安装说明
本rocketmq系列为4.9.1版本源码阅读
1、下载源码
git上下载地址：https://github.com/apache/rocketmq.git
项目目录：
2、启动nameserve
1）修改java_home配置：
修改两个配置文件：把第一行JAVA_HOME的地址改为本地安装的jdk地址，把第二第三行注释掉。
/Users/dwq/work_new/rocketmq/distribution/bin/runbroker.sh
/Users/dwq/work_new/rocketmq/distribution/bin/runserver.sh
[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/Library/Java/JavaVirtualMachines/jdk1.8.0_181.jdk/Contents/Home
#[ ! -e "$JAVA_HOME/bin/java" ] && JAVA_HOME=/usr/java
#[ ! -e "$JAVA_HOME/bin/java" ] && error_exit "Please set the JAVA_HOME variable in your
2）启动命令中添加配置：NamesrvStartup启动类
注：路径改为rocketmq项目对应路径
ROCKETMQ_HOME=/Users/dwq/work_new/rocketmq/distribution
3）启动成功nameser
3、启动broker
1）配置启动类：org.apache.rocketmq.broker.BrokerStartup
配置nameserver注册中心地址：-Drocketmq.namesrv.addr=localhost:9876
配置ROKETMQ_HOME:/Users/dwq/work_new/rocketmq/distribution
注：注册中心地址默认是localhost:9876,ROKETMQ_HOME地址改为本地对应的roketmq源码地址
2）启动成功
这样一个rocketmq服务端就启动成功了
下面我们来测试一下生产/订阅消息
4、生产消息
1、配置启动变量
org.apache.rocketmq.example.quickstart.Producer
配置nameserver注册中心地址：-Drocketmq.namesrv.addr=localhost:9876
配置ROKETMQ_HOME:/Users/dwq/work_new/rocketmq/distribution
2、消息发送成功
5、消费消息
1）配置启动变量
org.apache.rocketmq.example.quickstart.Consumer
配置nameserver注册中心地址：-Drocketmq.namesrv.addr=localhost:9876
配置ROKETMQ_HOME:/Users/dwq/work_new/rocketmq/distribution
2）消费成功
这样一个本地可以debug的rocketmq就启动完成了
注意：一定要按照步骤1->2->3->4-5来启动项目
网友评论