消息中间件RocketMQ原理解析 - 斩秋
............................................................................................. 43 6.4:Broker 与 client(comsumer ,producer)之间的心跳, ................................ 44 6.5:Broker 与 namesrv 计算消息跟文件头存储开始时间的时间差 根据消息头记录的存储消息个数计算消息索引存储的集体偏移量位置 写入真正的索引,内容参考上面索引内容格式 将槽位中的更新为此消息索引 更新索引头文件信息 6.4:Broker 与 client(comsumer ,producer)之间的心跳, 一: Broker 接收 client 心跳 ClientManageProcessor 处理 client0 码力 | 57 页 | 2.39 MB | 1 年前3RocketMQ v3.2.4 开发指南
......................................... 14 项目开源主页:https://github.com/alibaba/RocketMQ II 6.4 存储目彔结构 .......................................................................................... Offset、Key Offset、State(P/C/R) Offset、Delaylevel 项目开源主页:https://github.com/alibaba/RocketMQ 15 6.4 存储目录结构 |-- abort |-- checkpoint |-- config | |-- consumerOffset.json | |-- consumerOffset0 码力 | 52 页 | 1.61 MB | 1 年前3
共 2 条
- 1