RocketMQ(4.8.0)——Broker 主從同步機制
Broker 主從同步機制 一、主從同步概述 Broker 有2種角色： Master：主要用於處理生產者、消費者的請求和存儲數據。 Slave：從 Master 同步所有數據到本地。具體體現在以下2個方面 ...
原文：RocketMQ(4.8.0)——Broker 過期文件刪除機制
Broker 過期文件刪除機制 RocketMQ 中主要保存了 CommitLog Consume Queue Index File 三種數據文件。由於內存和磁盤都是有限的資源，Broker 不可能永久地保存所有數據，所以一些超過保存期限的數據會被定期刪除。RocketMQ 通過設置數據過期時間來刪除額外的數據文件，具體的實現邏輯是通過 D: rocketmq master store src m ...
2021-03-01 20:42 0 300 推薦指數：
相關推薦
RocketMQ(4.8.0)——Broker消息存儲機制
Broker消息存儲機制 RocketMQ 使用 CommitLog 文件將消息存儲到磁盤上，那么 RocketMQ 存儲消息到磁盤的過程是怎么樣的呢? RocketMQ 首先將消息數據寫入操作系統 PageCache，然后定時將數據刷入磁盤。 一、Broker 消息存儲的流程是什么 ...
RocketMQ-存儲機制-文件恢復&過期文件刪除
broker過期文件刪除機制 RocketMQ會每隔10秒執行文件清理任務 主要是刪除commitlog和consumequeue文件 commitlog文件刪除 觸發過期文件刪除的條件： 1）達到配置的時間點 2）磁盤用了超過85% 3）手動執行 ...
RocketMQ(4.8.0)——Broker 概述、啟動和停止流程
Broker 概述、啟動和停止流程 Broker 是 RocketMQ 體系中核心組件之一，存儲是 Broker 的核心功能之一，決定整個 RocketMQ 體系的吞吐性能、可靠性和可用性。 一、Broker 概述 1.1 什么是 Broker Broker ...
rocketMQ 刪除過期文件
commitLog 刪除文件的策略指定時間到了，磁盤不足，人工刪除，滿足任一條件，判斷文件是否過期或者磁盤嚴重不足（超過 85%），是則刪除，一批次最多刪除 10 個文件。 有個地方需要注意，mmap 寫文件，windows 觀察，發現文件的修改時間戳一直不變，linux 還未驗證 ...
RocketMQ(4.8.0)——消費進度保存機制
RocketMQ(4.8.0)——消費進度保存機制 在消費者啟動時會同時啟動位點管理器，那么位點具體是怎么管理的呢？ RocketMQ 設計了2種位點管理方式： 遠程位點管理方式（集群消費時，位點由客戶端交給 Broker 保存，代碼路徑：D ...
RocketMQ(4.8.0)——事務消息機制
RocketMQ——事務消息機制 一、事務消息概述 2018 年 07 月 24 日，RocketMQ 社區發布 4.3.0 版本，開始正式支持事務消息。 事務消息的實現方案目前分為2種： 兩階段提交方案 三階段提交方案 ...
RocketMQ：(2) Broker
Broker是RocketMQ的核心，大部分“重量級”工作都是由Broker完成的，包括接收Producer發過來的信息、處理Consumer的消費消息請求、消息的持久化存儲、消息的HA機制以及服務端過濾功能等。 一、消息存儲文件 分布式隊列因為有高可靠性的要求，所以數據要通過磁盤進行 ...