diff --git a/docs/rocketmq/rocketmq-commitlog.md b/docs/rocketmq/rocketmq-commitlog.md index 8a7c434..316f0b5 100644 --- a/docs/rocketmq/rocketmq-commitlog.md +++ b/docs/rocketmq/rocketmq-commitlog.md @@ -1,3 +1,5 @@ +该文所涉及的 RocketMQ 源码版本为 4.9.3。 + # RocketMQ CommitLog 详解 commitlog 目录主要存储消息，为了保证性能，顺序写入，每一条消息的长度都不相同，每条消息的前面四个字节存储该条消息的总长度，每个文件大小默认为 1G，文件的命名是以 commitLog 起始偏移量命名的，可以通过修改 broker 配置文件中 mappedFileSizeCommitLog 属性改变文件大小 diff --git a/docs/rocketmq/rocketmq-consumequeue.md b/docs/rocketmq/rocketmq-consumequeue.md index 407c72d..40c6c7d 100644 --- a/docs/rocketmq/rocketmq-consumequeue.md +++ b/docs/rocketmq/rocketmq-consumequeue.md @@ -1,3 +1,5 @@ +该文所涉及的 RocketMQ 源码版本为 4.9.3。 + # RocketMQ ConsumeQueue 详解 RocketMQ 基于主题订阅模式实现消息消费，消费者关注每一个主题下的所有消息，但是同一主题下的消息是不连续地存储在 CommitLog 文件中的，如果消费者直接从消息存储文件中遍历查找主题下的消息，效率会特别低。所以为了在查找消息的时候效率更高一些，设计了 ConsumeQueue 文件，可以看作 CommitLog 消费的目录文件. diff --git a/docs/rocketmq/rocketmq-consumer-start.md b/docs/rocketmq/rocketmq-consumer-start.md index 749e26a..78da74a 100644 --- a/docs/rocketmq/rocketmq-consumer-start.md +++ b/docs/rocketmq/rocketmq-consumer-start.md @@ -1,3 +1,5 @@ +该文所涉及的 RocketMQ 源码版本为 4.9.3。 + # RocketMQ 消费者启动流程 org.apache.rocketmq.client.impl.consumer.DefaultMQPushConsumerImpl#start diff --git a/docs/rocketmq/rocketmq-indexfile.md b/docs/rocketmq/rocketmq-indexfile.md index 0964c0b..45c466b 100644 --- a/docs/rocketmq/rocketmq-indexfile.md +++ b/docs/rocketmq/rocketmq-indexfile.md @@ -1,3 +1,5 @@ +该文所涉及的 RocketMQ 源码版本为 4.9.3。 + # RocketMQ IndexFile 详解 首先明确一下 IndexFile 的文件结构 diff --git a/docs/rocketmq/rocketmq-mappedfile-detail.md b/docs/rocketmq/rocketmq-mappedfile-detail.md index a427df5..0354e96 100644 --- a/docs/rocketmq/rocketmq-mappedfile-detail.md +++ b/docs/rocketmq/rocketmq-mappedfile-detail.md @@ -1,3 +1,5 @@ +该文所涉及的 RocketMQ 源码版本为 4.9.3。 + # RocketMQ MappedFile 内存映射文件详解 1、MappedFile 初始化 diff --git a/docs/rocketmq/rocketmq-nameserver-broker.md b/docs/rocketmq/rocketmq-nameserver-broker.md index 09ea2c0..45993f0 100644 --- a/docs/rocketmq/rocketmq-nameserver-broker.md +++ b/docs/rocketmq/rocketmq-nameserver-broker.md @@ -1,3 +1,5 @@ +该文所涉及的 RocketMQ 源码版本为 4.9.3。 + # RockerMQ Nameserver 如何与 Broker 进行通信的？ nameserver 每隔 10s 扫描一次 Broker，移除处于未激活状态的 Broker diff --git a/docs/rocketmq/rocketmq-producer-start.md b/docs/rocketmq/rocketmq-producer-start.md index 65c9258..804f961 100644 --- a/docs/rocketmq/rocketmq-producer-start.md +++ b/docs/rocketmq/rocketmq-producer-start.md @@ -1,3 +1,5 @@ +该文所涉及的 RocketMQ 源码版本为 4.9.3。 + # RocketMQ 生产者启动流程 入口： diff --git a/docs/rocketmq/rocketmq-pullmessage.md b/docs/rocketmq/rocketmq-pullmessage.md index 5adc02f..55f7f5b 100644 --- a/docs/rocketmq/rocketmq-pullmessage.md +++ b/docs/rocketmq/rocketmq-pullmessage.md @@ -1,3 +1,5 @@ +该文所涉及的 RocketMQ 源码版本为 4.9.3。 + # RocketMQ 消息拉取流程 之前在消费者启动流程中描述过 MQClientInstance 的启动流程，在启动过程中会启动 PullMessageService，它继承了`ServiceThread`，并且 ServiceThread 实现了 Runnable 接口，所以是单独启动了一个线程 diff --git a/docs/rocketmq/rocketmq-send-message.md b/docs/rocketmq/rocketmq-send-message.md index 21a55f9..a97b890 100644 --- a/docs/rocketmq/rocketmq-send-message.md +++ b/docs/rocketmq/rocketmq-send-message.md @@ -1,3 +1,5 @@ +该文所涉及的 RocketMQ 源码版本为 4.9.3。 + # RocketMQ 消息发送流程 这里以同步发送为示例讲解： diff --git a/docs/rocketmq/rocketmq-send-store.md b/docs/rocketmq/rocketmq-send-store.md index d041a2f..f8f870e 100644 --- a/docs/rocketmq/rocketmq-send-store.md +++ b/docs/rocketmq/rocketmq-send-store.md @@ -1,3 +1,5 @@ +该文所涉及的 RocketMQ 源码版本为 4.9.3。 + # RocketMQ 消息发送存储流程 第一步：检查消息存储状态