处理事务
SendMessageProcessor.processRequest()
各种检验
返回AppendMessageResult
ReputMessageService.doReput()
返回PutMessageResult
判断批量发送
CommitLog.putMessage()
选择最后一个mappedFile
复制了writebuffer
处理ha
DefaultAppendmessageCallback.doAppend()
1、如何保证重启后从相同而位置开始消费存储等2、
序列化消息
MessageStroe接口有两个重要的方法：1、从XXX加载以前存储的消息到XXX2、将消息从客户端put到内存中
putmessage
计算msgId
写入bytebuffer
根据结果更新wrotePosition
appendMessageInner
Mappedfile.appendMessage()
DefaultMessageStore.putMessage()
处理刷盘
MessageStroe
boolean load()void putMessage()
根据AppendMessageResult
N
todo:1、DefaultMessageStor的start方法何时停止2、构建Consume的过程是什么样的3、
storeStatService统计数据
消息存储
