RocketMQ之消息刷盤和讀取

    上篇我介紹了RocketMQ消息存儲結構,那Producer是怎麼把消息存到文件中,Consumer怎麼讀取數據呢? Producer消息刷盤 消息在通過Producer寫入RocketMQ的時候,有兩種寫磁盤方式,分佈式同步刷盤和異步刷盤。 1、同步刷盤(更安全,不會丟消息) 在返回寫成功狀態時,消息已經被寫入磁盤。具體流程是: 消息從socket 進入java 堆 消息寫入PAGECA
相關文章
相關標籤/搜索