RocketMQ 源码分析 05 消息存储

 Broker 接收到生产者发送消息请求后如何存储在 Broker 上  核心实现类DefaultMessageStore 先看核心方法putMessage 1.校验不能是slave,只允许写master 2.校验message store是可写的 3.校验mq的topic长度不能超过最大限制 4.校验mq属性不能过长 5.检测操作系统页写入是否繁忙 6.将日志写入CommitLog 文件,具体实
相关文章
相关标签/搜索