RocketMQ之消息刷盘和读取

    上篇我介绍了RocketMQ消息存储结构,那Producer是怎么把消息存到文件中,Consumer怎么读取数据呢? Producer消息刷盘 消息在通过Producer写入RocketMQ的时候,有两种写磁盘方式,分布式同步刷盘和异步刷盘。 1、同步刷盘(更安全,不会丢消息) 在返回写成功状态时,消息已经被写入磁盘。具体流程是: 消息从socket 进入java 堆 消息写入PAGECA
相关文章
相关标签/搜索