diff --git a/i18n/en/docusaurus-plugin-content-docs/version-5.0/04-featureBehavior/11messagestorepolicy.md b/i18n/en/docusaurus-plugin-content-docs/version-5.0/04-featureBehavior/11messagestorepolicy.md index c46c60e41b..13d7bcd642 100644 --- a/i18n/en/docusaurus-plugin-content-docs/version-5.0/04-featureBehavior/11messagestorepolicy.md +++ b/i18n/en/docusaurus-plugin-content-docs/version-5.0/04-featureBehavior/11messagestorepolicy.md @@ -51,6 +51,9 @@ Messages may be accumulated in a queue due to inactive consumers or abnormal con Consumers can manage messages based on storage duration to determine the lifecycle of each message. Consumers can consume a message any time during the storage duration, or consume the message multiple times by using the [Reset a consumer offset](./09consumerprogress.md) feature. +**Message Storage File Structure** +Apache RocketMQ messages are stored by default in local disk files, and the root directory of the storage files is determined by the configuration parameter storePathRootDir. The storage structure is shown in the following figure, where the commitlog folder stores the physical message files, the consumeCQueue folder stores the logical queue indexes. +![MessageStore](../picture/store.jpg) ## Message cleanup mechanism diff --git a/i18n/en/docusaurus-plugin-content-docs/version-5.0/picture/store.jpg b/i18n/en/docusaurus-plugin-content-docs/version-5.0/picture/store.jpg new file mode 100644 index 0000000000..150caadd54 Binary files /dev/null and b/i18n/en/docusaurus-plugin-content-docs/version-5.0/picture/store.jpg differ diff --git a/versioned_docs/version-5.0/04-featureBehavior/11messagestorepolicy.md b/versioned_docs/version-5.0/04-featureBehavior/11messagestorepolicy.md index 0dd6aded99..f55a339171 100644 --- a/versioned_docs/version-5.0/04-featureBehavior/11messagestorepolicy.md +++ b/versioned_docs/version-5.0/04-featureBehavior/11messagestorepolicy.md @@ -53,6 +53,10 @@ Apache RocketMQ 统一管理消息的存储时长,无论消息是否被消费 根据统一地存储时长管理消息,可以帮助消费者业务清晰地判断每条消息的生命周期。只要消息在有效期内可以随时被消费,或通过[重置消费位点](./09consumerprogress.md)功能使消息可被消费多次。 +**消息存储文件结构说明** + Apache RocketMQ 消息默认存储在本地磁盘文件中,存储文件的根目录由配置参数 storePathRootDir 决定,存储结构如下图所示,其中 commitlog 文件夹存储消息物理文件,consumeCQueue文件夹存储逻辑队列索引,其他文件的详细作用可以参考代码解析。 +![消息存储](../picture/store.jpg) + ## 消息过期清理机制 在 Apache RocketMQ中,消息保存时长并不能完整控制消息的实际保存时间,因为消息存储仍然使用本地磁盘,本地磁盘空间不足时,为保证服务稳定性消息仍然会被强制清理,导致消息的实际保存时长小于设置的保存时长。 diff --git a/versioned_docs/version-5.0/picture/store.jpg b/versioned_docs/version-5.0/picture/store.jpg new file mode 100644 index 0000000000..150caadd54 Binary files /dev/null and b/versioned_docs/version-5.0/picture/store.jpg differ