RocketMQ架構原理解析（三）：消息索引（ConsumeQueue & IndexFile）
RocketMQ架構原理解析（一）：整體架構 RocketMQ架構原理解析（二）：消息存儲（CommitLog） RocketMQ架構原理解析（三）：消息索引（ConsumeQueue & IndexFile） RocketMQ架構原理解析（四）：消息生產端（Producer） 一、概述 ...
原文：RocketMQ(3) 根據消息key查詢功能的實現: indexFile
三: indexFile 除了通過通常的指定Topic進行消息消費外，RocketMQ還提供了根據key進行消息查詢的功能。 該查詢是通過store目錄中的index子目錄中的indexFile進行索引實現的快速查詢。 這個indexFile中的索引數據是在如果包含了key的消息被生產者發送到Broker時寫入的。 如果消息中沒有包含key，則不會寫入。 . 索引條目結構 每個Broker中會包含 ...
2022-01-07 10:23 0 832 推薦指數：
相關推薦
rocketMQ retry 消息的實現
consumer 消費失敗，會把消息重新發往 %RETRY% + consumerGroup，這個 retry 消息會在一定時間后，真實送到 retry topic。 broker 處理發送到 retry topic 的消息： 消息消費超過最大次數或者客戶端配置了直接發送到 ...
RocketMQ - 如何實現順序消息
參考文檔： https://xie.infoq.cn/article/fba37afd9bda31fb10eec651f 順序消息的使用場景 日常項目中需要保證順序的應用場景非常多，比如交易場景中的訂單創建、支付、退款等流程，先創建訂單才能支付，支付完成的訂單才能退款，這需要保證先進先出 ...
【--RocketMQ--】RocketMQ實現事務消息
在RocketMQ4.3.0版本后，開放了事務消息這一特性，對於分布式事務而言，最常說的還是二階段提交協議，那么RocketMQ的事務消息又是怎么一回事呢，這里主要帶着以下幾個問題來探究一下RocketMQ的事務消息： 事務消息是如何實現的 我們有哪些手段來監控事務消息的狀態 事務消息 ...
基於Jmeter實現Rocketmq消息發送
、rabbitmq、rocketmq等。今天我主要來介紹下如何使用Jmeter來向rocketmq發送消 ...
RocketMQ事務消息實現分析
這周RocketMQ發布了4.3.0版本，New Feature中最受關注的一點就是支持了事務消息： 今天花了點時間看了下具體的實現內容，下面是簡單的總結。 RocketMQ事務消息概要 通過馮嘉發布的《RocketMQ 4.3正式發布，支持分布式事務》一文可以看到RocketMQ采用 ...
RocketMq延遲消息實現原理
這邊博文介紹Rocketmq的延遲消息的實現管理。文章直接將不會介紹RocketMq的組件，后續將會補上。 首先上圖： 定義用戶topic為study_rocketmq_topic。流程如下： 1.消息 ...
RocketMQ實現事務消息方案
。Apache RocketMQ 4.3之后的版本正式支持事務消息，為分布式事務實現提供了便利性支持。 ...