RocketMQ源码解读：Broker如何实现过期消息自动清理？

本文共计1794个文字，预计阅读时间需要8分钟。

目录前言Broker消息清理机制简介Broker与消息清理相关配置消息清理机制源码分析CommitLog清理源码分析ConsumeQueue和IndexFile清理源码分析ConsumeQueue文件清理IndexFile清理总结前言前面

目录

• 前言
• Broker消息清理机制简介
• Broker与消息清理相关配置
• 消息清理机制源码分析
• CommitLog清理源码分析
• ConsumeQueue和IndexFile清理源码分析
• ConsumeQueue文件清理
• IndexFile清理
• 总结

前言

前面文章讲了消息是如何保存的以及consumeQueue与Index文件更新机制。随着消息的增加，Broker不可能一直保存所有消息，Broker是按照什么规则清理消息的呢？被消费过后的消息就会被清理掉吗？下面我们来介绍Broker消息清理机制。

Broker消息清理机制简介

消息是被顺序存储在CommitLog文件中的，且消息长度不定长，因此消息的清理不是以消息为单位进行的，而是以CommitLog为单位进行的。