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读写分离机制

 

标签：存储,流程,技术,路由,rocketmq,内幕,机制,rocketMq,消息
来源： https://www.cnblogs.com/likeloves/p/14729938.html