RocketMQ学习第一步之源码构建

这里写目录标题绪论源码构建1.clone2. 构建3.配置3.1配置namesrv3.2新建文件夹3.3 配置broker3.4 配置producer3.5 配置 consumer4.启动

绪论

最近溪源在学习dubbo的相关API机制实践,如:负载均衡、服务分组、本地存根等等…一方面是dubbo官网文档给出了详细的介绍和demo,另一方面由于自己时间方面原因(自己现在也需要学习各种技术栈),没有整理相关实践总结。但是后面一定会整理出相关的实践总结。
今天主要给大家介绍一下rocketmq源码本地化构建,也是由于溪源项目中暂时未使用该技术栈,如果自己想要学习和精进,那只能阅读一下源码和了解相关机制啦!
好啦好啦~不再絮叨啦,无实际作用,下面进入今天的正题。

源码构建

首先,分享出rocketMQ相关资料:
项目地址:https://github.com/apache/rocketmq
中文文档:https://github.com/apache/rocketmq/tree/master/docs/cn
RocketMQ学习第一步之源码构建

1.clone

源码本地化构建肯定是clone啦,大家都明白。
命令 : git clone https://github.com/apache/rocketmq.git
或者大家可以使用idea直接New->Version Control
RocketMQ学习第一步之源码构建

2. 构建

项目克隆结束以后,输入命令构建:mvn clean install -U -DskipTests
但是但是~会那么轻松让我们构建成功吗??哈哈,惊喜终于来了—[ERROR]
RocketMQ学习第一步之源码构建

解决方案
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>

RocketMQ学习第一步之源码构建
修改结束,再次输入上面的构建命令,静静地等待构建、下载依赖等~
RocketMQ学习第一步之源码构建

3.配置

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

3.1配置namesrv

RocketMQ学习第一步之源码构建
具体设置如图:
RocketMQ学习第一步之源码构建
这里最重要的一步就是设置环境变量:
ROCKETMQ_HOME=/Users/***/rocketmq
目录结构根据自己实际情况新建文件夹,后面会用到(本文中溪源以rocketmq为例)。

3.2新建文件夹

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

    rocketmq中新建conf、store、logs
    RocketMQ学习第一步之源码构建

    配置conf
    RocketMQ学习第一步之源码构建
    将distribution目录中conf中的broker.conf、logback_broker.xml、logback_namesrv.xml文件复制到上一步新建文件夹conf中。

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

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = 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

    修改logback_namesrv.xml配置:
    需要${user.home}替换成自己上一步配置的文件夹路径;例如/Users/***/rocketmq/
    RocketMQ学习第一步之源码构建

3.3 配置broker

    program参数:-c /Users/***/rocketmq/conf/broker.conf

    环境变量:ROCKETMQ_HOME=/Users/***/rocketmq

以上路径均属于上面自定义配置文件路径。
具体配置如图:
RocketMQ学习第一步之源码构建

3.4 配置producer

RocketMQ学习第一步之源码构建

3.5 配置 consumer

RocketMQ学习第一步之源码构建

4.启动

经历上面的一番配置后,最后一步就是启动生产者和消费者啦。
先提前说一下启动顺序:

    启动org.apache.rocketmq.namesrv.NamesrvStartup
    启动org.apache.rocketmq.broker.BrokerStartup
    启动生产者org.apache.rocketmq.example.quickstart.Producer
    启动消费者org.apache.rocketmq.example.quickstart.Consumer
    如图:消费者已经成功消费消息
    RocketMQ学习第一步之源码构建
    到此,源码本地化构建已经成功啦,接下来就是熟悉rocketmq中的各种机制啦~

原创:https://www.panoramacn.com
源码网提供WordPress源码,帝国CMS源码discuz源码,微信小程序,小说源码,杰奇源码,thinkphp源码,ecshop模板源码,微擎模板源码,dede源码,织梦源码等。

专业搭建小说网站,小说程序,杰奇系列,微信小说系列,app系列小说

RocketMQ学习第一步之源码构建

免责声明,若由于商用引起版权纠纷,一切责任均由使用者承担。

您必须遵守我们的协议,如果您下载了该资源行为将被视为对《免责声明》全部内容的认可-> 联系客服 投诉资源
www.panoramacn.com资源全部来自互联网收集,仅供用于学习和交流,请勿用于商业用途。如有侵权、不妥之处,请联系站长并出示版权证明以便删除。 敬请谅解! 侵权删帖/违法举报/投稿等事物联系邮箱:2640602276@qq.com
未经允许不得转载:书荒源码源码网每日更新网站源码模板! » RocketMQ学习第一步之源码构建
关注我们小说电影免费看
关注我们,获取更多的全网素材资源,有趣有料!
120000+人已关注
分享到:
赞(0) 打赏

评论抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

您的打赏就是我分享的动力!

支付宝扫一扫打赏

微信扫一扫打赏