rocketmq源码系列(1)-快速debug启动rocketm

    概述

    很久之前就想写一篇关于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来启动项目