ROCKETMQ技术内幕
ROCKETMQ技术内幕
1.rocketMq路由中心
nameServer架构设计:
防止broker节点异常，不重启服务得情况下感知异常，以及发送到哪台服务。
nameServer启动流程：
nameServer路由注册/故障删除：
每隔30秒broker向nameserver发送心跳包更新lastUpdateTimestamp，nameserver 每次间隔10秒扫描lastUpdateTimeStamp，如果120秒没有收到，则关闭socket连接。
路由删除：
a扫描得情况下
b正常关闭前，注销。
路由发现：
2.rocketMq消息发送：
生产者启动流程
初识defaultMqProducer
生产者发送流程
批量消息发送
3.rocketMq消息存储
存储概要设计
初识消息存储
消息存储流程
存储文件组织与内存映射
rocketMq存储文件
实时更新消息队列与索引
消息队列与索引文件恢复
文件刷盘机制
过期文件删除机制
4.rocketMq消息消费
消费者启动流程
消息拉取
消息队列负载与重新分布机制
消息消费过程
定时消息机制
过滤消息机制
顺序消息
5.消息过滤filterServer
ClassFilter运行机制
FilterServer注册剖析
类过滤模式订阅机制
消息拉取
6。rocketMq主从同步机制
rocketMq主从同步原理
rocketMq读写分离机制
来源：https://www.cnblogs.com/likeloves/p/14729938.html