整体的架构如下:
对应说明如下:
broker:broker的进程
client:消息客户端,对应的消费者类
common:公共包
dev:开发者信息(…..)
distribution:部署实例文件夹(部署小简介)
example:RocketMQ实例代码
filter:消息过滤基础类
filtersrv:消息过滤服务器相关实现类
logappender:日志相关实现
namesrc:NameServer相关类
openmessaging:消息开放标准
remoting:远程通信模块,基于Netty
srvutil:服务器工具类
store:消息存储实现相关类
style:checkstyle相关实现
test:测试类
tools:监控命令实现类