推荐学习消息中间件合集：MQ（ActiveMQ/RabbitMQ/RocketMQ）+Kafka+笔记 真真香！耗时大半个月收整全套「Java架构进阶pdf」没白费 源码构建

首先，分享出rocketMQ相关资料：

项目地址：

中文文档：

1.clone

源码本地化构建肯定是clone啦，大家都明白。

命令 ： git clone

或者大家可以使用idea直接New->Version Control

2. 构建

项目克隆结束以后，输入命令构建：mvn clean install -U -DskipTests

但是但是~会那么轻松让我们构建成功吗？？哈哈，惊喜终于来了—[ERROR]

解决方案

Error:不再支持源选项 6。请使用 7或更高版本。

修改pom.xml文件中plugin

<plugin>      <groupId>org.apache.maven.plugins</groupId>      <artifactId>maven-compiler-plugin</artifactId>      <version>3.5.1</version>      <configuration>       <source>1.8</source>       <target>1.8</target>      </configuration></plugin>

修改结束，再次输入上面的构建命令，静静地等待构建、下载依赖等～

3.配置

构建完成之后，下面开始着手配置项。

3.1配置namesrv

具体设置如图：

这里最重要的一步就是设置环境变量：

ROCKETMQ_HOME=/Users/***/rocketmq

目录结构根据自己实际情况新建文件夹，后面会用到(本文中溪源以rocketmq为例)。

3.2新建文件夹

以下新建文件夹与上面配置的环境变量目录保持一致，例如：/Users/***/rocketmq，以下目录均基于rocketmq目录建立。

rocketmq中新建conf、store、logs配置conf

将distribution目录中conf中的broker.conf、logback_broker.xml、logback_namesrv.xml文件复制到上一步新建文件夹conf中。

修改broker.conf文件

修改上步复制的broker.conf文件。新增属性值：将该文件中的存放路径需要改成自己配置的路径。

brokerClusterName = DefaultClusterbrokerName = broker-abrokerId = 0deleteWhen = 04fileReservedTime = 48brokerRole = ASYNC_MASTERflushDiskType = ASYNC_FLUSH##以下属于自己新增配置项#nameserAddr地址，集群用分号；分割namesrvAddr=127.0.0.1:9876#存储路径storePathRootDir=/Users/***/rocketmq/store#commitLog存储路径storePathCommitLog=/Users/***/rocketmq/store/commitLog#消息队列存储路径storePathConsumeQueue=/Users/***/rocketmq/store/consumeQueue#消息索引存储路径storePathIndex=/Users/***/rocketmq/store/index#checkPoint文件存储路径storeCheckpoint=/Users/***/rocketmq/store/checkpoint#abort文件存储路径abortFile=/Users/***/rocketmq/store/abort

需要${user.home}替换成自己上一步配置的文件夹路径；例如/Users/***/rocketmq/。3.3 配置brokerprogram参数：-c /Users/***/rocketmq/conf/broker.conf环境变量：ROCKETMQ_HOME=/Users/***/rocketmq

以上路径均属于上面自定义配置文件路径。

具体配置如图：

3.4 配置producer3.5 配置 consumer4.启动

经历上面的一番配置后，最后一步就是启动生产者和消费者啦。

先提前说一下启动顺序：

启动org.apache.rocketmq.namesrv.NamesrvStartup启动org.apache.rocketmq.broker.BrokerStartup启动生产者org.apache.rocketmq.example.quickstart.Producer启动消费者org.apache.rocketmq.example.quickstart.Consumer

如图：消费者已经成功消费消息

到此，源码本地化构建已经成功啦，接下来就是熟悉rocketmq中的各种机制啦～

作者：溪~源

原文链接：