一、消息存储核心类      

          rocketmq消息存储的功能主要在store这个模块下。

        核心类就是DefaultMessageStore。我们看下其属性

// 配置文件
private final MessageStoreConfig messageStoreConfig;

 

// CommitLog 文件存储实现类
private final CommitLog commitLog;

 

// topic和comsumeQueue的对应关系
private final ConcurrentMap<String/* topic */, ConcurrentMap<Integer/* queueId */, ConsumeQueue>> consumeQueueTable;

// 文件刷盘线程
private final FlushConsumeQueueService flushConsumeQueueService;

// 清除CommitLog文件的线程
private final CleanCommitLogService cleanCommitLogService;

// 清除ConsumeQueue文件的线程
private final CleanConsumeQueueService cleanConsumeQueueService;

// 维护索引文件的服务
private final IndexService indexService;

// MappedFi