43篇文章 · 14233字 · 15人关注
-
store模块阅读22:HA(1):HAConnection简介 部分涉及HAService的代码后面再讲 master和slave同步数据的协议如下 属性 函数 构造函数和状态处理函数比较简单 内部类 ...
-
store模块阅读20:CommitLog(4):MessageExtBatchEncoder以及批量消息的doAppend
说明 本节讲解批量消息(MessageExtBatch)的编码器，以及上一节没讲完了批量消息的doAppend方法 MessageExtBatc...
-
store模块阅读19: CommitLog(3): DefaultAppendMessageCallback
说明 这个是AppendMessageCallback的实现类,在前面讲过，参照refer用于处理追加消息记录(MessageExtBroker...
-
store模块阅读18：CommitLog(2): FlushCommitLogService的三个刷盘策略说明 这里讲解CommitLog内部类FlushCommitLogService以及其实现类CommitRealTimeService,Flus...
-
store模块阅读16：ConsumeQueue
说明 consume queue是消息的逻辑队列相当于字典的目录，用来指定消息在物理文件commit log上的位置。默认存储路径为{user....
-
store模块阅读15：ConsumeQueueExt
说明 这个是consumeQueue类的拓展，记录一些不重要的信息 在MessageStoreConfig#enableConsumeQueue...
-
store模块阅读14:Index子模块3:IndexService说明 这个类就是索引服务，提供查询key，根据key构建索引，加载IndexFile到内存，destroy过期的IndexFile等功能，UML...
-
store模块阅读13:Index子模块2:QueryOffsetResult
说明 这个类就是用来记录IndexFile中selectPhyOffset的结果的，进行了一层封装 源码 问题 暂时不知道为什么要indexLa...
-
store模块阅读12:Index子模块1：IndexHeader && IndexFile
概述 IndexFile由几个部分构成: IndexHeader 文件头(40字节)SlotTable 槽表(4字节500w记录)Index L...
文集作者