從RocketMQ源碼的Store模塊分析RocketMQ

前言 前幾篇都是基於RockeMQ的工具類的源碼來分析其架構，功能等，本節從RocketMQ的存儲方面來分析，RocketMQ是如何實現回調，高可用的，這裏引入一篇總結不錯的文章. 消息追加的回調方法AppendCallback 這個的追加的消息體分爲批量的以及單一的消息體兩種方式，都是實現了MessageExt類，而MessageExt繼承了Message的基類，包括定義了消息的offset，q

>>阅读原文<<