1、通过IDEA使用git下载源码
到RocketMq官网指定的GitHub路径获取下载链接
https://github.com/apache/rocketmq
获取下载源码路径
使用IDEA自带的Git进行下载源码
执行编译打包
2、RocketMq模块分化
名称 作用
broker broker模块:c和p端消息存储逻辑
client 客户端api:produce、consumer端 接受与发送api
common 公共组件:常量、基类、数据结构
tools 运维tools:命令行工具模块
store 存储模块:消息、索引、commitlog存储
namesrv 服务管理模块:服务注册topic等信息存储
remoting 远程通讯模块:netty+fastjson
logappender 日志适配模块
example Demo列子
filtersrv 消息过滤器模块
srvutil 辅助模块
filter 过滤模块:消息过滤模块
distribution 部署、运维相关zip包中的代码
openmessaging 兼容openmessaging分布式消息模块
(注意:标注红色的是重点模块,黄色的是非重要模块)
3、RocketMq集群模式
1、单机模式
2、双主模式:两个主节点,不存在从节点
3、双主双从(同步&异步):两个主节点,两个从节点;可以是同步或者是异步的形式
4、多主多从(同步&异步):多个主节点,多个从节点;可以是同步或者是异步的形式