源码地址:https://github.com/apache/rocketmq.git
今天看提交记录,已经更新到4.5.1版本了,可以在release的版本中找到4.5.0的版本下载即可,也可以使用最新的版本进行相似的代码确认,学习为主,其他的都可以自由发挥。
本人的环境配置:
jdk:jdk1.8
os:mac
ide:idea
模块说明:
broker:broker模块 broker的核心启动管理
client:消息客户端,涉及消息的发送,消息的接受等
common:公共包,涉及配置,工具,协议等共享对象
dev:开发者,忽略
example:相关的事例代码
filter:消息的过滤相关的基础设计及类对象
logappender:基于日志的框架整合进rocketmq的通信
namesrv:namesrv的实现,服务启动,主要是服务注册中心及统一的topic管理
openmessaging:消息开发标准,基于标准的消息设计
remoting:内部核心通信设计,基于netty
srvutil:服务器工具
store:消息的存储实现核心
test:测试相关
tools:工具类,监控之类