RocketMQ源码环境搭建运行

下载源码

使用git

git clone https://github.com/apache/rocketmq.git

或者自行下载zip

https://github.com/apache/rocketmq

使用IDEA打开，等待加载完毕…

文件配置

在项目根路径下增加conf目录

从distribution拷贝，broker.conf、logback_broker.xml、logback_namesrv.xml三个文件到根目录下的conf目录中

修改conf目录下的配置

1.修改broker.conf配置,增加如下配置

#nameServer 地址，用逗号隔开
namesrvAddr=127.0.0.1:9876

#存储路径
stroePathRootDir=D:\workspace\temp\data
#commitLog存储路径
storePathCommitLog=D:\workspace\temp\commitlog
#消费队列存储路径
storePathConsumeQueue=D:\workspace\temp\consumequeue
#消息索引存储路径
storePathIndex=D:\workspace\temp\data\index
#checkpoint 文件存储路径
sotreCheckpoint=D:\workspace\temp\data\checkpoint
#abort 文件存储路径
abortFile=D:\workspace\temp\data\abort

2.修改logback_broker.xml文件

将${user.home} 环境变量替换成上述目录D:\workspace\temp

3.启动nameserver，并添加ROCKETMQ_HOME:“项目路径”

namesrv下有个NamesrvStartup启动类。

启动成功看到如下打印

4.启动BrokerStartup

添加环境变量ROCKETMQ_HOME:“项目路径”

添加启动参数 -c 上面配置的conf/broker.conf目录地址

broker有个BrokerStartup启动类

启动成功看到如下打印

The broker[broker-one, 192.168.50.4:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876

进行测试

rocketmq提供给我们了一个快速测试用例 rocketmq-example,我们打开找到

org.apache.rocketmq.example.quickstart.Product

可以看到注释，我们需要指定我们自己的name server的地址，因此添加

​

producer.setNamesrvAddr("127.0.0.1:9876");

启动main方法。看到如下。

到此成功！